grpc框架_谷歌开源的高性能RPC框架gRPC

gRPC 一开始由 google 开发&＃xff0c;是一款语言中立、平台中立、开源的远程过程调用(RPC)系统。gRPC 是一个高性能、开源和通用的 RPC 框架&＃xff0c;面向移动和 HTTP/2 设计。目前提供 C、Java 和 Go 语言版本&＃xff0c;分别是&＃xff1a;grpc, grpc-java, grpc-go。gRPC 基于 HTTP/2 标准设计&＃xff0c;带来诸如双向流、流控、头部压缩、单 TCP 连接上的多复用请求等特性。这些特性使得其在移动设备上表现更好&＃xff0c;更省电和节省空间占用。

所谓RPC(remote procedure call&＃xff0c;远程过程调用)框架实际是提供了一套机制&＃xff0c;使得应用程序之间可以进行通信&＃xff0c;而且也遵从server/client模型。在 gRPC 里客户端应用可以像调用本地对象一样直接调用另一台不同的机器上服务端应用的方法&＃xff0c;使得您能够更容易地创建分布式应用和服务。与许多 RPC 系统类似&＃xff0c;gRPC 也是基于以下理念&＃xff1a;定义一个服务&＃xff0c;指定其能够被远程调用的方法(包含参数和返回类型)。在服务端实现这个接口&＃xff0c;并运行一个 gRPC 服务器来处理客户端调用。在客户端拥有一个存根能够像服务端一样的方法。

gRPC 客户端和服务端可以在多种环境中运行和交互。从 google 内部的服务器到你自己的笔记本&＃xff0c;并且可以用任何 gRPC 支持的语言来编写。所以&＃xff0c;你可以很容易地用 Java 创建一个 gRPC 服务端&＃xff0c;用 Go、Python、Ruby 来创建客户端。此外&＃xff0c;Google 最新 API 将有 gRPC 版本的接口&＃xff0c;使你很容易地将 Google 的功能集成到你的应用里。

gRPC 默认使用 protocol buffers&＃xff0c;这是 Google 开源的一套成熟的结构数据序列化机制(当然也可以使用其他数据格式如 JSON)。用户可用 proto files 创建 gRPC 服务&＃xff0c;用 protocol buffers 消息类型来定义方法参数和返回类型。

正如其他 RPC 系统&＃xff0c;gRPC 基于如下思想&＃xff1a;定义一个服务&＃xff0c; 指定其可以被远程调用的方法及其参数和返回类型。gRPC 默认使用 protocol buffers 作为接口定义语言&＃xff0c;来描述服务接口和有效载荷消息结构。如果有需要的话&＃xff0c;可以使用其他替代方案。gRPC 提供 protocol buffer 编译插件&＃xff0c;能够从一个服务定义的 .proto 文件生成客户端和服务端代码。通常 gRPC 用户可以在服务端实现这些API&＃xff0c;并从客户端调用它们。

• 在服务侧&＃xff0c;服务端实现服务接口&＃xff0c;运行一个 gRPC 服务器来处理客户端调用。gRPC 底层架构会解码传入的请求&＃xff0c;执行服务方法&＃xff0c;编码服务应答。
• 在客户侧&＃xff0c;客户端有一个存根实现了服务端同样的方法。客户端可以在本地存根调用这些方法&＃xff0c;用合适的 protocol buffer 消息类型封装这些参数— gRPC 来负责发送请求给服务端并返回服务端 protocol buffer 响应。

同步 RPC 调用一直会阻塞直到从服务端获得一个应答&＃xff0c;这与 RPC 希望的抽象最为接近。另一方面网络内部是异步的&＃xff0c;并且在许多场景下能够在不阻塞当前线程的情况下启动 RPC 是非常有用的。在多数语言里&＃xff0c;gRPC 编程接口同时支持同步和异步的特点。

单项 RPC

最简单的 RPC 形式&＃xff1a;客户端发出单个请求&＃xff0c;获得单个响应。

