Fabric源码基础-grpc的使用01

Fabric的节点通过grpc向内部或外部提供接口，在学习源码之前，需要对grpc的基本使用有所了解，并了解如何在grpc中配置tls。因此，本节整理了go语言中grpc的基本使用

准备：安装相关软件

安装protobuf

grpc是一个跨语言的rpc框架，采用了google的protobuf作为底层的编解码框架，在使用之前，需要先安装proto，用来生成grpc的相关代码

$ sudo apt-get install autoconf automake libtool curl make g++ unzip
$ git clone https://github.com/google/protobuf.git
$ cd protobuf
$ git submodule update --init --recursive
$ ./autogen.sh
$ ./configure
$ make
$ make check
$ sudo make install
$ sudo ldconfig

安装grpc

正宗的安装方式：

$ go get -u google.golang.org/grpc

由于国内网络访问不到google，需要通过下面的方式从github安装，某些package安装不成功，可以通过https://www.golangtc.com/download/package下载后，解压到$GOPATH/src下面

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
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

1.grpc之HelloWorld

首先，以一个最简单的例子开始，定义一个hello接口，生成相关的代码，最后编写服务器和客户端的程序，实现调用。

1.1 编写proto文件

proto用于定义接口，包括输入和输出格式，方法名称，如下所示为hello.proto的内容,内容比较简单，主要是定义了hello方法

syntax = "proto3";
package hellopb;
message Request {
    string content = 1;
}
message Response {
    string content = 1;
}
service HelloService {
    rpc hello(Request) returns (Response){}
}

1.2 生成代码

编写完成后，进入该文件目录

protoc --go_out=plugins=grpc:. hello.proto

执行完成，可以看到，生成了一个hello.pb.go，我们的服务器端程序和客户端程序都需要在这个文件的基础上完成。

1.3 服务器程序

服务器程序的主要流程是：定义结构体，为该结构体实现定义的方法，启动Server，将结构体注册到Server上
定义结构体，并实现方法

type HelloService struct {
}
func (s *HelloService) Hello(ctx context.Context,request *pb.Request) (*pb.Response, error){
    var req = request.Content
    var ret = "Hello " + req
    return &pb.Response{Content:ret},nil
}

启动服务，注册结构体

var port int = 9999
lis, err := net.Listen("tcp", fmt.Sprintf("0.0.0.0:%d", port))
if err != nil {
  log.Fatalf("failed to listen: %v", err)
}
var opts []grpc.ServerOption // 服务器端的配置参数
grpcServer := grpc.NewServer(opts...)// 创建一个Server，
s := &HelloService{}
pb.RegisterHelloServiceServer(grpcServer, s) // 注册到grpc服务器上
grpcServer.Serve(lis) // 启动服务器

1.4 客户端程序

客户端程序的调用流程是，连接服务器，获取client，调用服务

var opts []grpc.DialOption
opts = append(opts, grpc.WithInsecure())
conn, err := grpc.Dial("127.0.0.1:9999", opts...)
if err != nil {
    log.Fatalf("fail to dial: %v", err)
}
defer conn.Close()
client := pb.NewHelloServiceClient(conn)

// 调用GetFeature
response, err := client.Hello(context.Background(),&pb.Request{Content:"shisj"})
if err != nil {
    log.Fatalf("%v.Hello(_) = _, %v: ", client, err)
}
println(response.Content)

最后编辑于：2018.12.18 11:30:07