Fabric源码基础-grpc的使用01 - Go语言中文社区

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)
版权声明:本文来源简书,感谢博主原创文章,遵循 CC 4.0 by-sa 版权协议,转载请附上原文出处链接和本声明。
原文链接:https://www.jianshu.com/p/9009d4c960ab
站方申明:本站部分内容来自社区用户分享,若涉及侵权,请联系站方删除。
  • 发表于 2020-02-02 14:52:54
  • 阅读 ( 1292 )
  • 分类:

0 条评论

请先 登录 后评论

官方社群

GO教程

猜你喜欢