grpc-go的介绍：
The Go implementation of gRPC: A high performance, open source, general RPC framework that puts mobile and HTTP/2 first.
github地址
https://github.com/grpc/grpc-go
注意看readme中的安装方式 go get -u google.golang.org/grpc，此处可能需要全局科学上网。
google提供的范例
https://github.com/grpc/grpc-go/tree/master/examples
写个测试程序试试，完整的代码见https://github.com/changjixiong/goNotes/tree/master/grpcnotes 。
创建子目录hello，在目录hello中创建一个hello.proto文件，对着exmaples中的helloworld依葫芦画瓢:
syntax = "proto3";
package hello;
service Hello {
rpc SayHello (HelloRequest) returns (HelloReply) {}
}
message HelloRequest {
int32 num = 1;
}
message HelloReply {
string message = 1;
}
在目录grpcnotes下执行protoc -I hello/ hello/hello.proto --go_out=plugins=grpc:hello
生成hello.pb.go文件
按同样的步骤在创建一个world。
创建子目录echo，在目录echo中创建一个echo.proto文件，对着exmaples/route_guide/routeguide/route_guide.proto文件抄一个stream模式的定义:
syntax = "proto3";
package echo;
service Echo {
rpc SayEcho (EchoRequest) returns (EchoReply) {}
rpc SayEchoS(stream EchoRequest) returns (stream EchoReply) {}
}
message EchoRequest {
int32 num = 1;
}
message EchoReply {
string message = 1;
}
在目录grpcnotes下执行protoc -I echo/ echo/echo.proto --go_out=plugins=grpc:echo
生成echo.pb.go文件。
按照exmaples/helloworld/greeter_server/main.go的例子抄一个，由于这里有3个protobuf对象，所以代码略有不同：
s := grpc.NewServer(
grpc.KeepaliveParams(keepalive.ServerParameters{}),
grpc.MaxConcurrentStreams(10000))
pb.RegisterHelloServer(s, &serverHello{})
pb2.RegisterWorldServer(s, &serverWorld{})
pb3.RegisterEchoServer(s, &serverEcho{})
// Register reflection service on gRPC server.
reflection.Register(s)
client参考exmaples/helloworld/greeter_client/main.go，增加了并发调用，参数风格参考ab测试
编译服务器程序命名为grpcserver，编译客户端程序命名为grpcclient。
运行 ./grpcserver
运行 ./grpcclient -c 1000 -n 100000
输出
550 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
400 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
500 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
50 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
900 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
150 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
300 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
200 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
650 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
250 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
750 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
600 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
800 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
350 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
0 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
850 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
950 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
450 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
100 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
700 sendokNum: 100 recvokNum 100 sendErrNum: 0 recvErrNum: 0 emptyNum: 0
cost: 3.96848528s
有疑问加站长微信联系（非本文作者））
