grpc教程 java



通过学习教程中例子，你可以学会如何：

• 用 protocol buffer 编译器生成服务器和客户端代码。
• 使用 gRPC 的 Java API 为你的服务实现一个简单的客户端和服务器。
  假设你已经阅读了概览 并且熟悉。 注意，教程中的例子使用的是 protocol buffers 语言的 proto3 版本，它目前只是 alpha 版：可以在 proto3 语言指南和 protocol buffers 的 Github 仓库的发现更多关于新版本的内容。

这算不上是一个在 Java 中使用 gRPC 的综合指南：以后会有更多的参考文档。

我们的例子是一个简单的路由映射的应用，它允许客户端获取路由特性的信息，生成路由的总结，以及交互路由信息，如服务器和其他客户端的流量更新。

有了 gRPC， 我们可以一次性的在一个 .proto 文件中定义服务并使用任何支持它的语言去实现客户端和服务器，反过来，它们可以在各种环境中，从Google的服务器到你自己的平板电脑—— gRPC 帮你解决了不同语言及环境间通信的复杂性。使用 protocol buffers 还能获得其他好处，包括高效的序列号，简单的 IDL 以及容易进行接口更新。

教程的代码在这里 。 要下载例子，通过运行下面的命令去克隆代码库：

然后改变当前的目录到 ：

你还需要安装生成服务器和客户端的接口代码相关工具——如果你还没有安装的话，请查看下面的设置指南 Java快速开始指南。

我们的第一步(可以从中得知)是使用 protocol buffers去定义 gRPC service 和方法 request 以及 response 的类型。你可以在看到完整的 .proto 文件。

在生成例子中的 Java 代码的时候，在 .proto 文件中我们指定了一个 文件的选项：

这个指定的包是为我们生成 Java 类使用的。如果在 .proto 文件中没有显示的 参数，那么就会使用缺省的 proto 包（通过 "package" 关键字指定）。但是，因为 proto 包一般不是以域名翻转的格式命名，所以它不是好的 Java 包。 如果我们用其它语言通过 .proto 文件生成代码， 是不起任何作用的。

要定义一个服务，你必须在你的 .proto 文件中指定 ：

然后在我们的服务中定义 方法，指定它们的请求的和响应类型。gRPC 允许你定义4种类型的service 方法，这些都在 服务中使用：

• 一个 简单 RPC ， 客户端使用存根发送请求到服务器并等待响应返回，就像平常的函数调用一样。
• 一个 服务器端流式 RPC ， 客户端发送请求到服务器，拿到一个流去读取返回的消息序列。 客户端读取返回的流，直到里面没有任何消息。从例子中可以看出，通过在 响应 类型前插入 stream 关键字，可以指定一个服务器端的流方法。
• 一个 客户端流式 RPC ， 客户端写入一个消息序列并将其发送到服务器，同样也是使用流。一旦客户端完成写入消息，它等待服务器完成读取返回它的响应。通过在 请求 类型前指定 stream关键字来指定一个客户端的流方法。
• 一个 双向流式 RPC 是双方使用读写流去发送一个消息序列。两个流独立操作，因此客户端和服务器可以以任意喜欢的顺序读写：比如， 服务器可以在写入响应前等待接收所有的客户端消息，或者可以交替的读取和写入消息，或者其他读写的组合。 每个流中的消息顺序被预留。你可以通过在请求和响应前加stream 关键字去制定方法的类型。

我们的 .proto 文件也包含了所有请求的 protocol buffer 消息类型定义以及在服务方法中使用的响应类型——比如，下面的消息类型：

接下来我们需要从 .proto 的服务定义中生成 gRPC 客户端和服务器端的接口。我们通过 protocolbuffer 的编译器 以及一个特殊的 gRPC Java 插件来完成。为了生成 gRPC 服务，你必须使用编译器（同时支持 proto2 和proto3 语法）。

从这里src/generated/main可以看到为了例子预生成的代码。

下面的类都是从我们的服务定义中生成：

