java - 在 StreamObserver.onNext() 内部阻塞

Question

我在 GRPC 文档中找不到任何与此相关的内容。 GRPC 是否期望我的 StreamObserver.onNext() 实现是非阻塞的？如果 GRPC 确实阻塞(例如拒绝新请求、对新请求排队等)，会对 GRPC 产生什么影响？

Answer 1

如果需要屏蔽，可以屏蔽。

由于 RPC 的回调被认为是非线程安全的，因此阻塞会延迟其他回调，直到您返回。其中包括 ClientCallStreamObserver 和 ServerCallStreamObserver 中的 setOnReadyHandler 和 setOnCancelHandler。

在流式 RPC 中，gRPC 在您从 onNext() 返回后自动请求另一条消息，因此如果您阻止 gRPC 将避免接收太多消息。不过，gRPC 仍然允许缓冲一些消息。

阻塞对新的 RPC 没有影响。