我是如何用 go-zero 实现一个中台系统

作者:Jack Luo

原文连接:https://www.cnblogs.com/jackluo/p/14148518.html

最近发现golang社区里出了一个新星的微服务框架,来自好未来,光看这个名字,就很有奔头,之前,也只是玩过go-micro,其实真正的还没有在项目中运用过,只是觉得 微服务,grpc 这些很高大尚,还没有在项目中,真正的玩过,我看了一下官方提供的工具真的很好用,只需要定义好,舒适文件jia结构 都生成了,只需要关心业务,加上最近 有个投票的活动,加上最近这几年中台也比较火,所以决定玩一下,

开源地址: https://github.com/jackluo2012/datacenter

先聊聊中台架构思路吧:

我是如何用go-zero 实现一个中台系统 - 图1

中台的概念大概就是把一个一个的app 统一起来,反正我是这样理解的。

先聊用户服务吧,现在一个公司有很多的公众号、小程序、微信的、支付宝的,还有 xxx xxx,很多的平台,每次开发的时候,我们总是需要做用户登陆的服务,不停的复制代码,然后我们就在思考能不能有一套独立的用户服务,只需要告诉我你需要传个你要登陆的平台(比如微信),微信登陆,需要的是客户端返回给服务端一个code ,然后服务端拿着这个code去微信获取用户信息,反正大家都明白。

我们决定,将所有的信息弄到配置公共服务中去,里面再存微信、支付宝以及其它平台的appid、appkey、还有支付的appid、appkey,这样就写一套。


最后说说实现吧,整个就一个repo:

  • 网关,我们用的是: go-zero的Api服务
  • 其它它的是服务,我们就是用的go-zero的rpc服务

看下目录结构

我是如何用go-zero 实现一个中台系统 - 图2

整个项目完成,我一个人操刀,写了1个来星期,我就实现了上面的中台系统。

datacenter-api服务

先看官方文档 https://go-zero.dev/cn/

我们先把网关搭建起来:

  1. blogs mkdir datacenter && cd datacenter
  2. datacenter go mod init datacenter
  3. go: creating new go.mod: module datacenter
  4. datacenter

查看book目录:

  1. datacenter tree
  2. .
  3. └── go.mod
  4. 0 directories, 1 file

创建api文件

  1. datacenter goctl api -o datacenter.api
  2. Done.
  3. datacenter tree
  4. .
  5. ├── datacenter.api
  6. ├── user.api #用户
  7. ├── votes.api #投票
  8. ├── search.api #搜索
  9. ├── questions.api #问答
  10. └── go.mod

定义api服务

分别包含了上面的 公共服务用户服务投票活动服务

datacenter.api的内容:

  1. info(
  2. title: "中台系统"// TODO: add title
  3. desc: "中台系统"// TODO: add description
  4. author: "jackluo"
  5. email: "net.webjoy@gmail.com"
  6. )
  7. import "user.api"
  8. import "votes.api"
  9. import "search.api"
  10. import "questions.api"
  11. //获取 应用信息
  12. type Beid {
  13. Beid int64 `json:"beid"`
  14. }
  15. type Token {
  16. Token string `json:"token"`
  17. }
  18. type WxTicket {
  19. Ticket string `json:"ticket"`
  20. }
  21. type Application {
  22. Sname string `json:"Sname"` //名称
  23. Logo string `json:"logo"` // login
  24. Isclose int64 `json:"isclose"` //是否关闭
  25. Fullwebsite string `json:"fullwebsite"` // 全站名称
  26. }
  27. type SnsReq {
  28. Beid
  29. Ptyid int64 `json:"ptyid"` //对应平台
  30. BackUrl string `json:"back_url"` //登陆返回的地址
  31. }
  32. type SnsResp {
  33. Beid
  34. Ptyid int64 `json:"ptyid"` //对应平台
  35. Appid string `json:"appid"` //sns 平台的id
  36. Title string `json:"title"` //名称
  37. LoginUrl string `json:"login_url"` //微信登陆的地址
  38. }
  39. type WxShareResp {
  40. Appid string `json:"appid"`
  41. Timestamp int64 `json:"timestamp"`
  42. Noncestr string `json:"noncestr"`
  43. Signature string `json:"signature"`
  44. }
  45. @server(
  46. group: common
  47. )
  48. service datacenter-api {
  49. @doc(
  50. summary: "获取站点的信息"
  51. )
  52. @handler appInfo
  53. get /common/appinfo (Beid) returns (Application)
  54. @doc(
  55. summary: "获取站点的社交属性信息"
  56. )
  57. @handler snsInfo
  58. post /common/snsinfo (SnsReq) returns (SnsResp)
  59. //获取分享的
  60. @handler wxTicket
  61. post /common/wx/ticket (SnsReq) returns (WxShareResp)
  62. }
  63. //上传需要登陆
  64. @server(
  65. jwt: Auth
  66. group: common
  67. )
  68. service datacenter-api {
  69. @doc(
  70. summary: "七牛上传凭证"
  71. )
  72. @handler qiuniuToken
  73. post /common/qiuniu/token (Beid) returns (Token)
  74. }

