• gRPC库介绍
    • 参考文档

    gRPC库介绍

    gRPC是一个高性能、通用的开源RPC框架，其由Google主要面向移动应用开发并基于HTTP/2协议标准而设计，基于ProtoBuf(Protocol Buffers)序列化协议开发，且支持众多开发语言。
    gRPC提供了一种简单的方法来精确地定义服务和为iOS、Android和后台支持服务自动生成可靠性很强的客户端功能库。
    客户端充分利用高级流和链接功能，从而有助于节省带宽、降低的TCP链接次数、节省CPU使用、和电池寿命。

    gRPC具有以下重要特征：

    1. 强大的IDL特性
      RPC使用ProtoBuf来定义服务，ProtoBuf是由Google开发的一种数据序列化协议，性能出众，得到了广泛的应用。
    2. 支持多种语言
      支持C++、Java、Go、Python、Ruby、C#、Node.js、Android Java、Objective-C、PHP等编程语言。
    3. 基于HTTP/2标准设计

    gRPC库介绍 - 图1

    gRPC已经应用在Google的云服务和对外提供的API中。

    我们以 gRPC-go 为例介绍一下gRPC的开发。

    首先下载相应的库:

    1. go get google.golang.org/grpc
    2. go get -u github.com/golang/protobuf/{proto,protoc-gen-go}

    同时保证按照Protocol Buffers v3 编译器到你的开发环境中(protoc)。

    定义你的protobuf文件 (helloworld.proto):

    1. syntax = "proto3";
    3. option java_package = "com.colobu.rpctest";
    5. package greeter;
    7. // The greeting service definition.
    8. service Greeter {
    9.   // Sends a greeting
    10.   rpc SayHello (HelloRequest) returns (HelloReply) {}
    11. }
    13. // The request message containing the user's name.
    14. message HelloRequest {
    15.   string name = 1;
    16. }
    18. // The response message containing the greetings
    19. message HelloReply {
    20.   string message = 1;
    21. }

    这个文件定义了一个Greeter服务，它有一个SayHello方法，这个方法接收一个Request，返回一个Response。

    然后我们可以编译这个文件，生成服务器和客户端的stub:

    1. protoc -I protos protos/helloworld.proto --go_out=plugins=grpc:src/greeter

    因为上面我们安装了proto和protoc-gen-go，所以protoc可以生成响应的Go代码。

    然后我们就可以利用这个生成的代码创建服务器代码和客户端代码了。

    服务器端的代码如下：

    1. package main
    3. import (
    4.     "log"
    5.     "net"
    7.     pb "greeter"
    8.     "golang.org/x/net/context"
    9.     "google.golang.org/grpc"
    10. )
    12. const (
    13.     port = ":50051"
    14. )
    16. type server struct{}
    18. // SayHello implements helloworld.GreeterServer
    19. func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {
    20.     return &pb.HelloReply{Message: "Hello " + in.Name}, nil
    21. }
    23. func main() {
    24.     lis, err := net.Listen("tcp", port)
    25.     if err != nil {
    26.         log.Fatalf("failed to listen: %v", err)
    27.     }
    28.     s := grpc.NewServer()
    29.     pb.RegisterGreeterServer(s, &server{})
    30.     s.Serve(lis)
    31. }

    客户端的测试代码如下：

    1. package main
    3. import (
    4.     "fmt"
    5.     "log"
    6.     "os"
    7.     "strconv"
    8.     "sync"
    9.     "time"
    11.     pb "greeter"
    13.     "golang.org/x/net/context"
    14.     "google.golang.org/grpc"
    15. )
    17. const (
    18.     address     = "localhost:50051"
    19.     defaultName = "world"
    20. )
    22. func invoke(c pb.GreeterClient, name string) {
    23.     r, err := c.SayHello(context.Background(), &pb.HelloRequest{Name: name})
    24.     if err != nil {
    25.         log.Fatalf("could not greet: %v", err)
    26.     }
    27.     _ = r
    28. }
    30. func syncTest(c pb.GreeterClient, name string) {
    31.     i := 10000
    32.     t := time.Now().UnixNano()    
    33.     for ; i>0; i-- {
    34.         invoke(c, name)
    35.     }
    36.     fmt.Println("took", (time.Now().UnixNano() - t) / 1000000, "ms")
    37. }
    40. func asyncTest(c [20]pb.GreeterClient, name string) {
    41.     var wg sync.WaitGroup
    42.     wg.Add(10000)
    44.     i := 10000
    45.     t := time.Now().UnixNano()    
    46.     for ; i>0; i-- {
    47.         go func() {invoke(c[i % 20], name);wg.Done()}()
    48.     }    
    49.     wg.Wait()
    50.     fmt.Println("took", (time.Now().UnixNano() - t) / 1000000, "ms")
    51. }
    54. func main() {
    55.     // Set up a connection to the server.
    56.     conn, err := grpc.Dial(address)
    57.     if err != nil {
    58.         log.Fatalf("did not connect: %v", err)
    59.     }
    60.     defer conn.Close()
    61.     var c [20]pb.GreeterClient
    64.     // Contact the server and print out its response.
    65.     name := defaultName
    66.     sync := true
    67.     if len(os.Args) > 1 {
    68.         sync, err = strconv.ParseBool(os.Args[1])
    69.     }
    71.     //warm up
    72.     i := 0
    73.     for ; i < 20; i++ {
    74.         c[i] = pb.NewGreeterClient(conn)
    75.         invoke(c[i], name)
    76.     }
    78.     if sync {
    79.         syncTest(c[0], name)
    80.     } else {
    81.         asyncTest(c, name)
    82.     }
    83. }

    参考文档

    1. http://www.grpc.io/docs/quickstart/go.html
    2. http://www.infoq.com/cn/news/2015/03/grpc-google-http2-protobuf
    3. https://github.com/smallnest/RPC-TEST