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

J.N*_*ini 3 asynchronous grpc grpc-java

当我查看 grpc-java 自动生成的服务器调用类以及 grpc-java git 存储库中给出的示例时,我可以看到我们扩展了 ImplBase 类并重写了服务方法。就像下面这样:

static class communicationImpl extends communicationImplBase

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

小智 5

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