user.api内容

  1. //注册请求
  2. type RegisterReq struct {
  3. // TODO: add members here and delete this comment
  4. Mobile string `json:"mobile"` //基本一个手机号码就完事
  5. Password string `json:"password"`
  6. Smscode string `json:"smscode"` //短信码
  7. }
  8. //登陆请求
  9. type LoginReq struct{
  10. Mobile string `json:"mobile"`
  11. Type int64 `json:"type"` //1.密码登陆,2.短信登陆
  12. Password string `json:"password"`
  13. }
  14. //微信登陆
  15. type WxLoginReq struct {
  16. Beid int64 `json:"beid"` //应用id
  17. Code string `json:"code"` //微信登陆密钥
  18. Ptyid int64 `json:"ptyid"` //对应平台
  19. }
  20. //返回用户信息
  21. type UserReply struct {
  22. Auid int64 `json:"auid"`
  23. Uid int64 `json:"uid"`
  24. Beid int64 `json:"beid"` //应用id
  25. Ptyid int64 `json:"ptyid"` //对应平台
  26. Username string `json:"username"`
  27. Mobile string `json:"mobile"`
  28. Nickname string `json:"nickname"`
  29. Openid string `json:"openid"`
  30. Avator string `json:"avator"`
  31. JwtToken
  32. }
  33. //返回APPUser
  34. type AppUser struct{
  35. Uid int64 `json:"uid"`
  36. Auid int64 `json:"auid"`
  37. Beid int64 `json:"beid"` //应用id
  38. Ptyid int64 `json:"ptyid"` //对应平台
  39. Nickname string `json:"nickname"`
  40. Openid string `json:"openid"`
  41. Avator string `json:"avator"`
  42. }
  43. type LoginAppUser struct{
  44. Uid int64 `json:"uid"`
  45. Auid int64 `json:"auid"`
  46. Beid int64 `json:"beid"` //应用id
  47. Ptyid int64 `json:"ptyid"` //对应平台
  48. Nickname string `json:"nickname"`
  49. Openid string `json:"openid"`
  50. Avator string `json:"avator"`
  51. JwtToken
  52. }
  53. type JwtToken struct {
  54. AccessToken string `json:"access_token,omitempty"`
  55. AccessExpire int64 `json:"access_expire,omitempty"`
  56. RefreshAfter int64 `json:"refresh_after,omitempty"`
  57. }
  58. type UserReq struct{
  59. Auid int64 `json:"auid"`
  60. Uid int64 `json:"uid"`
  61. Beid int64 `json:"beid"` //应用id
  62. Ptyid int64 `json:"ptyid"` //对应平台
  63. }
  64. type Request {
  65. Name string `path:"name,options=you|me"`
  66. }
  67. type Response {
  68. Message string `json:"message"`
  69. }
  70. @server(
  71. group: user
  72. )
  73. service datacenter-api {
  74. @handler ping
  75. post /user/ping ()
  76. @handler register
  77. post /user/register (RegisterReq) returns (UserReply)
  78. @handler login
  79. post /user/login (LoginReq) returns (UserReply)
  80. @handler wxlogin
  81. post /user/wx/login (WxLoginReq) returns (LoginAppUser)
  82. @handler code2Session
  83. get /user/wx/login () returns (LoginAppUser)
  84. }
  85. @server(
  86. jwt: Auth
  87. group: user
  88. middleware: Usercheck
  89. )
  90. service datacenter-api {
  91. @handler userInfo
  92. get /user/dc/info (UserReq) returns (UserReply)
  93. }

