go语言中的gRPC（一）

初识protobuf 1、protobuf 介绍

Protobuf是Protocol Buffer的简称，它是Google公司于2008年开源的一种高效的平台无关、语言无关、可扩展的数据格式，目前Protobuf作为接口规范的描述语言。是一种轻便高效的结构化数据存储格式，可以用于结构化数据序列化，很适合做数据存储或 RPC 数据交换格式。

2、protobuf 对应go数据类型

.proto Type	Go Type
double	float64
float	float32
int32	int32
uint32	uint32
uint64	uint64
sint32	int32
sint64	int64
fixed32	uint32
fixed64	uint64
sfixed32	int32
sfixed64	int64
bool	bool
string	string
bytes	[]byte
repeated string	[]string

使用protobuf 1、相关工具安装（windows） 1.1安装 protoc

下载地址：https://github.com/protocolbuffers/protobuf/releases/tag/v3.15.5

下载完成后，解压，bin目录下有个 protoc.exe 文件，将这个目录加入环境变量

测试是否安装成功

protoc --version

显示版本号代表安装成功

1.2安装 protoc-gen-go

go get -u github.com/golang/protobuf/protoc-gen-go

运行完了后在你的 GOPATH/bin 目录会下生成 protoc-gen-go.exe 文件

1.3配置环境变量

要想在全局使用，需要把 GOPATH/bin目录配置到环境变量中

2、简单介绍

gRPC有四种交换模式，分别是：

简单模式服务端流式客户端流式双向流式

3、简单模式的gPRC示例 3.1创建 *.proto 文件

新建 simple.proto 文件

syntax = "proto3";

package proto;

// 定义发送请求信息
message SimpleRequest{
  // 参数类型 参数名称 标识号
  string name = 1;
  repeated string data = 2;
}

// 定义响应信息
message SimpleResponse{
  int32 code = 1;
  string msg = 2;
}

// 定义我们的服务(可以定义多个服务，每个服务可以定义多个接口)
service Simple{
  rpc GetSimpleInfo(SimpleRequest) returns (SimpleResponse){};
}

3.2编译 *.proto 文件

# protoc --go_out=plugins=grpc:. 文件名
protoc --go_out=plugins=grpc:. simple.proto

编译完成后会出现一下个 simple.pb.go 文件
扩展：编译时如果出现一下错误，可以尝试下面的方法

① 在*.proto文件中加上： option go_package = “/proto”
option go_package是指定将其输入到哪个文件
② 老版本的proto-gen-go，使用命令切换为 v1.3.2 版本
go get -u github.com/golang/protobuf/protoc-gen-go@v1.3.2

打开simple.pb.go文件如果文件报错就用go mod tidy加载一下依赖包

3.3创建服务端文件

新建一个server.go文件

package main

import (
	"context"
	"google.golang.org/grpc"
	"log"
	"net"
	pb "simple/proto"
)

const (
	Addr string = ":50001"
	Network string = "tcp"
)

// 定义我们的服务
type SimpleService struct{}

// 实现 GetSimpleInfo 方法
func (s *SimpleService) GetSimpleInfo(ctx context.Context, req *pb.SimpleRequest) (*pb.SimpleResponse, error) {
	name := req.Name
	data := req.Data
	log.Println("获取来自客户端的：我是", name, data)
	resp := &pb.SimpleResponse{
		Code:  200,
		Msg: "grpc",
	}
	return resp, nil
}

func main() {
	// 1.监听端口
	listener, err := net.Listen(Network, Addr)
	if err != nil {
		log.Fatalf("net.listen err: %v", err)
	}
	log.Println(Addr, " net listening...")
	// 2.实例化gRPC服务端
	grpcServer := grpc.NewServer()
	// 3.注册我们实现的服务 SimpleService
	pb.RegisterSimpleServer(grpcServer, &SimpleService{})
	// 4.启动gRPC服务端
	err = grpcServer.Serve(listener)
	if err != nil {
		log.Fatalf("grpc server err: %v",err)
	}
}

3.4创建客户端文件

新建一个client.go文件

package main

import (
	"context"
	"google.golang.org/grpc"
	"log"
	pb "simple/proto"
)

const (
	Address string = ":50001"
)

func main() {
	// 1.创建于gRPC服务端的连接
	conn, err := grpc.Dial(Address, grpc.WithInsecure())
	if err != nil {
		log.Fatalf("dial conn err: %v", err)
	}
	defer conn.Close()
	// 2.创建grpc客户端
	client := pb.NewSimpleClient(conn)
	// 3.调用服务端提供的服务
	req := pb.SimpleRequest{
		Name: "客户端",
		Data: []string{"Hello word"},
	}
	resp, err := client.GetSimpleInfo(context.Background(), &req)
	if err != nil {
		log.Fatalf("resp err: %v", err)
	}
	log.Printf("获取服务端的响应,code: %v,msg: %v", resp.Code, resp.Msg)
}

3.5运行测试

1.启动服务端

2.启动客户端

看到服务端能接收到客户端的请求并响应就成功了。