最简最速搭建grpc分布式服务的Mac系统开发环境
环境详情
golang 1.18
macOS Big Sur
protobuf 3
基本原理
整个RPC过程就是：
客户端 发送数据（以字节流的方式）服务端接收，并解析。 根据约定知道要知道执行什么。然后把结果返回客户端
RPC就是把——
上述过程封装下，使其操作更加优化使用一些大家都认可的协议 使其规范化
那么——GRPC框架中采用了protobuf作为这个过程中消息传递的数据结构。
什么是 Protobuf
Protobuf是Protocol Buffers的简称，它是Google公司开发的一种数据描述语言，用于描述一种轻便高效的结构化数据存储格式，并于2008年对外开源。Protobuf可以用于结构化数据串行化，或者说序列化。它的设计非常适用于在网络通讯中的数据载体，很适合做数据存储或 RPC 数据交换格式，它序列化出来的数据量少再加上以 K-V 的方式来存储数据，对消息的版本兼容性非常强，可用于通讯协议、数据存储等领域的语言无关、平台无关、可扩展的序列化结构数据格式。开发者可以通过Protobuf附带的工具生成代码并实现将结构化数据序列化的功能。
本教程将在接下来的内容中描述 .proto 文件的语法以及如何通过 .proto 文件生成数据访问类和 grpc 服务类，并以此为基础搭建简易的 grpc 服务端开发环境。
工具安装
新建工程，选择 go modules，配置 GOPROXY 等操作不再赘述;
下载grpc依赖
go get -u google.golang.org/grpc@v1.51.0
brew 安装 protocol
brew install protobuf
安装后可以执行命令protoc，作为protocol编译器使用，能够通过中间文件 .proto 转译成各种语言的grpc文件
brew install protoc-gen-go
转译中间文件成go文件的插件
brew install protoc-gen-go-grpc
转译中间文件成go-grpc文件的插件。
注意：如果安装失败那可能是依赖安装失败，直接brew intall 安装依赖即可。
至此，工具和依赖安装完毕，接下来将构建工程。
环境搭建
工程 go-rpc-server 结构:
.
├── client.go ——用于编写客户端测试
├── go.mod
├── go.sum
├── main.go ——服务端的启动
├── pbfiles ——该目录用于放置原始proto文件
│ └── Prod.proto
├── services ——该目录用于放置转译出的go文件
首先新建 .proto 文件，该示例中演示用于展示商品库存的 API，因此取名为 Prod.proto ；
编辑有如下内容 ：
syntax="proto3";option go_package ="go-rpc-server/services"; //相对路径 和protoc的flag go_out拼接//package services; //该选项配置后 客户端请求需要多加上services.的路径messageProdRequest {int32 prod_id =1; //传入的商品ID}message ProdResponse{int32 prod_stock=1;//商品库存}//这里的内容其实可以独立配置一个.proto文件，因为 rpc 服务类的文件会独立于数据访问类service ProdService {rpc GetProdStock (ProdRequest) returns (ProdResponse);}
文档参考 Protocol Buffer Basics: Go
随后通过protoc生成——
1.数据访问类
protoc --go_out=./../ pbfiles/Prod.proto
2.rpc服务类
protoc --go-grpc_out=./../ pbfiles/Prod.proto
若报错
file
只需要在proto文件中加入
option go_package ="go-rpc-server/services";
指定中间文件生成go文件的路径即可。
编写服务类的实现
值得一提的是从某个版本开始，服务类的实现接口发生了以下变化：
type ProdServiceServer interface { GetProdStock(context.Context, *ProdRequest) (*ProdResponse, error) mustEmbedUnimplementedProdServiceServer() //这里是新增的}
并且在生成的 grpc 服务类中有——
type UnimplementedProdServiceServer struct {}func (UnimplementedProdServiceServer) GetProdStock(context.Context, *ProdRequest) (*ProdResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetProdStock not implemented")}func (UnimplementedProdServiceServer) mustEmbedUnimplementedProdServiceServer() {}
实现了上述接口；官方推荐我们在实现服务类时，嵌套该结构体。
因此有以下实现：
type ProdService struct { UnimplementedProdServiceServer}func (ps *ProdService) GetProdStock(context.Context, *ProdRequest) (*ProdResponse, error) { return &ProdResponse{ProdStock: 233}, nil}
接口返回了我们的 mock 数据；
启动服务
编写 main 函数，通过 net 包进行监听, 执行 go run main.go
func main() { rpcServer := grpc.NewServer() services.RegisterProdServiceServer(rpcServer, new(services.ProdService)) lis, _ := net.Listen("tcp", ":8087") rpcServer.Serve(lis)}
至此，我们的 grpc 服务端环境搭建完毕。
客户端测试
多的不说，直接上客户端代码：
func main() { cli, _ := grpc.DialContext(context.Background(), "localhost:8087", grpc.WithTransportCredentials(insecure.NewCredentials()), ) req := &services.ProdRequest{} rsp := &services.ProdResponse{} err := cli.Invoke(context.Background(), "/ProdService/GetProdStock", req, rsp) if err != nil { log.Fatal(err) } fmt.Println(rsp.ProdStock)}
执行go run client.go，于是有：
file
搞定！
本文由博客一文多发平台 OpenWrite 发布！
页:
[1]