本篇内容介绍了“Go gRPC怎么实现Simple RPC”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
前言
gRPC主要有4种请求和响应模式,分别是简单模式(Simple RPC)、服务端流式(Server-side streaming RPC)、客户端流式(Client-side streaming RPC)、和双向流式(Bidirectional streaming RPC)。
简单模式(Simple RPC):客户端发起请求并等待服务端响应。
服务端流式(Server-side streaming RPC):客户端发送请求到服务器,拿到一个流去读取返回的消息序列。 客户端读取返回的流,直到里面没有任何消息。
客户端流式(Client-side streaming RPC):与服务端数据流模式相反,这次是客户端源源不断的向服务端发送数据流,而在发送结束后,由服务端返回一个响应。
双向流式(Bidirectional streaming RPC):双方使用读写流去发送一个消息序列,两个流独立操作,双方可以同时发送和同时接收。
新建proto文件
定义发送消息的信息
message SimpleRequest{ // 定义发送的参数,采用驼峰命名方式,小写加下划线,如:student_name string data = 1;//发送数据}
定义响应信息
message SimpleResponse{ // 定义接收的参数 // 参数类型 参数名 标识号(不可重复) int32 code = 1; //状态码 string value = 2;//接收值}
定义服务方法Route
// 定义我们的服务(可定义多个服务,每个服务可定义多个接口)service Simple{ rpc Route (SimpleRequest) returns (SimpleResponse){};}
编译proto文件
我这里使用上一篇介绍的VSCode-proto3插件,保存后自动编译。
指令编译方法,进入simple.proto文件所在目录,运行:
protoc --go_out=plugins=grpc:./ ./simple.proto
创建Server端
定义我们的服务,并实现Route方法
import ("context""log""net""google.golang.org/grpc"pb "go-grpc-example/proto")// SimpleService 定义我们的服务type SimpleService struct{}// Route 实现Route方法func (s *SimpleService) Route(ctx context.Context, req *pb.SimpleRequest) (*pb.SimpleResponse, error) {res := pb.SimpleResponse{Code: 200,Value: "hello " + req.Data,}return &res, nil}
该方法需要传入RPC的上下文context.Context,它的作用结束超时或取消的请求。更具体的说请参考该文章
启动gRPC服务器
const (// Address 监听地址Address string = ":8000"// Network 网络通信协议Network string = "tcp")func main() {// 监听本地端口listener, err := net.Listen(Network, Address)if err != nil {log.Fatalf("net.Listen err: %v", err)}log.Println(Address + " net.Listing...")// 新建gRPC服务器实例grpcServer := grpc.NewServer()// 在gRPC服务器注册我们的服务pb.RegisterSimpleServer(grpcServer, &SimpleService{})//用服务器 Serve() 方法以及我们的端口信息区实现阻塞等待,直到进程被杀死或者 Stop() 被调用err = grpcServer.Serve(listener)if err != nil {log.Fatalf("grpcServer.Serve err: %v", err)}}
里面每个方法的作用都有注释,这里就不解析了。
运行服务端
go run server.go:8000 net.Listing...
创建Client端
import ("context""log""google.golang.org/grpc"pb "go-grpc-example/proto")const (// Address 连接地址Address string = ":8000")func main() {// 连接服务器conn, err := grpc.Dial(Address, grpc.WithInsecure())if err != nil {log.Fatalf("net.Connect err: %v", err)}defer conn.Close()// 建立gRPC连接grpcClient := pb.NewSimpleClient(conn)// 创建发送结构体req := pb.SimpleRequest{Data: "grpc",}// 调用我们的服务(Route方法)// 同时传入了一个 context.Context ,在有需要时可以让我们改变RPC的行为,比如超时/取消一个正在运行的RPCres, err := grpcClient.Route(context.Background(), &req)if err != nil {log.Fatalf("Call Route err: %v", err)}// 打印返回值log.Println(res)}
运行客户端
go run client.gocode:200 value:"hello grpc"
成功调用Server端的Route方法并获取返回的数据。
“Go gRPC怎么实现Simple RPC”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注编程网网站,小编将为大家输出更多高质量的实用文章!