go-zero微服务入门案例

一、go-zero微服务环境安装

• 1、go-zero脚手架的安装

  go install github.com/zeromicro/go-zero/tools/goctl@latest
  

• 2、etcd的安装下载地址根据自己电脑操作系统下载对应的版本，具体的使用自己查阅文章

二、创建一个user-rpc服务

• 1、定义user.proto文件

  syntax = "proto3";package user;
  option go_package="./user";service User {rpc FindById(FindByIdReq) returns (FindByIdResp);
  }message FindByIdReq{int64 id = 1;
  }message FindByIdResp {int64 id = 1;string username = 2;
  }
  

• 2、使用命令生成对应的项目文件

  goctl rpc protoc ./user.proto --go_out=. --go-grpc_out=. --zrpc_out=./
  

• 3、安装对应的依赖包

  go mod tidy
  

• 4、运行user服务

  go run user.go

• 5、在etcd中查看服务是否已经注册成功

  etcdctl get --prefix user.rpc
  

• 6、模拟业务代码返回数据

  func (l *FindByIdLogic) FindById(in *user.FindByIdReq) (*user.FindByIdResp, error) {return &user.FindByIdResp{Id:       in.Id,Username: "哈哈哈",}, nil
  }
  

• 7、使用apifox可以直接调用rpc的服务,引入文件

  

三、在提供restful api接口端调用rpc服务返回数据给前端

• 1、创建一个user-api的项目

• 2、创建描述文件

  syntax = "v1"type GetUserReq {Id int64 `path:"id"` // 主键id
  }type GetUserResp {Id int64 `json:"id"`              // 用户idUsername string `json:"username"` // 用户名
  }
  @server(prefix: api/v1/usergroup: user
  )
  service user-api {@doc "根据用户id获取用户新"@handler GetUserByIdApiget /:id (GetUserReq) returns (GetUserResp)
  }
  

• 3、使用脚本生成对应的项目文件

  goctl api go -api *.api -dir . --style=gozero
  

• 4、在user-api的配置文件中引入rpc服务的配置

  Name: user-api
  Host: 0.0.0.0
  Port: 8888UserRpc:Etcd:Hosts:- 127.0.0.1:2379Key: user.rpc
  

• 5、在apps/user-api/internal/config/config.go创建服务的配置

  type Config struct {rest.RestConfUserRpc zrpc.RpcClientConf
  }
  

• 6、在apps/user-api/internal/svc/servicecontext.go依赖注入rpc服务

  type ServiceContext struct {Config  config.ConfigUserRpc userclient.User
  }func NewServiceContext(c config.Config) *ServiceContext {return &ServiceContext{Config:  c,UserRpc: userclient.NewUser(zrpc.MustNewClient(c.UserRpc)),}
  }
  

• 7、模拟实现业务代码

  func (l *GetUserByIdApiLogic) GetUserByIdApi(req *types.GetUserReq) (resp *types.GetUserResp, err error) {// 模拟业务开发findByIdResp, err := l.svcCtx.UserRpc.FindById(l.ctx, &user.FindByIdReq{Id: req.Id,})if err != nil {return &types.GetUserResp{}, errors.New("查询失败")}return &types.GetUserResp{Id:       findByIdResp.Id,Username: findByIdResp.Username,}, nil
  }
  

• 8、直接浏览模拟请求http://localhost:8888/api/v1/user/1