在 Spring Webflux 中进行 Grpc 调用

如何解决在 Spring Webflux 中进行 Grpc 调用

您好，我们有一个基于 Spring WebFlux 的应用程序，它需要对我们正在使用的另一台服务器进行 GRPC 调用。我知道我们可以使用 WebFlux 的内置 WebClient 类以反应方式进行 http 调用，但我想知道我们如何以类似的方式进行 GRPC 调用。现在，我们通过在不同的线程上进行阻塞 grpc 调用来进行出站 grpc 调用，如下所示。

      Mono<Response> responseMono =  Mono.just(req)
            .publishOn(Schedulers.boundedElastic())
            .flatMap(request -> Mono.just(blockingStub.myMethod(req)))

有没有办法以类似于我们如何使用内置的 WebClient 类进行调用的方式进行这些出站 grpc 调用，这样它是反应性的，我们不需要使用阻塞存根，也不需要调用一个单独的线程？