站在巨人的肩膀上：gRPC通过HTTP/2构建云原生时代的通信标准

gRPC：云原生时代的通信标准
gRPC将HTTP/2作为其传输层，并在此基础上定义了自身的通信语义。gRPC支持四种服务方法类型，它们都映射到HTTP/2的流模型上。
1）Unary RPC: 客户端发送单个请求，服务器返回单个响应（类似传统请求-响应）。
2）Server Streaming RPC: 客户端发送单个请求，服务器返回一个消息序列（流）。
3）Client Streaming RPC: 客户端发送一个消息序列（流），服务器返回单个响应。
4）Bidirectional Streaming RPC: 客户端和服务器都可以独立地发送一个消息序列（流）。
请求 (Request) 结构
gRPC的Request 包含请求头（Request Headers），请求体（Request Body）和EOS（end-of-stream）。
请求头使用 HTTP/2的headers， 使用HEADERS和CONTINUATION帧派发。请求头有Call-Definition和Custom-Metadata。其中grpc-前缀为 gRPC自己保留。

1. HEADERS (flags = END_HEADERS)
2. // HTTP 方法。对于 gRPC，:method标头始终为POST。
3. :method = POST
4. // HTTP 协议。如果启用了 TLS，则协议设置为https，否则为http。
5. :scheme = http
6. // 终端路径。对于 gRPC，此值构造为“/${包名}.${服务名}/${接口名}"。
7. :path = /ProductInfo/getProduct
8. // 目标 URI 的虚拟主机名。
9. :authority = abc.com
10. // 不兼容代理的检测。对于 gRPC，该值必须是“trailers”。
11. te = trailers
12. // 调用超时时。如果未指定，server端应假定无限超时。
13. grpc-timeout = 1S
14. // 内容类型。对于 gRPC，内容类型应以application/grpc。
15. content-type = application/grpc
16. // 消息压缩方式。包括identity、gzip、deflate、snappy及自定义压缩方式。
17. grpc-encoding = gzip
18. // 可选的请求头，用于访问有安全限制的终端服务。
19. authorization = Bearer xxxxxx

复制代码

请求体使用DATA
<Length-Prefixed Message>帧派发，请求体是长度前缀消息。它有一个 Compressed flag 用来表示message 是否压缩，为1表示采用了压缩算法（具体的压缩算法在HEADERS帧中定义）。后面跟着四字节的 message length 以及实际的 message。

EOS会在DATA
<Length-Prefixed Message>帧里面带上了END_STREAM这个flag。用来表示请求消息的结束。

1. DATA
2. <Length-Prefixed Message> (flags = END_STREAM)
3. <Length-Prefixed Message>

复制代码

响应 (Response) 结构
gRPC的Response包含响应头（Response-Headers），响应体（Response Body）和 Trailers。

1. HEADERS (flags = END_HEADERS)
2. // 标识 HTTP 请求的状态。
3. :status = 200
4. // 消息压缩类型。包括identity、gzip、deflate、snappy和自定义类型。
5. grpc-encoding = gzip
6. // 内容类型。对于gRPC，content-type应该设置为application/grpc。
7. content-type = application/grpc

复制代码

发完响应头，使用DATA
<Length-Prefixed Message>帧派发响应体。响应体是长度前缀消息。

1. DATA
2. <Length-Prefixed Message>

复制代码

结束标志不与数据帧一起发送，而是作为单独的头部发送，称为Trailers。 如果遇到了错误，也可以直接返回 Trailers-Only。
Trailer是一种特殊的元数据，通常包含有关执行的状态信息，例如状态码（ grpc-status）和状态消息（grpc-message）
gRPC之所以要用单独的Trailers来标志响应结束。是因为在streaming模式下，所有消息没有传输完成之前，gRPC也不知道要传什么样的grpc-status 。

1. HEADERS (flags = END_STREAM, END_HEADERS)
2. // gRPC 状态代码
3. grpc-status = 0 # OK
4. // 错误描述。可选的，仅在处理请求出现错误时设置。
5. grpc-message = xxxxxx

复制代码

服务描述
gRPC 利用 .proto 文件中的 service 来定义 RPC 接口。

1. // 文件: demo/hello/greeter.proto
2. syntax = "proto3";
4. package demo.hello;
6. // Greeter 服务定义
7. service Greeter {
8.   // SayHello 方法定义
9.   rpc SayHello (HelloRequest) returns (HelloReply);
10. }
12. // 请求消息结构
13. message HelloRequest {
14.   string name = 1;
15. }
17. // 响应消息结构
18. message HelloReply {
19.   string message = 1;
20. }

复制代码

在上述 .proto 文件中，定义了一个名为 Greeter 的服务，它包含一个名为 SayHello 的方法。该方法接收 HelloRequest 消息并返回 HelloReply 消息。gRPC工具链会基于此IDL生成各种语言的客户端存根（stub）和服务端骨架（skeleton）。开发者通过调用存根上的方法，就如同调用本地方法一样，gRPC框架会处理底层的序列化、网络通信和方法分发。
一个 gRPC 定义包含三个部分，包名、服务名和接口名，连接规则如下：

1. /${包名}.${服务名}/${接口名}

复制代码

SayHello的包名是demo.hello，服务名是Greeter，接口名是SayHello，所以对应的路径就是 /demo.hello.Greeter/SayHello。

1. HEADERS (flags = END_HEADERS) :method = POST:scheme = http:path = /demo.hello.Greeter/SayHello:authority = grpc.demo.comcontent-type = application/grpcDATA
2. <Length-Prefixed Message> (flags = END_STREAM)
3. <Length-Prefixed Message>

复制代码

gRPC基于这样的一个设计理念：定义一个服务，及其被远程调用的方法（方法名称、入参、出参）。开发者可以像调用本地方法一样，使用gRPC客户端存根（stub）调用远程机器上 gRPC 服务的方法。gRPC 的客户端和服务端都可以用任何支持 gRPC 的语言来实现，例如一个 gRPC 服务端可以是 C++语言编写的，以供 Ruby 语言的 gRPC 客户端和 JAVA 语言的 gRPC 客户端调用，如下图所示。

未完待续.
很高兴与你相遇！如果你喜欢本文内容，记得关注哦！

来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！