votes.api 投票内容

  1. // 投票活动api
  2. type Actid struct {
  3. Actid int64 `json:"actid"` //活动id
  4. }
  5. type VoteReq struct {
  6. Aeid int64 `json:"aeid"` // 作品id
  7. Actid
  8. }
  9. type VoteResp struct {
  10. VoteReq
  11. Votecount int64 `json:"votecount"` //投票票数
  12. Viewcount int64 `json:"viewcount"` //浏览数
  13. }
  14. // 活动返回的参数
  15. type ActivityResp struct {
  16. Actid int64 `json:"actid"`
  17. Title string `json:"title"` //活动名称
  18. Descr string `json:"descr"` //活动描述
  19. StartDate int64 `json:"start_date"` //活动时间
  20. EnrollDate int64 `json:"enroll_date"` //投票时间
  21. EndDate int64 `json:"end_date"` //活动结束时间
  22. Votecount int64 `json:"votecount"` //当前活动的总票数
  23. Viewcount int64 `json:"viewcount"` //当前活动的总浏览数
  24. Type int64 `json:"type"` //投票方式
  25. Num int64 `json:"num"` //投票几票
  26. }
  27. //报名
  28. type EnrollReq struct {
  29. Actid
  30. Name string `json:"name"` // 名称
  31. Address string `json:"address"` //地址
  32. Images []string `json:"images"` //作品图片
  33. Descr string `json:"descr"` // 作品描述
  34. }
  35. // 作品返回
  36. type EnrollResp struct {
  37. Actid
  38. Aeid int64 `json:"aeid"` // 作品id
  39. Name string `json:"name"` // 名称
  40. Address string `json:"address"` //地址
  41. Images []string `json:"images"` //作品图片
  42. Descr string `json:"descr"` // 作品描述
  43. Votecount int64 `json:"votecount"` //当前活动的总票数
  44. Viewcount int64 `json:"viewcount"` //当前活动的总浏览数
  45. }
  46. @server(
  47. group: votes
  48. )
  49. service datacenter-api {
  50. @doc(
  51. summary: "获取活动的信息"
  52. )
  53. @handler activityInfo
  54. get /votes/activity/info (Actid) returns (ActivityResp)
  55. @doc(
  56. summary: "活动访问+1"
  57. )
  58. @handler activityIcrView
  59. get /votes/activity/view (Actid) returns (ActivityResp)
  60. @doc(
  61. summary: "获取报名的投票作品信息"
  62. )
  63. @handler enrollInfo
  64. get /votes/enroll/info (VoteReq) returns (EnrollResp)
  65. @doc(
  66. summary: "获取报名的投票作品列表"
  67. )
  68. @handler enrollLists
  69. get /votes/enroll/lists (Actid) returns(EnrollResp)
  70. }
  71. @server(
  72. jwt: Auth
  73. group: votes
  74. middleware: Usercheck
  75. )
  76. service datacenter-api {
  77. @doc(
  78. summary: "投票"
  79. )
  80. @handler vote
  81. post /votes/vote (VoteReq) returns (VoteResp)
  82. @handler enroll
  83. post /votes/enroll (EnrollReq) returns (EnrollResp)
  84. }