• 包含了所有填充，序列化以及获取请求和应答的消息类型的Feature.java，Point.java，Rectangle.java以及其它类文件。
• RouteGuideGrpc.java 文件包含（以及其它一些有用的代码）：
  • RouteGuide 服务器要实现的一个接口 RouteGuideGrpc.RouteGuide，其中所有的方法都定义在RouteGuide服务中。
  • 客户端可以用来和RouteGuide服务器交互的 存根 类。异步的存根也实现了 RouteGuide 接口。

首先来看看我们如何创建一个 服务器。如果你只对创建 gRPC 客户端感兴趣，你可以跳过这个部分，直接到 (当然你也可能发现它也很有意思)。

让 服务工作有两个部分：

• 实现我们服务定义的生成的服务接口：做我们的服务的实际的“工作”。
• 运行一个 gRPC 服务器，监听来自客户端的请求并返回服务的响应。
  你可以从grpc-java/examples/src/main/java/io/grpc/examples/RouteGuideServer.java看到我们的]() 服务器的实现代码。现在让我们近距离研究它是如何工作的。

如你所见，我们的服务器有一个实现了生成的 接口的类：

简单 RPC

实现了我们所有的服务方法。首先让我们看看最简单的类型 ，它从客户端拿到一个 对象，然后从返回包含从数据库拿到的feature信息的 。

接收两个参数：

• Point： 请求
• StreamObserver ： 一个应答的观察者，实际上是服务器调用它应答的一个特殊接口。
  要将应答返回给客户端，并完成调用：
  1. 如在我们的服务定义中指定的那样，我们组织并填充一个 Feature 应答对象返回给客户端。在这个例子中，我们通过一个单独的私有方法checkFeature()来实现。
  2. 我们使用应答观察者的 onNext() 方法返回 Feature。
  3. 我们使用应答观察者的 onCompleted() 方法来指出我们已经完成了和 RPC的交互。

  服务器端流式 RPC

现在让我们来看看我们的一种流式 RPC。 是一个服务器端的流式 RPC，所以我们需要将多个 发回给客户端。

和简单 RPC 类似，这个方法拿到了一个请求对象（客户端期望从 找到 ）和一个应答观察者 。

这次我们得到了需要返回给客户端的足够多的 对象（在这个场景下，我们根据他们是否在我们的 请求中，从服务的特性集合中选择他们），并且使用 方**流往响应观察者写入。最后，和简单 RPC 的例子一样，我们使用响应观察者的 方法去告诉 gRPC 写入应答已完成。

客户端流式 RPC

现在让我们看看稍微复杂点的东西：客户端流方法 ，我们通过它可以从客户端拿到一个 的流，并且返回一个包括它们路径的信息 。

如你所见，这次这个方法没有请求参数。相反的，它拿到了一个 流，服务器可以用它来同时读 和_ 写消息——它可以用自己的 方法接收客户端消息并且用 方法返回它的单个响应。

如你所见，我们的方法和前面的方法类型相似，拿到一个 应答观察者参数，但是这次它返回一个 以便客户端写入它的 。

在这个方法体中，我们返回了一个匿名 实例，其中我们：

• 覆写了 onNext() 方法，每次客户端写入一个 Point 到消息流时，拿到特性和其它信息。
• 覆写了 onCompleted() 方法（在 客户端 结束写入消息时调用），用来填充和构建我们的 RouteSummary。然后我们用 RouteSummary 调用方法自己的的响应观察者的 onNext()，之后调用它的 onCompleted() 方法，结束服务器端的调用。

  双向流式 RPC

最后，让我们看看双向流式 RPC 。

和我们的客户端流的例子一样，我们拿到和返回一个 应答观察者，除了这次我们在客户端仍然写入消息到 它们的 消息流时通过我们方法的应答观察者返回值。这里读写的语法和客户端流以及服务器流方法一样。虽然每一端都会按照它们写入的顺序拿到另一端的消息，客户端和服务器都可以任意顺序读写——流的操作是互不依赖的。

