JavagRPC服务器流模型

Question

我正在通过以下示例寻找一个用于服务器端流的客户端侦听器示例-https://grpc.io/docs/languages/java/basics/

我已经按照文档-https://github.com/grpc/grpc/blob/master/doc/keepalive.md

所有的例子都表明，当向服务器发出请求时，服务器将作为异步或一元模型响应，或者客户端可以与新请求聊天。每次请求都必须发送到服务器进行响应。连接保持活动时间更长；这很好。

问：客户端是否有可能在不使用BIDI（双向）模型的情况下发送一个请求并无限期地从服务器接收响应？在这种情况下，只要服务器上有数据可用，它就会继续发送，而不需要进一步的请求。同样，这种通信是单播，而不是广播；这意味着每个连接（用户）都是唯一的，可以根据用户的数据进行响应。

不确定，但有一种方法可以是-服务器将请求对象保持在缓存中某个位置的活动状态并保持响应？客户端是否必须使用轮询循环来无限期地侦听响应？

期待能解决这个问题的例子。

Answer 1

一个客户端请求和许多服务器响应是“服务器流”您将仅对响应使用stream关键字。

您可以将阻塞或异步API用于服务器流式RPC。示例中使用了阻塞API，因为阻塞操作通常更加清晰。但也可以使用异步存根。

对于服务器流，异步客户端API让您传递请求和响应观察器来启动调用。之后，它看起来与bidi示例相同，只是客户端不再发送任何消息。服务器可以在任何时候发送消息时调用StreamObserver，当新消息到达时，将调用客户端的StreamObserver。

要查看示例，可以用异步存根替换listFeatures（）的阻塞存根：

final CountDownLatch finishLatch = new CountDownLatch(1);
asyncStub.listFeatures(request, new StreamObserver<Feature>() {
  int i;

  @Override public void onNext(Feature feature) {
    info("Result #" + i + ": {0}", feature);
    if (testHelper != null) {
      testHelper.onMessage(feature);
    }
    i++;
  }

  @Override public void onCompleted() {
    finishLatch.countDown();
  }

  @Override public void onError(Throwable t) {
    warning("RPC failed: {0}", Status.fromThrowable(t));
    if (testHelper != null) {
      testHelper.onRpcError(t);
    }
    finishLatch.countDown();
  }
});
finishLatch.await();