questions.api 问答内容:

  1. // 问答 抽奖 开始
  2. @server(
  3. group: questions
  4. )
  5. service datacenter-api {
  6. @doc(
  7. summary: "获取活动的信息"
  8. )
  9. @handler activitiesInfo
  10. get /questions/activities/info (Actid) returns (ActivityResp)
  11. @doc(
  12. summary: "获取奖品信息"
  13. )
  14. @handler awardInfo
  15. get /questions/award/info (Actid) returns (ActivityResp)
  16. @handler awardList
  17. get /questions/award/list (Actid) returns (ActivityResp)
  18. }
  19. type AnswerReq struct {
  20. ActivityId int64 `json:"actid"`
  21. Answers string `json:"answers"`
  22. Score string `json:"score"`
  23. }
  24. type QuestionsAwardReq struct {
  25. ActivityId int64 `json:"actid"`
  26. AnswerId int64 `json:"answerid"`
  27. }
  28. type AnswerResp struct {
  29. Answers string `json:"answers"`
  30. Score string `json:"score"`
  31. }
  32. type AwardConvertReq struct {
  33. UserName string `json:"username"`
  34. Phone string `json:"phone"`
  35. LotteryId int64 `json:"lotteryid"`
  36. }
  37. @server(
  38. jwt: Auth
  39. group: questions
  40. middleware: Usercheck
  41. )
  42. service datacenter-api {
  43. @doc(
  44. summary: "获取题目"
  45. )
  46. @handler lists
  47. get /questions/lists (VoteReq) returns (AnswerResp)
  48. @doc(
  49. summary: "提交答案"
  50. )
  51. @handler change
  52. post /questions/change (AnswerReq) returns (VoteResp)
  53. @doc(
  54. summary: "获取分数"
  55. )
  56. @handler grade
  57. get /questions/grade (VoteReq) returns (VoteResp)
  58. @doc(
  59. summary: "开始转盘"
  60. )
  61. @handler turntable
  62. post /questions/lottery/turntable (EnrollReq) returns (EnrollResp)
  63. @doc(
  64. summary: "填写中奖信息人"
  65. )
  66. @handler lottery
  67. post /questions/lottery/convert (AwardConvertReq) returns (EnrollResp)
  68. }
  69. // 问答 抽奖 结束

search.api 搜索

  1. type SearchReq struct {
  2. Keyword string `json:"keyword"`
  3. Page string `json:"page"`
  4. Size string `json:"size"`
  5. }
  6. type SearchResp struct {
  7. Data []ArticleReq `json:"data"`
  8. }
  9. type ArticleReq struct{
  10. NewsId string `json:"NewsId"`
  11. NewsTitle string `json:"NewsTitle"`
  12. ImageUrl string `json:"ImageUrl"`
  13. }
  14. @server(
  15. group: search
  16. middleware: Admincheck
  17. )
  18. service datacenter-api {
  19. @doc(
  20. summary: "搜索"
  21. )
  22. @handler article
  23. get /search/article (SearchReq) returns (SearchResp)
  24. @handler articleInit
  25. get /search/articel/init (SearchReq) returns (SearchResp)
  26. @handler articleStore
  27. post /search/articel/store (ArticleReq) returns (ArticleReq)
  28. }

上面基本上写就写的API及文档的思路

生成datacenter api服务

  1. datacenter goctl api go -api datacenter.api -dir .
  2. Done.
  3. datacenter treer
  4. .
  5. ├── datacenter.api
  6. ├── etc
  7. └── datacenter-api.yaml
  8. ├── go.mod
  9. ├── internal
  10. ├── config
  11. └── config.go
  12. ├── handler
  13. ├── common
  14. ├── appinfohandler.go
  15. ├── qiuniutokenhandler.go
  16. ├── snsinfohandler.go
  17. ├── votesverificationhandler.go
  18. └── wxtickethandler.go
  19. ├── routes.go
  20. ├── user
  21. ├── code2sessionhandler.go
  22. ├── loginhandler.go
  23. ├── pinghandler.go
  24. ├── registerhandler.go
  25. ├── userinfohandler.go
  26. └── wxloginhandler.go
  27. └── votes
  28. ├── activityicrviewhandler.go
  29. ├── activityinfohandler.go
  30. ├── enrollhandler.go
  31. ├── enrollinfohandler.go
  32. ├── enrolllistshandler.go
  33. └── votehandler.go
  34. ├── logic
  35. ├── common
  36. ├── appinfologic.go
  37. ├── qiuniutokenlogic.go
  38. ├── snsinfologic.go
  39. ├── votesverificationlogic.go
  40. └── wxticketlogic.go
  41. ├── user
  42. ├── code2sessionlogic.go
  43. ├── loginlogic.go
  44. ├── pinglogic.go
  45. ├── registerlogic.go
  46. ├── userinfologic.go
  47. └── wxloginlogic.go
  48. └── votes
  49. ├── activityicrviewlogic.go
  50. ├── activityinfologic.go
  51. ├── enrollinfologic.go
  52. ├── enrolllistslogic.go
  53. ├── enrolllogic.go
  54. └── votelogic.go
  55. ├── middleware
  56. └── usercheckmiddleware.go
  57. ├── svc
  58. └── servicecontext.go
  59. └── types
  60. └── types.go
  61. └── datacenter.go
  62. 14 directories, 43 files

