整个迭代过程会围绕着两个核心思想进行:

  1. 关注技术选型背后的思想。虽然最终某个技术选型的可能并不是你喜欢的方案(如RPC、日志、数据库等,你可以fork后自行调整),但我们更关注各个技术组件背后的原理与思想,选择的过程比结果更重要
  2. 聚焦于简单,关注可维护性。技术框架是项目的基础设施,也是排查复杂业务问题的根本,所以框架层的功能会尽量考虑简单易用,可以让我们花更多的心思在业务开发中。许多开源库提供了大量扩展功能,但我们使用时会尽量克制,减少学习和排查问题时的成本。

微服务框架系列重点介绍框架的搭建过程,期间对一些细节技术点的讲解,会在另一个系列Go语言技巧系列中展开。

v0.1.0:搭建gRPC+HTTP的双重网关服务

项目链接

gRPC-gateway官方Github

有很多朋友更喜欢使用Gin框架,但我依然选择了gRPC-gateway。 主要在于gRPC-gateway方案对接Google提供的各种开源插件生态都很棒。大家会在后面框架的迭代过程中慢慢体会到它的特性。 后续我也会对Gin做一些分析。

目标

完成RPC服务的框架的搭建

关键技术点

protobufferbufGoGo

目录构造

--- micro_web_service            项目目录
 |-- gen                            从idl文件夹中生成的文件,不可手动修改
    |-- idl                             对应idl文件夹
       |-- demo                             对应idl/demo服务
          |-- demo.pb.go                        demo.proto的基础结构
          |-- demo.pb.gw.go                     demo.proto的HTTP接口,对应gRPC-Gateway
          |-- demo_grpc.pb.go                   demo.proto的gRPC接口代码
 |-- idl                            原始的idl定义
    |-- demo                            业务package定义
       |-- demo.proto                       protobuffer的原始定义
 |-- internal                       项目的内部代码,不对外暴露
    |-- server                          服务器的实现
       |-- demo.go                          server中对demo这个服务的接口实现
       |-- server.go                        server的定义,须实现对应服务的方法
 |-- buf.gen.yaml                   buf生成代码的定义
 |-- buf.yaml                       buf工具安装所需的工具
 |-- gen.sh                         buf生成的shell脚本
 |-- go.mod                         Go Module文件
 |-- main.go                        项目启动的main函数

1. protobuffer定义IDL

demo.proto
message DemoRequest {
   string value = 1;
}

message DemoResponse {
   int32 code = 1;
}

// 样例服务
service DemoService {
  // Echo 样例接口
  rpc Echo(DemoRequest) returns (DemoResponse) {
    option (google.api.http) = {
      post : "/apis/demo"
      body : "*"
    };
  }
}
protobufferDemoRequestDemoResponse

2. buf工具生成Go代码

gen.shgen
proto

buf工具的安装请参考README.md,它是protoc的演进版本,不再需要大量flag参数,更加简单易用。 注意,如果修改了模块名,buf工具第一次初始化建议使用 buf beta mod init 指令

3.Go项目实现RPC服务

Go
buf.gen.yamlgo-grpcgrpc-gatewaygRPCHTTPdemo.protogen/idl/demo*_grpc.pb.go*.pb.gw.gogRPCHTTPmaindemo.RegisterDemoServiceServer(s, &server.Server{})demo.RegisterDemoServiceHandlerFromEndpoint(ctx, mux, *grpcServerEndpoint, opts)internal/server/server.goserver.Serverprotodemo.UnsafeDemoServiceServerinternal/server/demo.gofunc (s *Server) Echo(ctx context.Context, req *demo.DemoRequest) (*demo.DemoResponse, error)

项目运行

我们用简单的命令来运行,并用RPC访问

# 编译并运行
go build && ./micro_web_service 

# 模拟HTTP请求
curl --location --request POST 'http://127.0.0.1:8081/apis/demo'
# 收到返回值 {"code":0}

# 而gRPC比较麻烦,是私有协议,我们查看一下对应的网络端口,发现正在监听,也就意味着正常运行
netstat -an | grep 9090
tcp4       0      0  127.0.0.1.9090         127.0.0.1.49266        ESTABLISHED
tcp4       0      0  127.0.0.1.49266        127.0.0.1.9090         ESTABLISHED
tcp46      0      0  *.9090                 *.*                    LISTEN 

项目的私有化

由于本项目只是一个框架,如果你希望修改为个人的项目,主要改动点在两处:

go.modGoprotogo_package

建议用编辑工具全量替换

新增接口示例

添加proto定义

message EmptyMessage {
}

// Empty 空接口
rpc Empty(EmptyMessage) returns (EmptyMessage) {
  option (google.api.http) = {
    post : "/apis/empty"
    body : "*"
  };
}

生成Go文件

bash gen.sh

添加接口定义

main.goserver.ServerEmptyinternal/server/demo.go
func (s *Server) Empty(ctx context.Context, req *demo.EmptyMessage) (*demo.EmptyMessage, error) {
 return &demo.EmptyMessage{}, nil
}

测试新接口

# 编译并运行
go build && ./micro_web_service 

# 模拟HTTP请求
curl --location --request POST 'http://127.0.0.1:8081/apis/empty'
# 返回 {} 

总结

v0.1.0
HTTPgRPCEcho
gRPC-Gateway

Github: https://github.com/Junedayday/code_reading Blog: http://junes.tech/ Bilibili: https://space.bilibili.com/293775192 公众号: golangcoding