如何使用spring flux和spring flux web客户端组织线程池？
考虑一个简单的控制器
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.reactive.function.client.WebClient;
@RestController
public class DtoController {
private final WebClient client = WebClient.create("http://localhost:8081");
@GetMapping("/booking")
public Mono<MyDto> getDto() {
return carsClient.get().uri("/myUrl")
.retrieve()
.bodyToMono(MyDto.class);
}
}一个文档告诉我们，在spring web flux中，有单个IO线程和N个工作线程(N - CPU核心计数)。并且工作线程在Mono/Flux调用之间被重用。
但是当我运行这个应用程序时，我发现除了spring flux，spring web客户端还创建了IO线程和N个工作线程。所以我得到了：
"Attach Listener"@11 046: RUNNING
"DestroyJavaVM"@9 089 in group "main": RUNNING
"Finalizer"@11 048: WAIT
"ObjectCleanerThread"@6 732 in group "main": WAIT
"reactor-http-nio-1"@6 711 in group "main": RUNNING
"reactor-http-nio-2"@6 713 in group "main": RUNNING
"reactor-http-nio-3"@6 715 in group "main": RUNNING
"reactor-http-nio-4"@6 714 in group "main": RUNNING
"Reference Handler"@11 049: WAIT
"RMI Scheduler(0)"@1 798: WAIT
"RMI TCP Accept-0"@1 288: RUNNING
"RMI TCP Accept-0"@1 445: RUNNING
"RMI TCP Accept-59098"@1 355: RUNNING
"Signal Dispatcher"@11 047: RUNNING
"SimplePauseDetectorThread_0"@6 329: SLEEPING
"Thread-15"@6 328: WAIT
"XNIO-1 Accept"@8 573 in group "main": RUNNING
"XNIO-1 I/O-1"@8 518 in group "main": RUNNING
"XNIO-1 I/O-2"@8 537 in group "main": RUNNING
"XNIO-1 I/O-3"@8 547 in group "main": RUNNING
"XNIO-1 I/O-4"@8 552 in group "main": RUNNING带有reactor-http-nio前缀的线程对应spring应用程序，而XNIO前缀的线程对应web flux客户端。
有没有一种方法可以在web客户端和应用程序之间重用工作者？重用这些线程是个好主意吗？
回答 1
Stack Overflow用户
发布于 2018-12-19 17:55:37
您的服务器应用程序是在Reactor Netty上运行还是在Undertow上运行？XNIO线程通常与Undertow相关联。您可以通过查看应用程序启动期间的日志来确保这一点。
如果是这样，那么这是预期的行为，因为反应器Netty和Undertow不共享客户端和服务器资源。
在Spring Boot的最新版本中，client and server resources are automatically shared, when possible for Jetty and Reactor Netty。
顺便说一句，如果你使用Spring Boot，你应该尝试从一个你可以在应用程序中的任何地方注入的WebClient.Builder中创建WebClient实例。这将为您提供预期的默认值和自定义配置。
https://stackoverflow.com/questions/53844431
复制相似问题
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号