RPC和gRPC

肖楠 · · 2613 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

关于RPC(Remote Procedure Call)的定义,可以参考这两篇文章:Remote procedure callRemote Procedure Call (RPC)。简单来讲,RPC指的就是一个进程(client)发起一个函数调用,但是实际用来执行这个函数调用是另一个进程(server)。这个函数调用会阻塞在那里,直到收到响应。Server进程可以与client进程可以位于同一台机器也可以是不同机器。Clientserver都有一个stub模块,clientstub负责发送request,并处理server返回的response;而serverstub则负责处理client发送的request,并返回response。 通常,我们使用Interface Description Language来定义RPC的消息格式。

gRPCgoogle实现的RPC,其默认使用protocol buffers,一个使用gRPC的例子如下(图出自Getting started):

grpc_concept_diagram_00

Go语言为例,搭建gPRC环境包括下列几步:

(1)安装gRPC runtime

go get google.golang.org/grpc

(2)安装protocol buffers支持(包含compilerruntime):从protocol buffers官网下载最新的源码包,解压缩:

./configure
make
make check
make install
ldconfig

(3)安装Go protoc plugin

go get -a github.com/golang/protobuf/protoc-gen-go

参考gRPC提供的例子,下载helloworld.proto文件,然后在当前目录执行“protoc --go_out=plugins=grpc:. *.proto”就会在当前目录下生成helloworld.pb.go文件。对于client来讲,发送request的函数已生成好,只需直接传入request内容以及option即可:

type GreeterClient interface {
    // Sends a greeting
    SayHello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloReply, error)
}

type greeterClient struct {
    cc *grpc.ClientConn
}

func NewGreeterClient(cc *grpc.ClientConn) GreeterClient {
    return &greeterClient{cc}
}

func (c *greeterClient) SayHello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloReply, error) {
    out := new(HelloReply)
    err := grpc.Invoke(ctx, "/helloworld.Greeter/SayHello", in, out, c.cc, opts...)
    if err != nil {
        return nil, err
    }
    return out, nil
} 

对于server,定义好了interface,需要自己实现满足这个interface的结构体:

// Server API for Greeter service

type GreeterServer interface {
    // Sends a greeting
    SayHello(context.Context, *HelloRequest) (*HelloReply, error)
}

可以看出,SayHello()函数只要实现如何构造response即可,其它如何传输消息等等,均不用管。

为了熟悉这个流程,我自己做了一遍,代码在这里:https://github.com/NanXiao/helloworld


有疑问加站长微信联系(非本文作者)

本文来自:nanxiao

感谢作者:肖楠

查看原文:RPC和gRPC

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

2613 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传