gRPC初体验

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

本作品采用《CC 协议》，转载必须注明作者和本文链接