Grpc介绍 — ProToBuf基本使用
Grpc介绍 — ProToBuf基本使用
RPC（Remote Procedure Call）远程过程调用，关注笔者的同学应该知道之前笔者出过关于Thrift对应的问题，这次主要来说的是Google开源的Grpc，和Thrift有很大的区别Grpc是基于HTTP2.0并且依赖protobuf，为什么又推出关于grpc的文章呢？请大家继续往下看。
附上:
喵了个咪的博客：w-blog.cn
博文实例demo：GitHub - sunmi-OS/grpc-php-to-golang-demo
grpc官网：grpc / grpc.io
protobuf代码仓库：Releases · protocolbuffers/protobuf · GitHub
一，为什么要用grpc它的优势是什么
一个高性能、通用的开源RPC框架，其由Google主要面向移动应用开发并基于HTTP/2协议标准而设计，基于ProtoBuf(Protocol Buffers)序列化协议开发，且支持众多开发语言。 gRPC基于HTTP/2标准设计，带来诸如双向流控、头部压缩、单TCP连接上的多复用请求等特性。这些特性使得其在移动设备上表现更好，更省电和节省空间占用。
性能 Grpc PK Thrift 借鉴：开源RPC（gRPC/Thrift）框架性能评测 - 沧海一滴 - 博客园
PS：笔者也做了对应的性能测试，后面的文章会附上详细步骤，通过这个现有的结果一个简单的结论
从压测的结果商米我们可以得到以下重要结论：
- 整体上看，长连接性能优于短连接，性能差距在两倍以上；
- 对比Go语言的两个RPC框架，Thrift性能明显优于gRPC，性能差距也在两倍以上；
- 对比Thrift框架下的的两种语言，长连接下Go 与C++的RPC性能基本在同一个量级，在短连接下，Go性能大概是C++的二倍；
- 两套RPC框架，以及两大语言运行都非常稳定，5w次请求耗时约是1w次的5倍；
这里主要要回答的一个问题是既然已经用thrift并且性能还是grpc的2倍为什么还要用grpc呢？
这里主要要说到两个Go的微服务框架，go-kit和istio
- go-kit 支持thrift但是在thrift的情况下不支持链路追踪
- istio因为是无侵入式连thrift也不支持
主要的导致这个问题的原因在于thrift的传输方式是通过TCP的方式传输，对于这些框架想在传输过程中加入些链路的ID是无法实现的，istio连对于thrift的请求次数感知都做不到，对于grpc因为是基于http2在harder头上可以做很多补充参数，对于这类微服务框架非常友好。
二，安装protobuf
安装protobuf为了生成对应语言的文件必须需要protoc的命名，protoc是c语言的protobuf的命名，有两种访问一个是自己编译:
wget https://github.com/protocolbuffers/protobuf/releases/download/v3.6.1/protobuf-cpp-3.6.1.tar.gz
> tar -zxvf protobuf-cpp-3.6.1.tar.gz
> cd protobuf-3.6.1
> ./configure
> make
> make install
> protoc --version
libprotoc 3.6.1或者根据更具系统直接使用编译好的bin文件运行protoc（这里使用的是MAC OSX系统）
wget https://github.com/protocolbuffers/protobuf/releases/download/v3.6.1/protoc-3.6.1-osx-x86_64.zip
> tar -zxvf protoc-3.6.1-osx-x86_64.zip
> cd protoc-3.6.1-osx-x86_6/bin
> ./protoc --version
> libprotoc 3.6.1安装好了我们就要来运行下测试程序了
三，Golang 环境准备
不得不说Go是Google的亲儿子，自然Grpc的支持不会差依赖只需要一个命令就可以（这里使用的是go 1.11版本）：
> go get google.golang.org/grpc如果大家报错，原因是这个代码已经转移到github上面了，但是代码里面的包依赖还是没有修改，还是google.golang.org这种，所以有的不能使用go get的方式安装，可以使用以下安装方式：
> git clone https://github.com/grpc/grpc-go.git $GOPATH/src/google.golang.org/grpc
> git clone https://github.com/golang/net.git $GOPATH/src/golang.org/x/net
> git clone https://github.com/golang/text.git $GOPATH/src/golang.org/x/text
> git clone https://github.com/golang/sys.git $GOPATH/src/golang.org/x/sys
> go get -u github.com/golang/protobuf/{proto,protoc-gen-go}
> git clone https://github.com/google/go-genproto.git $GOPATH/src/google.golang.org/genproto
> cd $GOPATH/src/
> go install google.golang.org/grpc先使用笔者的准备好的：
> cd $GOPATH/src
> mkdir -p grpc-php-to-golang-demo/protobuf
> cd grpc-php-to-golang-demo/protobuf
> vim helloworld.proto文件内容如下：
syntax = "proto3";
option java_multiple_files = true;
option java_package = "io.grpc.examples.helloworld";
option java_outer_classname = "HelloWorldProto";
option objc_class_prefix = "HLW";
package helloworld;
// The greeting service definition.
service Greeter {
// Sends a greeting
rpc SayHello (HelloRequest) returns (HelloReply) {}
}
// The request message containing the user's name.
message HelloRequest {
string name = 1;
}
// The response message containing the greetings
message HelloReply {
string message = 1;
}生成对应的文件：
> mkdir -p go-server/helloworld
> protoc --go_out=plugins=grpc:./go-server/helloworld ./helloworld.proto
> cd go-server/helloworld/
> ll
total 16
drwxr-xr-x 3 wenzhenxi staff 96 2 15 14:24 ./
drwxr-xr-x 3 wenzhenxi staff 96 2 15 14:23 ../
-rw-r--r-- 1 wenzhenxi staff 6915 2 15 14:24 helloworld.pb.go编写服务端和客户端Go程序：
> cd $GOPATH/src/grpc-php-to-golang-demo
> mkdir -p golang/holleworld
> cd golang/holleworld服务端：
> vim server.go
package main
import (
"log"
"net"
pb "grpc-php-to-golang-demo/protobuf/go-server/helloworld"
"google.golang.org/grpc"
"golang.org/x/net/context"
"google.golang.org/grpc/reflection"
)
const (
port = ":50051"
)
// server is used to implement helloworld.GreeterServer.
type server struct{}
// SayHello implements helloworld.GreeterServer
func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {
return &pb.HelloReply{Message: "Hello " + in.Name}, nil
}
func main() {
lis, err := net.Listen("tcp", port)
if err != nil {
log.Fatalf("failed to listen: %v", err)
}
s := grpc.NewServer()
pb.RegisterGreeterServer(s, &server{})
// Register reflection service on gRPC server.
reflection.Register(s)
if err := s.Serve(lis); err != nil {
log.Fatalf("failed to serve: %v", err)
}
}客户端：
> vim client.go
package main
import (
"log"
"os"
"time"
pb "grpc-php-to-golang-demo/protobuf/go-server/helloworld"
"google.golang.org/grpc"
"golang.org/x/net/context"
)
const (
address = "localhost:50051"
defaultName = "world"
)
func main() {
// Set up a connection to the server.
conn, err := grpc.Dial(address, grpc.WithInsecure())
if err != nil {
log.Fatalf("did not connect: %v", err)
}
defer conn.Close()
c := pb.NewGreeterClient(conn)
// Contact the server and print out its response.
name := defaultName
if len(os.Args) > 1 {
name = os.Args[1]
}
go func() {
r, err := c.SayHello(context.Background(), &pb.HelloRequest{Name: name})
if err != nil {
log.Fatalf("could not greet: %v", err)
}
log.Printf("Greeting: %s", r.Message)
}()
time.Sleep(10 * time.Second)
}运行测试：
> go build server.go
> go build client.go
./server
./client
2019/02/15 14:35:35 Greeting: Hello world此时在go to go的场景就调用通了