go-zero微服务的使用

一、入门案例

1、使用goland创建一个工程

2、新建一个user.proto

syntax = "proto3";package user;
// 这个地方表示生成的go的包名叫user
option go_package = "./user";message UserInfoRequest {int64 userId = 1;
}message UserInfoResponse {int64 userId = 1;string username = 2;
}message UserCreateRequest {string username = 1;string password = 2;
}message UserCreateResponse {string message = 1;
}// 定义两个方法
service Users {rpc UserInfoById(UserInfoRequest) returns(UserInfoResponse);rpc CreateUser(UserCreateRequest) returns(UserCreateResponse);
}// goctl rpc protoc user.proto --go_out=./types --go-grpc_out=./types --zrpc_out=.

3、使用goctl执行生成对应的项目文件

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

4、安装依赖包
5、运行文件go run user.go，不出意外的话肯定会启动后挂的，查看etc/user.yaml文件里面用etcd的服务,但是本地没启动etcd

二、`etcd`的安装

1、github下载地址
2、如果是window电脑，直接下载后解压，运行可执行文件就可以
3、可视界面的安装
4、具体使用可以自己查看文档

三、测试启动的`rpc`端口

1、需要下载一个最新版的apifox(老版的不支持)，创建一个grpc的项目
2、导入你刚刚写的proto文件

在这里插入图片描述

3、测试调用接口

在这里插入图片描述

4、在internal/logic/userinfobyidlogic.go里面补充代码,重启服务继续测试

func (l *UserInfoByIdLogic) UserInfoById(in *user.UserInfoRequest) (*user.UserInfoResponse, error) {// todo: add your logic here and delete this linereturn &user.UserInfoResponse{UserId:   in.UserId,Username: "水痕",}, nil
}

四、`rpc`对接`gorm`数据库操作

1、参考go-zero对数据库的操作，基本步骤都是一样的,这里就不继续重复的工作

2、修改根据用户id查询用户数据方法

func (l *UserInfoByIdLogic) UserInfoById(in *user.UserInfoRequest) (*user.UserInfoResponse, error) {// todo: add your logic here and delete this line//userEntity := &model.UserEntity{}//l.svcCtx.MySqlDb.Where("id = ?", in.UserId).First(&userEntity)userEntity, err := dao.Use(l.svcCtx.MySqlDb).UserEntity.WithContext(l.ctx).Where(dao.Use(l.svcCtx.MySqlDb).UserEntity.ID.Eq(in.UserId)).First()fmt.Println(userEntity, "获取到的数据")return &user.UserInfoResponse{UserId:   userEntity.ID,Username: userEntity.Username,}, err
}

3、继续测试下创建用户的方法

func (l *CreateUserLogic) CreateUser(in *user.UserCreateRequest) (*user.UserCreateResponse, error) {// todo: add your logic here and delete this lineif err := dao.Use(l.svcCtx.MySqlDb).UserEntity.Create(&model.UserEntity{Username: in.Username,Password: in.Password,}); err != nil {return &user.UserCreateResponse{Message: "创建失败",}, nil}return &user.UserCreateResponse{Message: "创建成功",}, nil
}

五、`api`对接`rpc`接口

1、创建一个项目分别创建两个文件夹rpc和api
2、rpc项目和上面介绍的一样的,这里就不继续重复介绍，执行转换脚本
```
goctl rpc protoc user.proto --go_out=types --go-grpc_out=types --zrpc_out=.
```

3、创建一个user.api文件

type CreateRequest {Username string `json:"username"`Password string `json:"password"`
}type CreateResponse {Message string `json:"message"`
}type UserInfoRequest {Id int64 `path:"id"`
}
type UserInfoResponse {Id int64 `json:"id"`Username string `json:"username"`
}// 定义要被方法的方法
service users {@handler createpost /api/users (CreateRequest) returns (CreateResponse)@handler userInfoget /api/users/:id (UserInfoRequest) returns (UserInfoResponse)
}

4、在api/etc/users.yaml文件中添加rpc中配置

Name: users
Host: 0.0.0.0
Port: 8888
# 直接引入etcd的地址就可以,Key直接查看rpc/etc/user.yaml，并且要保持一致
UserRpc:Etcd:Hosts:- 127.0.0.1:2379Key: user.rpc

5、在api/internal/config/config.go中添加user.rpc的配置

package configimport ("github.com/zeromicro/go-zero/rest""github.com/zeromicro/go-zero/zrpc"
)type Config struct {rest.RestConfUserRpc zrpc.RpcClientConf
}

6、 api/internal/svc/servicecontext.go添加rpc的服务配置

package svcimport ("github.com/zeromicro/go-zero/zrpc""zero_demo06_rpc_api/api/internal/config""zero_demo06_rpc_api/rpc/userclient"
)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、在api/internal/logic里面写业务逻辑

func (l *UserInfoLogic) UserInfo(req *types.UserInfoRequest) (resp *types.UserInfoResponse, err error) {// todo: add your logic here and delete this lineuserInfo, err := l.svcCtx.UserRpc.UserInfoById(l.ctx, &user.UserInfoRequest{UserId: req.Id})if err != nil {return &types.UserInfoResponse{}, err}return &types.UserInfoResponse{Id:       userInfo.UserId,Username: userInfo.Username,}, nil
}

func (l *CreateLogic) Create(req *types.CreateRequest) (resp *types.CreateResponse, err error) {// todo: add your logic here and delete this linecreateUser, err := l.svcCtx.UserRpc.CreateUser(l.ctx, &user.UserCreateRequest{Username: req.Username,Password: req.Password,})if err != nil {return nil, err}return &types.CreateResponse{Message: createUser.Message,}, nil
}