我们打开 etc/datacenter-api.yaml 把必要的配置信息加上

  1. Name: datacenter-api
  2. Log:
  3. Mode: console
  4. Host: 0.0.0.0
  5. Port: 8857
  6. Auth:
  7. AccessSecret: 你的jwtwon Secret
  8. AccessExpire: 86400
  9. CacheRedis:
  10. - Host: 127.0.0.1:6379
  11. Pass: 密码
  12. Type: node
  13. UserRpc:
  14. Etcd:
  15. Hosts:
  16. - 127.0.0.1:2379
  17. Key: user.rpc
  18. CommonRpc:
  19. Etcd:
  20. Hosts:
  21. - 127.0.0.1:2379
  22. Key: common.rpc
  23. VotesRpc:
  24. Etcd:
  25. Hosts:
  26. - 127.0.0.1:2379
  27. Key: votes.rpc

上面的 UserRpcCommonRpc ,还有 VotesRpc 这些我先写上,后面再来慢慢加。

我们先来写 CommonRpc 服务。

CommonRpc服务

新建项目目录

  1. datacenter mkdir -p common/rpc && cd common/rpc

直接就新建在了,datacenter目录中,因为common 里面,可能以后会不只会提供rpc服务,可能还有api的服务,所以又加了rpc目录

goctl创建模板

  1. rpc goctl rpc template -o=common.proto
  2. rpc ls
  3. common.proto

往里面填入内容:

  1. rpc cat common.proto
  2. syntax = "proto3";
  3. option go_package = "common";
  4. package common;
  5. message BaseAppReq{
  6. int64 beid=1;
  7. }
  8. message BaseAppResp{
  9. int64 beid=1;
  10. string logo=2;
  11. string sname=3;
  12. int64 isclose=4;
  13. string fullwebsite=5;
  14. }
  15. // 请求的api
  16. message AppConfigReq {
  17. int64 beid=1;
  18. int64 ptyid=2;
  19. }
  20. // 返回的值
  21. message AppConfigResp {
  22. int64 id=1;
  23. int64 beid=2;
  24. int64 ptyid=3;
  25. string appid=4;
  26. string appsecret=5;
  27. string title=6;
  28. }
  29. service Common {
  30. rpc GetAppConfig(AppConfigReq) returns(AppConfigResp);
  31. rpc GetBaseApp(BaseAppReq) returns(BaseAppResp);
  32. }

gotcl生成rpc服务

  1. rpc goctl rpc proto -src common.proto -dir .
  2. protoc -I=/Users/jackluo/works/blogs/datacenter/common/rpc common.proto --go_out=plugins=grpc:/Users/jackluo/works/blogs/datacenter/common/rpc/common
  3. Done.
  1. rpc tree
  2. .
  3. ├── common
  4. └── common.pb.go
  5. ├── common.go
  6. ├── common.proto
  7. ├── commonclient
  8. └── common.go
  9. ├── etc
  10. └── common.yaml
  11. └── internal
  12. ├── config
  13. └── config.go
  14. ├── logic
  15. ├── getappconfiglogic.go
  16. └── getbaseapplogic.go
  17. ├── server
  18. └── commonserver.go
  19. └── svc
  20. └── servicecontext.go
  21. 8 directories, 10 files

