gRPC 4种rpc定义方法与3种stub介绍

gRPC

有关gRPC官方介绍(https://www.grpc.io/docs/what-is-grpc/introduction/)如下:


run and talk to each other in a variety of environments

gRPC是一个能在不同语言不同平台中进行高效通信的服务。gRPC默认使用Protocol Buffers数据格式:

Protocol Buffers:Google成熟的用于序列化结构化数据的开源机制(类似于JSON并且能与JSON一起使用)

Protocol Buffers以.proto作为拓展名,是一系列以name-value键值对的形式存储的数据格式。

message  Person{

    string  name=1;

    int32  id=2;

    bool  has_ponycopter=3;    

}

Protocol Buffers从开源到现在已经经过很长时间,目前已经到了proto3版本,有着更加简化的语法,更加有用的特性,能够支持更多的语言。你可以从proto3 language guide和 reference documentation看到更多有用的东西。另外.proto的文件格式能够从formal specification获取到更详细的讲解。

As you can see, each field in the message definition has a unique number. These field numbers are used to identify your fields in the message binary format, and should not be changed once your message type is in use. Note that field numbers in the range 1 through 15 take one byte to encode, including the field number and the field's type (you can find out more about this in Protocol Buffer Encoding). Field numbers in the range 16 through 2047 take two bytes. So you should reserve the numbers 1 through 15 for very frequently occurring message elements. Remember to leave some room for frequently occurring elements that might be added in the future.

The smallest field number you can specify is 1, and the largest is 229 - 1, or 536,870,911. You also cannot use the numbers 19000 through 19999 (FieldDescriptor::kFirstReservedNumber through FieldDescriptor::kLastReservedNumber), as they are reserved for the Protocol Buffers implementation - the protocol buffer compiler will complain if you use one of these reserved numbers in your .proto. Similarly, you cannot use any previously reserved field numbers.

每个参数带有一个唯一的标识符,这些标识符被用来在message的二进制中被识别出来。不是代表每个数据的数值。

Why use gRPC? 

有了gRPC,我们可以在.proto文件中定义我们的服务,并用gRPC支持的任何语言生成客户端和服务器,它可以在从大型数据中心内的服务器到您自己的平板电脑的各种环境中运行,不同语言和环境之间的所有复杂通信都由gRPC为您处理。我们还获得了使用协议缓冲区的所有优点,包括高效的序列化、简单的IDL和容易的接口更新。

(java).proto格式

声明定义proto使用3版本,如果不生命默认2版本号。

syntax = "proto3";

在proto文件中定义java_package,指定了我们要用于生成的Java类的包。如果.proto文件中没有显式的java_package选项,那么默认情况下将使用proto包(使用“package”关键字指定)。

option  java_package  =  "io.grpc.examples.routeguide";

使用service定义服务。然后在service中使用rpc方法定义,gRPC允许使用4种不同的定义方式,定义方法。

service  RouteGuide {

    rpc   GetFeature(Point)   returns (Feature) {}

    rpc   ListFeatures(Rectangle)   returns (stream Feature) {}

    rpc   RecordRoute(stream Point)   returns (RouteSummary) {}

    rpc   RouteChat(stream RouteNote)   returns (stream RouteNote) {}

}

区别在客户端调用Grpc中Stub发送请求方法时:

newStub

当Grpc.Stub.GetFeature:

//双一元请求方法,在newStub中是没有返回值,在参数中虽然是使用StreamObserver,但是进一步调用的call方法为asyncUnaryCall,在这个方法中声明了boolean streamingResponse为false,进而返回值不是数据流。

返回值:void

参数:Request request,   StreamObserver<Response>  responseObserver

当Grpc.Stub.ListFeatures:

//在参数中使用StreamObserver,进一步调用的call方法为asyncServerStreamingCall,在这个方法中声明了boolean streamingResponse为true,返回值是数据流。

返回值:void

参数:Request request, StreamObserver<Response> responseObserver

当Grpc.Stub.RecordRoute:

返回值:StreamObserver<Request>

参数:streamResponse responseObserver

当Grpc.Stub.RouteChat:双向流式请求,

返回值:StreamObserver<Request>

参数:StreamObserver<Response> responseObserver

newBlockingStub

当Grpc.Stub.GetFeature:

返回值:Response

参数:Request request

当Grpc.Stub.ListFeatures:

返回值:java.util.Iterator<Response>

参数:Request request

当Grpc.Stub.RecordRoute:没有rpc对应的方法。。

返回值:

参数:

当Grpc.Stub.RouteChat:双向流式请求,没有对应方法

返回值:

参数:

newFutureStub

当Grpc.Stub.GetFeature:

返回值:ListenableFuture<streamResponse>

参数:streamRequest request

当Grpc.Stub.ListFeatures:没有rcp对应的方法。。

返回值:

参数:

当Grpc.Stub.RecordRoute:没有rpc对应的方法。。

返回值:

参数:

当Grpc.Stub.RouteChat:双向流式请求,没有对应方法

返回值:

参数:

可以使用message定义所有的request and response types,在service中使用到的数据格式。

message    Point  {

    int32    latitude = 1;

    int32    longitude = 2;

}    

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 215,294评论 6 497
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,780评论 3 391
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 161,001评论 0 351
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,593评论 1 289
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,687评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,679评论 1 294
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,667评论 3 415
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,426评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,872评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,180评论 2 331
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,346评论 1 345
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,019评论 5 340
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,658评论 3 323
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,268评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,495评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,275评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,207评论 2 352