gRPC是什么？

复制
gRPC是一个高性能、开源、通用的RPC框架，面向移动和HTTP/2设计
支持多语言：C++、C#、Dart、Go、Java、Node.js、Objective-c、PHP、Python、Ruby
特点：HTTP/2、Protobuf、客户端、服务的基于同一份IDL、移动网络的良好支持、支持多语言

图解调用过程：

1、客户端（gRPC Stub）发起发起 RPC 调用

2、对请求参数使用 Protobuf 进行对象序列化（IDL）

3、服务端（gRPC Server）接收到请求后，解码请求体，进行业务逻辑处理并返回

4、对响应结果使用 Protobuf 进行对象序列化（IDL）

5、客户端接受到服务端响应，解码请求体，返回响应结果

入门示例

首先需要安装

gRPC：

复制
go get -u google.golang.org/grpc

Protocol Buffers v3

复制
wget https://github.com/google/protobuf/releases/download/v3.5.1/protobuf-all-3.5.1.zip
unzip protobuf-all-3.5.1.zip
cd protobuf-3.5.1/
./configure
make
make install

验证安装是否成功：

复制
protoc --version

Protoc Plugin:

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

首先我们新建 hello.proto

复制
syntax = "proto3";
 
package proto;
option go_package = "/";
 
service HelloService {
  rpc Hello(HelloRequest) returns (HelloResponse) {}
}
 
message HelloRequest {
  string request = 1;
}
 
message HelloResponse {
  string response = 1;
}

其中 option go_package 是指定go包，不然执行编译时会报错：

protoc-gen-go: unable to determine Go import path for "hello.proto"

然后再该文件目录下执行：

复制
protoc --go_out=plugins=grpc:. *.proto

该命令会在目录下生成 hello.pb.go 文件

新建 server.go 文件，并写入以下内容

复制
package main
 
    import ("context""google.golang.org/grpc""log""net""proto"
)
 
type HelloService struct {}
 
func (s *HelloService) Hello(ctx context.Context, r *proto.HelloRequest) (*proto.HelloResponse, error) {
    return &pb.HelloResponse{Response: "Hello " + r.GetRequest()}, nil
}
 
const PORT = "8088"
 
func main()  {
    server := grpc.NewServer()
 
    proto.RegisterHelloServiceServer(server, &HelloService{})
 
    lis, err := net.Listen("tcp", ":"+PORT)if err != nil {
        log.Fatalf("net.listen err: %v", err)}
 
    server.Serve(lis)
}

新建client.go文件，并写入以下内容：

复制
package main
 
import ("context""google.golang.org/grpc""proto""log")
 
const PORT = "8088"
 
func main()  {
    conn, err := grpc.Dial(":" + PORT, grpc.WithInsecure())if err != nil {
        log.Fatalf("grpc.Dial err: %v", err)}defer conn.Close()
 
    client := proto.NewHelloServiceClient(conn)
    resp, err := client.Hello(context.Background(), &proto.HelloRequest{
        Request: "gRPC",})if err != nil {
        log.Fatalf("client.Search err:%v", err)}
 
    log.Printf("resp: %s", resp.GetResponse())
}

启动server

复制
go run server.go

启动client

复制
go run client.go

输出：

复制
$ go run client.go
2021/04/25 15:07:27 resp: Hello gRPC