如何提高单核cpu反应式编程的性能

Question

我有一个连接到第三方服务并将结果返回给客户端的应用程序。在内部，应用程序向第三方服务发出GET请求并获取结果。我已经使用Reactor和reactive代码在重负载下扩展应用程序。这是一个SpringBoot项目，它运行嵌入式Tomcat并依赖于Web客户端（被动netty向第三方发出请求）。不知何故，CPU利用率和响应时间都比阻塞模式差。硬件设置在Kubernetes中运行单核。

该项目建立在库伯内特斯内部，在一个核心的单吊舱上运行。我尝试以反应性的方式，但应用程序是慢得多，甚至CPU利用率高时，与阻塞架构相比。

 public Mono<ResponseEntity<?>> get(HttpServletRequest request)
   {
      return Mono.create ( callback -> {
         Mono<Response> response = Make HTTP GET Call using webClient.
         response.subscribe(response -> {
         callback.success(response);
         },error -> {
         callback.error(error);
         }
       });
    }

在传统的阻塞模式下，当采用反应式方法时，我可以看到更好的性能和更低的CPU使用率。造成这种差异的原因可能是什么？因为只有一个核心，这是因为上下文切换吗？如果是，我们如何通过单核架构获得更好的性能？

Answer 1

在整个反应链中应该只有一个订阅。尽可能地推迟——最后一次订阅。让我们重新编写您的代码：

public Mono<ResponseEntity<?>> get(HttpServletRequest request) {
      return Mono.just(requestObject)
                 .flatmap(a -> makeAsyncCall(a))
                 .doOnError(err -> doSomethingOnError());
}

你可以订阅你在哪里开始你的反应链。通常，这将是控制器。

这将是：

Mono.just(request)
    .flatMap(request -> get(request))
    .subscribe(response -> setDeferredResult(response));

return deferredResult;

Answer 2

我真的不明白你为什么在中间订阅来提取响应。订阅我认为是一个昂贵的过程，只应该由调用客户端完成一次。

这是一个例子，说明我将如何使用doOnError方法来处理错误和映射响应。

public Mono<Foo> bar() {
    return client.get()
            .uri("/something")
            .accept(MediaType.APPLICATION_JSON)
            .exchange()
            .flatMap(response -> response.bodyToMono(Foo.class))

}

public Mono<Bar> foo() {
    return bar()
        .flatMap(stuff -> {
         return // Map it here to something else that 
                // is getting returned to the calling client
        })
        .doOnError(FooBarException::new);