覆盖spring webflux项目的默认线程池执行器有多有效？

Question

我是新来spring的-WebFlux。

我正在2核处理器中运行下面的示例项目。我的RESTful api将调用外部api，并且外部api响应小于500ms。

当我使用jMeter进行负载测试时，不能达到15 TPS以上。

我是不是遗漏了什么或者下面的设计有什么问题？

在Webflux项目中重写默认的线程池执行器有多有效？

提前谢谢你。

controller.java
----------------

LookupController
{

@AutoWired
private LookupService LookupService；
@PostMapping（value=“/findOrder”）
public Mono>findOrder(@RequestBody InputBean InputBean）{

返回LookupService.FindOrder（输入Bean）
.Map（resp->ResponseEntity.OK（resp））
.DefaultifEmpty（ResponseEntity.NotFound（）.Build（））；
}
}

服务
---------

@Service
public class LookupService
{
private RestWorker RestWorker；
public Mono findOrder（InputBean InputBean）
{
..//Basic Validation
ApiBean ApiBean=RestWorker.BuildApibean（InputBean）；
Mono responseStr=RestWorker.CallAPI（ApiBean）；
return responseStr.FlatMap（resp->{
//Business

}

帮助程序
---------

@Component
public RestWorker{

private Webclient Webclient=null；

@postconstruct
private void initWorker（）{
webClient=webClient.builder（）
.baseurl（httpUrl）
.defaulteader（httpheaders.content_type,“application/json”）
.defaulteader（httpheaders.accept,“application/json”）
.defaulteader（httpheaders.accept,“application/json”）
.build()；
}

public ApiBean buildApiBean（InputBean InputBean）{
//基于输入bean+配置值创建ApiBean
...
返回ApiBean；
}

public Mono callApi（ApiBean ApiBean）{
Mono responseMonoStr=Null；
try{
responseMonoStr=WebClient.Post()
.URI(url_tibco)

.Body(BodyInserters.FromObject(reqDoc))

.Exchange()

.Timeout（Duration.OfMillis（socketReadTimeout))
.FlatMap（clientResponse->{

}

}

Answer 1

布莱恩·克洛泽，

太感谢你了。非阻塞api是基于少量线程的事件循环工作的。但是，当我发送一些并行请求时，它会打开两个不同的线程，如reactor-http-nio-2和reactor-http-nio-3。

为什么它在每个并行请求上打开不同的线程？

Answer 2

它不是，因为spring WebFlux没有使用线程池执行器来调度web请求。而是使用其他服务器资源，如事件循环（用于Netty）。有关这方面的更多信息，您可以查看spring boot关于reactive server resources的参考文档，更重要的是了解spring WebFlux中的并发模型。