如何管理 gRPC-java 服务器方法中的阻塞代码？

Question

假设我有一个 grpc-java 服务器，代码如下：

@Override

public void getData(RequestValue requestValue, StreamObserver<ResponseValue>responseObserver) {

   ResponseValue rv = ... // blocking code here

   responseObserver.onNext(rv);

   responseObserver.onCompleted();

}

因此，由于阻塞代码（来自数据库或其他服务的数据），我有一个 responseValue。

我想避免使用另一个线程池来阻塞当前线程来执行阻塞任务。例如，在 Netty 中，我可以使用特定的 EventExecutorGroup 来完成此类任务。

如何使用 grpc-java 服务正确管理它？

Answer 1

最简单的方法是将 responseObserver 传递给长时间运行的任务：@Overridepublic void getData(RequestValue requestValue, StreamObserver<ResponseValue> responseObserver) {&nbsp; &nbsp; Runnable r = () -> {&nbsp; &nbsp; &nbsp; &nbsp; try {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ResponseValue rv = ... // blocking code here&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; responseObserver.onNext(rv);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; responseObserver.onCompleted();&nbsp; &nbsp; &nbsp; &nbsp; } catch (Exception e) {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; responseObserver.onError(e);&nbsp; &nbsp; }&nbsp; &nbsp; executor.schedule(r);}重要的是您在某个时间完成调用，即使发生意外错误也是如此。否则你会泄漏调用（在超时发生之前保持打开状态，如果有的话）。