• 一旦客户端通过桩调用一个方法&＃xff0c;服务端会得到相关通知 &＃xff0c;通知包括客户端的元数据&＃xff0c;方法名&＃xff0c;允许的响应期限
• 服务端既可以在任何响应之前直接发送回初始的元数据&＃xff0c;也可以等待客户端的请求信息&＃xff0c;到底哪个先发生&＃xff0c;取决于具体的应用。
• 一旦服务端获得客户端的请求信息&＃xff0c;就会做所需的任何工作来创建或组装对应的响应。如果成功的话&＃xff0c;这个响应会和包含状态码以及可选的状态信息等状态明细及可选的追踪信息返回给客户端 。
• 假如状态是 OK 的话&＃xff0c;客户端会得到应答&＃xff0c;这将结束客户端的调用。

服务端流式 RPC

服务端流式 RPC 除了在得到客户端请求信息后发送回一个应答流之外&＃xff0c;在发送完所有应答后&＃xff0c;服务端的状态详情(状态码和可选的状态信息)和可选的跟踪元数据被发送回客户端&＃xff0c;以此来完成服务端的工作。客户端在接收到所有服务端的应答后也完成了工作。

客户端流式 RPC

客户端流式 RPC 区别在于客户端通过发送一个请求流给服务端&＃xff0c;取代了原先发送的单个请求。服务端通常(但并不必须)会在接收到客户端所有的请求后发送回一个应答&＃xff0c;其中附带有它的状态详情和可选的跟踪数据。

双向流式 RPC

双向流式 RPC &＃xff0c;调用由客户端调用方法来初始化&＃xff0c;而服务端则接收到客户端的元数据&＃xff0c;方法名和截止时间。服务端可以选择发送回它的初始元数据或等待客户端发送请求。下一步怎样发展取决于应用&＃xff0c;因为客户端和服务端能在任意顺序上读写 - 这些流的操作是完全独立的。例如服务端可以一直等直到它接收到所有客户端的消息才写应答&＃xff0c;或者服务端和客户端可以像"乒乓球"一样&＃xff1a;服务端后得到一个请求就回送一个应答&＃xff0c;接着客户端根据应答来发送另一个请求&＃xff0c;以此类推。

截止时间

gRPC 允许客户端在调用一个远程方法前指定一个最后期限值。这个值指定了在客户端可以等待服务端多长时间来应答&＃xff0c;超过这个时间值 RPC 将结束并返回DEADLINE_EXCEEDED错误。在服务端可以查询这个期限值来看是否一个特定的方法已经过期&＃xff0c;或者还剩多长时间来完成这个方法。各语言来指定一个截止时间的方式是不同的 - 比如在 Python 里一个截止时间值总是必须的&＃xff0c;但并不是所有语言都有一个默认的截止时间。

RPC 终止

在 gRPC 里&＃xff0c;客户端和服务端对调用成功的判断是独立的、本地的&＃xff0c;他们的结论可能不一致。这意味着&＃xff0c;比如你有一个 RPC 在服务端成功结束("我已经返回了所有应答!")&＃xff0c;到那时在客户端可能是失败的("应答在最后期限后才来到!")。也可能在客户端把所有请求发送完前&＃xff0c;服务端却判断调用已经完成了。

取消 RPC

无论客户端还是服务端均可以再任何时间取消一个 RPC 。一个取消会立即终止 RPC 这样可以避免更多操作被执行。它不是一个"撤销"&＃xff0c; 在取消前已经完成的不会被回滚。当然&＃xff0c;通过同步调用的 RPC 不能被取消&＃xff0c;因为直到 RPC 结束前&＃xff0c;程序控制权还没有交还给应用。

元数据集

元数据是一个特殊 RPC 调用对应的信息(授权详情]) &＃xff0c;这些信息以键值对的形式存在&＃xff0c;一般键的类型是字符串&＃xff0c;值的类型一般也是字符串(当然也可以是二进制数据)。元数据对 gRPC 本事来说是不透明的 - 它让客户端提供调用相关的信息给服务端&＃xff0c;反之亦然。

频道

在创建客户端存根时&＃xff0c;一个 gRPC 频道提供一个特定主机和端口服务端的连接。客户端可以通过指定频道参数来修改 gRPC 的默认行为&＃xff0c;比如打开关闭消息压缩。一个频道具有状态&＃xff0c;包含已连接和空闲 。gRPC 如何处理关闭频道是语言相关的。有些语言可允许询问频道状态。