如何实现 grpc - java 异步服务器?

How to implement grpc - java async server?

当我查看 grpc-java 为服务器调用自动生成的 classes 和 grpc-java git repo 中给出的示例时,我可以看到我们扩展了 ImplBase class 并覆盖了服务方法。如下所示:

static class communicationImpl extends communicationImplBase

在 C++ 中,为了实现异步服务,我们使用 AsyncService 而不是 Service class 来扩展我们的实现。但是在 java 生成的 Grpc class 中,我看不到另一个 class 是具有异步的 named/starting。我在其中看到的唯一与服务器相关的 class 是以 ImplBase 结尾的。那么我如何设置我的服务器以在 grpc-Java 中异步处理请求?

ImplBaseclass异步接口,尽管对于一元和服务器流方法,它可以以阻塞方式实现。