Golang 语言怎么使用 go-micro 和 gin 开发微服务？

大家好，我是 frank。
欢迎大家点击上方蓝色文字「Golang 语言开发栈」关注公众号。
设为星标，第一时间接收推送文章。
文末扫码，和大家一起学 Golang 语言。

01 

介绍

Go Micro 是一个分布式系统开发框架。Go Micro 提供了分布式系统开发的核心需求，包括 RPC 和事件驱动的通信。Gin 是一个用 Golang 编写的 web 框架。本文首先介绍怎么使用 go-micro 和 go-grpc 构建微服务，然后再介绍怎么集成 gin 和 go-micro。我们使用的 go-micro 版本是 v1.18.0，golang 版本是 v1.13，gin 版本是 v1.7.2。

02 

使用 go-micro 和 go-grpc 构建微服务

在我们开始使用 go-micro 之前，我们还需要提前做一些准备工作。安装 protoc、protoc-gen-go 和 protoc-gen-micro，关于如何安装，读者朋友们可以参阅官方文档，我们在之前的文章中也介绍过，限于篇幅，本文不再赘述。

其实，我们可以使用 Go Micro 工具集以命令的方式快速生成模板文件，但是因为本文我们不准备介绍工具集的相关内容，所以我们使用手动创建文件的方式。

下面我们正式开始介绍如何构建服务，包括服务端服务和客户端服务。

服务端

服务端代码目录：

├── go.mod
├── go.sum
├── handler
│   └── user
│       └── user.go
├── main.go
└── proto
    └── user
        ├── user.pb.go
        ├── user.pb.micro.go
        └── user.proto

构建服务端服务，分为以下几个步骤：

1. 编写 protobuf 文件

   第一步是编写 protobuf 文件，一般会将不同 package 的 protobuf 文件存放在单独的文件目录中。

   文件路径：proto/user/user.proto

   syntax = "proto3";
   
   package user;
   
   service User {
     rpc Login(LoginRequest) returns (LoginResponse) {}
   }
   
   message LoginRequest {
     string email = 1;
     string password = 2;
   }
   
   message LoginResponse {
     string username = 1;
   }
   

   阅读上面这段代码，我们在定义的 user.proto 文件中，创建了一个 rpc 服务。

2. 生成文件

   第二步是生成文件，使用命令：

   protoc --proto_path=. --micro_out=. --go_out=. user.proto
   

   执行以上命令，将会自动生成两个文件，分别是 user.pb.go 和 user.micro.go。

   阅读 user.micro.go 文件，可以发现在该文件中已经自动生成了客户端和服务端的代码。

3. 编写 handler

   第三步是编写服务端的 handler 代码。

   文件路径：handler/user/user.go

   type User struct{}
   
   func (u *User) Login(ctx context.Context, req *protoUser.LoginRequest, rsp *protoUser.LoginResponse) error {
     if req.Email != "[email protected]" || req.Password != "123456" {
       rsp.Username = "Sorry " + req.Email
       return nil
     }
     rsp.Username = "Welcome " + req.Email
     return nil
   }
   

4. 定义服务端服务

   第四步是定义服务端服务，需要注意的是，这里使用的是 grpc。在 main.go 文件中编写如下代码：

   文件路径：main.go

   func main() {
     // 创建服务
     service := grpc.NewService(
       micro.Name("go.micro.srv.demo"),
       micro.Version("v0.0.0"),
       micro.RegisterTTL(time.Second * 10),
       micro.RegisterInterval(time.Second * 5),
     )
     // 注册处理器
     err := protoUser.RegisterUserHandler(service.Server(), new(user.User))
     if err !=nil {
       log.Fatal(err)
     }
     // 运行服务
     if err = service.Run(); err != nil {
       log.Fatal(err)
     }
   }
   

完成以上 4 个步骤，我们就已经实现了服务端 rpc 服务，接下来，我们开始编写客户端代码。

客户端

客户端代码目录：

├── go.mod
├── go.sum
├── main.go
├── proto
│   └── user
│       ├── user.pb.go
│       ├── user.pb.micro.go
│       └── user.proto
└── router
    ├── router.go
    └── v1
        └── user.go

构建客户端服务，分为以下几个步骤：

1. 拷贝 proto 文件和生成文件

   第一步是拷贝服务端的 proto 文件和生成文件，目的是为了保证服务端和客户端的类型一致性。

2. 定义客户端服务

   第二步是定义客户端：

   文件路径：router/v1/user.go

   func NewUserClient() protoUser.UserService {
     // 创建服务
     service := grpc.NewService()
   
     // 创建客户端
     userClient := protoUser.NewUserService("go.micro.srv.demo", service.Client())
   
     return userClient
   }
   

3. rpc 调用远程服务的方法

   第三步是 rpc 调用远程服务的方法：

   文件路径：router/v1/user.go

   client := NewUserClient()
   
   // rpc 调用远程服务的方法
   resp, err := client.Login(context.TODO(), &protoUser.LoginRequest{Email: param.Email, Password: param.Password})
   if err != nil {
     fmt.Println(err)
   }
   

完成以上 3 步，我们就已经基本编写完客户端的代码。

03 

gin 和 go-micro 集成

接下来，我们介绍如何集成 gin 和 go-micro，该部分代码也是在客户端中，共需要两个步骤。

1. 创建路由

   文件路径：router/router.go

   func NewRouter() *gin.Engine {
     r := gin.New()
     
     userControllerV1 := new(v1.User)
   
     // 路由分组
     v1 := r.Group("/v1")
     {
       v1.Use(gin.Logger(), gin.Recovery())
       userV1 := v1.Group("/user")
       {
         userV1.POST("/login", userControllerV1.Login)
       }
     }
   
     return r
   }
   

2. 启动（监听）服务

   文件路径：main.go

   func main() {
     r := router.NewRouter()
     server := &http.Server{
       Addr:           ":8080",
       Handler:        r,
       ReadTimeout:    time.Second * 10,
       WriteTimeout:   time.Second * 10,
       MaxHeaderBytes: 1 << 20,
     }
     if err := server.ListenAndServe(); err != nil {
       log.Fatal(err)
     }
   }
   

至此，我们已经完成了集成 gin 和 go-micro，启动服务端服务和客户端服务后，我们就可以使用以下命令进行 cURL 测试：

curl --location --request POST 'http://127.0.0.1:8080/v1/user/login' \
--header 'Content-Type: application/json' \
--data-raw '{
    "email": "[email protected]",
    "password": "123456"
}'

04 

总结

本文我们主要介绍怎么使用 go-micro 和 go-grpc 构建微服务，和怎么集成 gin 和 go-micro，并没有介绍 gin 和 go-micro 的使用方法，如果读者朋友们还不了解 gin 和 go-micro，建议先阅读 gin 和 go-micro 官方文档，也可以参考公众号之前推送的关于 gin 的文章。

「阅读完整代码，请点击阅读原文。」

推荐阅读：

Golang 语言中怎么解码 4 种常见JSON 格式数据？

Golang 语言中的 defer 怎么使用？

Golang 语言是面向对象编程风格的编程语言吗？

Golang 语言中 kafka 客户端库 sarama

Golang 语言怎么使用 panic 函数？

参考资料：
https://github.com/asim/go-micro 
https://gin-gonic.com/zh-cn/docs/introduction/ 

扫描二维码，加入微信群