基本上,就把所有的目录规范和结构的东西都生成了,就不用纠结项目目录了,怎么放了,怎么组织了。

看一下,配置信息,里面可以写入mysql和其它redis的信息:

  1. Name: common.rpc
  2. ListenOn: 127.0.0.1:8081
  3. Mysql:
  4. DataSource: root:admin@tcp(127.0.0.1:3306)/datacenter?charset=utf8&parseTime=true&loc=Asia%2FShanghai
  5. CacheRedis:
  6. - Host: 127.0.0.1:6379
  7. Pass:
  8. Type: node
  9. Etcd:
  10. Hosts:
  11. - 127.0.0.1:2379
  12. Key: common.rpc

我们再来加上数据库服务:

  1. rpc cd ..
  2. common ls
  3. rpc
  4. common pwd
  5. /Users/jackluo/works/blogs/datacenter/common
  6. common goctl model mysql datasource -url="root:admin@tcp(127.0.0.1:3306)/datacenter" -table="base_app" -dir ./model -c
  7. Done.
  8. common tree
  9. .
  10. ├── model
  11. ├── baseappmodel.go
  12. └── vars.go
  13. └── rpc
  14. ├── common
  15. └── common.pb.go
  16. ├── common.go
  17. ├── common.proto
  18. ├── commonclient
  19. └── common.go
  20. ├── etc
  21. └── common.yaml
  22. └── internal
  23. ├── config
  24. └── config.go
  25. ├── logic
  26. ├── getappconfiglogic.go
  27. └── getbaseapplogic.go
  28. ├── server
  29. └── commonserver.go
  30. └── svc
  31. └── servicecontext.go
  32. 10 directories, 12 files

这样基本的一个 rpc 就写完了,然后我们将rpc 和model 还有api串连起来,这个官方的文档已经很详细了,这里就只是贴一下代码:

  1. common cat rpc/internal/config/config.go
  2. package config
  3. import (
  4. "github.com/zeromicro/go-zero/core/stores/cache"
  5. "github.com/zeromicro/go-zero/zrpc"
  6. )
  7. type Config struct {
  8. zrpc.RpcServerConf
  9. Mysql struct {
  10. DataSource string
  11. }
  12. CacheRedis cache.ClusterConf
  13. }

再在svc中修改:

  1. common cat rpc/internal/svc/servicecontext.go
  2. package svc
  3. import (
  4. "datacenter/common/model"
  5. "datacenter/common/rpc/internal/config"
  6. "github.com/zeromicro/go-zero/core/stores/sqlx"
  7. )
  8. type ServiceContext struct {
  9. c config.Config
  10. AppConfigModel model.AppConfigModel
  11. BaseAppModel model.BaseAppModel
  12. }
  13. func NewServiceContext(c config.Config) *ServiceContext {
  14. conn := sqlx.NewMysql(c.Mysql.DataSource)
  15. apm := model.NewAppConfigModel(conn, c.CacheRedis)
  16. bam := model.NewBaseAppModel(conn, c.CacheRedis)
  17. return &ServiceContext{
  18. c: c,
  19. AppConfigModel: apm,
  20. BaseAppModel: bam,
  21. }
  22. }

上面的代码已经将 rpcmodel 数据库关联起来了,我们现在再将 rpcapi 关联起来:

  1. datacenter cat internal/config/config.go
  2. package config
  3. import (
  4. "github.com/zeromicro/go-zero/core/stores/cache"
  5. "github.com/zeromicro/go-zero/rest"
  6. "github.com/zeromicro/go-zero/zrpc"
  7. )
  8. type Config struct {
  9. rest.RestConf
  10. Auth struct {
  11. AccessSecret string
  12. AccessExpire int64
  13. }
  14. UserRpc zrpc.RpcClientConf
  15. CommonRpc zrpc.RpcClientConf
  16. VotesRpc zrpc.RpcClientConf
  17. CacheRedis cache.ClusterConf
  18. }

