gRPC 服务器如何通知客户端取消了服务器端流式调用？

Question

我想使用 gRPC 让客户端订阅服务器生成的事件。我有一个 RPC 声明如下：

rpc Subscribe (SubscribeRequest) returns (stream SubscribeResponse);

其中返回的流是无限的。要“取消订阅”，客户端取消 RPC（顺便说一句。有没有更干净的方法？）。

我已经弄清楚客户端如何取消呼叫：

rpc Subscribe (SubscribeRequest) returns (stream SubscribeResponse);

但是，服务器似乎没有注意到客户端已取消其调用。我正在用一个虚拟服务器实现来测试这个：

Context.CancellableContext cancellableContext =
         Context.current().withCancellation();
cancellableContext.run(() -> {
   stub.subscribe(request, callback);
});
// do other stuff / wait for reason to unsubscribe
cancellableContext.cancel(new InterruptedException());

服务器会很高兴地继续将其消息发送到以太坊中。服务器如何识别调用已被客户端取消并因此停止发送响应？

Answer 1

我自己找到了答案。您将StreamObserver传递的强制转换为 subscribe ServerCallStreamObserver，它公开了方法isCancelled和setOnCancelHandler。

scso = ((ServerCallStreamObserver<SubscribeResponse>) responseObserver);

scso.setOnCancelHandler(handler);
// or
if (scso.isCancelled()) {
  // do whatever
}

对我来说，这引出了一个问题，为什么subscribe没有通过 aServerCallStreamObserver开始。