一旦我们实现了所有的方法，我们还需要启动一个gRPC服务器，这样客户端才可以使用服务。下面这段代码展示了在我们服务中实现的过程：

如你所见，我们用一个 构建和启动服务器。这个服务器的生成器基于 Netty 传输框架。

• 创建我们服务实现类 RouteGuideService 的一个实例并且将其传给生成的 RouteGuideGrpc 类的静态方法 bindService() 去获得服务定义。
• 使用生成器的 forPort() 方法指定地址以及期望客户端请求监听的端口。
• 通过传入将 bindService() 返回的服务定义，用生成器注册我们的服务实现到生成器的 addService() 方法。
• 调用生成器上的 build() 和 start() 方法为我们的服务创建和启动一个 RPC 服务器。

在这部分，我们将尝试为 服务创建一个 Java 的客户端。你可以从grpc-java/examples/src/main/java/io/grpc/examples/RouteGuideClient.java看到我们完整的客户端例子代码。

为了调用服务方法，我们需要首先创建一个 存根，或者两个存根：

• 一个 阻塞/同步 存根：这意味着 RPC 调用等待服务器响应，并且要么返回应答，要么造成异常。
• 一个 非阻塞/异步 存根可以向服务器发起非阻塞调用，应答会异步返回。你可以使用异步存根去发起特定类型的流式调用。
  我们首先为存根创建一个 gRPC channel，指明服务器地址和我们想连接的端口号：

如你所见，我们用一个 构建和启动服务器。这个服务器的生成器基于 传输框架。

我们使用 Netty 传输框架，所以我们用一个 启动服务器。

现在我们可以通过从 .proto 中生成的 类的 和 方法，使用频道去创建我们的存根。

现在让我们看看如何调用服务方法。

简单 RPC

在阻塞存根上调用简单 RPC 几乎是和调用一个本地方法一样直观。

我们创建和填充了一个请求 protocol buffer 对象（在这个场景下是 ），在我们的阻塞存根上将其传给 方法，拿回一个 。

服务器端流式 RPC

接下来，让我们看一个对于 的服务器端流式调用，这个调用会返回一个地理性的 流：

如你所见，这和我们刚看过的简单 RPC 很相似，除了方法返回客户端用来读取所有返回的 的 一个 ，而不是单个的 。

客户端流式 RPC

现在看看稍微复杂点的东西：我们在客户端流方法 中发送了一个 流给服务器并且拿到一个 。为了这个方法，我们需要使用异步存根。如果你已经阅读了创建服务器，一些部分看起来很相近——异步流式 RPC 是在两端通过相似的方式实现的。

如你所见，为了调用这个方法我们需要创建一个 ，它为了服务器用它的 应答实现了一个特殊的接口。在 中，我们：

• 覆写了 onNext() 方法，在服务器把 RouteSummary 写入到消息流时，打印出返回的信息。
• 覆写了 onCompleted() 方法（在 服务器 完成自己的调用时调用）去设置 SettableFuture，这样我们可以检查服务器是不是完成写入。
  之后，我们将 传给异步存根的 方法，拿到我们自己的 请求观察者将 发给服务器。一旦完成点的写入，我们使用请求观察者的 方法告诉 gRPC 我们已经完成了客户端的写入。一旦完成，我们就检查 验证服务器是否已经完成写入。

双向流式 RPC

最后，让我们看看双向流式 RPC 。

和我们的客户端流的例子一样，我们拿到和返回一个 应答观察者，除了这次我们在客户端仍然写入消息到 它们的 消息流时通过我们方法的应答观察者返回值。这里读写的语法和客户端流以及服务器流方法一样。虽然每一端都会按照它们写入的顺序拿到另一端的消息，客户端和服务器都可以任意顺序读写——流的操作是互不依赖的。

根据example目录下的README的指导去构建和运行客户端及服务器。

原文:

版权声明：

本文来源网络，所有图片文章版权属于原作者，如有侵权，联系删除。

本文网址：https://www.bianchenghao6.com/java-jiao-cheng/14035.html