加入 svc 服务中:

  1. datacenter cat internal/svc/servicecontext.go
  2. package svc
  3. import (
  4. "context"
  5. "datacenter/common/rpc/commonclient"
  6. "datacenter/internal/config"
  7. "datacenter/internal/middleware"
  8. "datacenter/shared"
  9. "datacenter/user/rpc/userclient"
  10. "datacenter/votes/rpc/votesclient"
  11. "fmt"
  12. "net/http"
  13. "time"
  14. "github.com/zeromicro/go-zero/core/logx"
  15. "github.com/zeromicro/go-zero/core/stores/cache"
  16. "github.com/zeromicro/go-zero/core/stores/redis"
  17. "github.com/zeromicro/go-zero/core/syncx"
  18. "github.com/zeromicro/go-zero/rest"
  19. "github.com/zeromicro/go-zero/zrpc"
  20. "google.golang.org/grpc"
  21. )
  22. type ServiceContext struct {
  23. Config config.Config
  24. GreetMiddleware1 rest.Middleware
  25. GreetMiddleware2 rest.Middleware
  26. Usercheck rest.Middleware
  27. UserRpc userclient.User //用户
  28. CommonRpc commonclient.Common
  29. VotesRpc votesclient.Votes
  30. Cache cache.Cache
  31. RedisConn *redis.Redis
  32. }
  33. func timeInterceptor(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error {
  34. stime := time.Now()
  35. err := invoker(ctx, method, req, reply, cc, opts...)
  36. if err != nil {
  37. return err
  38. }
  39. fmt.Printf("调用 %s 方法 耗时: %v\n", method, time.Now().Sub(stime))
  40. return nil
  41. }
  42. func NewServiceContext(c config.Config) *ServiceContext {
  43. ur := userclient.NewUser(zrpc.MustNewClient(c.UserRpc, zrpc.WithUnaryClientInterceptor(timeInterceptor)))
  44. cr := commonclient.NewCommon(zrpc.MustNewClient(c.CommonRpc, zrpc.WithUnaryClientInterceptor(timeInterceptor)))
  45. vr := votesclient.NewVotes(zrpc.MustNewClient(c.VotesRpc, zrpc.WithUnaryClientInterceptor(timeInterceptor)))
  46. //缓存
  47. ca := cache.NewCache(c.CacheRedis, syncx.NewSharedCalls(), cache.NewCacheStat("dc"), shared.ErrNotFound)
  48. rcon := redis.NewRedis(c.CacheRedis[0].Host, c.CacheRedis[0].Type, c.CacheRedis[0].Pass)
  49. return &ServiceContext{
  50. Config: c,
  51. GreetMiddleware1: greetMiddleware1,
  52. GreetMiddleware2: greetMiddleware2,
  53. Usercheck: middleware.NewUserCheckMiddleware().Handle,
  54. UserRpc: ur,
  55. CommonRpc: cr,
  56. VotesRpc: vr,
  57. Cache: ca,
  58. RedisConn: rcon,
  59. }
  60. }

这样基本上,我们就可以在 logic 的文件目录中调用了:

  1. cat internal/logic/common/appinfologic.go
  2. package logic
  3. import (
  4. "context"
  5. "datacenter/internal/svc"
  6. "datacenter/internal/types"
  7. "datacenter/shared"
  8. "datacenter/common/model"
  9. "datacenter/common/rpc/common"
  10. "github.com/zeromicro/go-zero/core/logx"
  11. )
  12. type AppInfoLogic struct {
  13. logx.Logger
  14. ctx context.Context
  15. svcCtx *svc.ServiceContext
  16. }
  17. func NewAppInfoLogic(ctx context.Context, svcCtx *svc.ServiceContext) AppInfoLogic {
  18. return AppInfoLogic{
  19. Logger: logx.WithContext(ctx),
  20. ctx: ctx,
  21. svcCtx: svcCtx,
  22. }
  23. }
  24. func (l *AppInfoLogic) AppInfo(req types.Beid) (appconfig *common.BaseAppResp, err error) {
  25. //检查 缓存中是否有值
  26. err = l.svcCtx.Cache.GetCache(model.GetcacheBaseAppIdPrefix(req.Beid), appconfig)
  27. if err != nil && err == shared.ErrNotFound {
  28. appconfig, err = l.svcCtx.CommonRpc.GetBaseApp(l.ctx, &common.BaseAppReq{
  29. Beid: req.Beid,
  30. })
  31. if err != nil {
  32. return
  33. }
  34. err = l.svcCtx.Cache.SetCache(model.GetcacheBaseAppIdPrefix(req.Beid), appconfig)
  35. }
  36. return
  37. }

这样,基本就连接起来了,其它基本上就不用改了,UserRPCVotesRPC 类似,这里就不在写了。

使用心得

go-zero 的确香,因为它有一个 goctl 的工具,他可以自动的把代码结构全部的生成好,我们就不再去纠结,目录结构 ,怎么组织,没有个好几年的架构能力是不好实现的,有什么规范那些,并发,熔断,完全不用,考虑其它的,专心的实现业务就好,像微服务,还要有服务发现,一系列的东西,都不用关心,因为 go-zero 内部已经实现了。

我写代码也写了有10多年了,之前一直用的 php,比较出名的就 laravel,thinkphp,基本上就是模块化的,像微服务那些实现真的有成本,但是你用上go-zero,你就像调api接口一样简单的开发,其它什么服务发现,那些根本就不用关注了,只需要关注业务。

一个好的语言,框架,他们的底层思维,永远都是效率高,不加班的思想,我相信go-zero会提高你和你团队或是公司的效率。go-zero的作者说,他们有个团队专门整理go-zero框架,目的也应该很明显,那就是提高,他们自己的开发效率,流程化,标准化,是提高工作效率的准则,像我们平时遇到了问题,或是遇到了bug,我第一个想到的不是怎么去解决我的bug,而是在想我的流程是不是有问题,我的哪个流程会导致bug,最后我相信 go-zero 能成为 微服务开发 的首选框架。

最后说说遇到的坑吧:

  • grpc

grpc 本人第一次用,然后就遇到了,有些字符为空时,字段值不显示的问题:

通过 grpc 官方库中的 jsonpb 来实现,官方在它的设定中有一个结构体用来实现 protoc buffer 转换为JSON结构,并可以根据字段来配置转换的要求。

  • 跨域问题

go-zero 中设置了,感觉没有效果,大佬说通过nginx 设置,后面发现还是不行,最近强行弄到了一个域名下,后面有时间再解决。

  • sqlx

go-zerosqlx 问题,这个真的费了很长的时间:

time.Time 这个数据结构,数据库中用的是 timestamp 这个 比如我的字段 是delete_at 默认数库设置的是null ,结果插入的时候,就报了 Incorrect datetime value: '0000-00-00' for column 'deleted_at' at row 1"} 这个错,查询的时候报 deleted_at\": unsupported Scan, storing driver.Value type \u003cnil\u003e into type *time.Time" 后面果断去掉了这个字段,字段上面加上 .omitempty 这个标签,好像也有用,db:".omitempty"

其次就是这个 Conversion from collation utf8_general_ci into utf8mb4_unicode_ci,这个导致的大概原因是,现在都喜欢用emj表情了,mysql数据识别不了。

  • 数据连接

mysql 这边照样按照原始的方式,将配置文件修改编码格式,重新创建数据库,并且设置数据库编码为utf8mb4,排序规则为 utf8mb4_unicode_ci

这样的话,所有的表还有string字段都是这个编码格式,如果不想所有的都是,可以单独设置,这个不是重点.因为在navicat上都好设置,手动点一下就行了

重点来了:golang中使用的是 github.com/go-sql-driver/mysql 驱动,将连接 mysqldsn(因为我这使用的是gorm,所以dsn可能跟原生的格式不太一样,不过没关系, 只需要关注 charsetcollation 就行了) root:password@/name?parseTime=True&loc=Local&charset=utf8 修改为: root:password@/name?parseTime=True&loc=Local&charset=utf8mb4&collation=utf8mb4_unicode_ci