Spring WebFlux和Reactor的线程模型

Z时代
2024-01-10
分类：问答

目前正在尝试使用，和进行反应式编程。

想知道WebFlux和Reactor使用的来正确编写应用程序并处理可变状态。

Reactor文档指出该库被认为与并发无关，并提到了Scheduler抽象。WebFlux文档不提供信息。

但是，通过Spring Boot使用WebFlux时，会定义一个线程模型。

从我的实验中，我得到了：

该模型既不是1个事件线程，也不是1个事件线程+ worker

使用了多个线程池

“ reactor-http-nio-3 ”线程：每个内核大概一个，处理传入的HTTP请求

“ Thread-7 ”线程：由对MongoDB或HTTP资源的异步请求使用

“ parallel-1 ”线程：每个内核一个，由Reactor的Schedulers.parallel（）创建，供延迟运算符等使用

共享的可变状态必须由应用程序同步

ThreadLocal（用于应用程序状态，MDC日志记录等）不在请求范围内，因此不是很有趣

这样对吗？WebFlux的并发和线程模型是什么：例如，默认的线程池是什么？

感谢您的信息

回答：

在提出问题之后，本文档的确提供了一些有关并发模型和线程可能期望的线索（但我仍然认为，从多线程的角度对幕后发生的事情进行更清晰/更好的描述将受到高度赞赏。春季新人）。

它讨论了Spring MVC和Spring WebFlux（每请求1线程模型与事件循环）之间的区别：

通常在Spring
MVC和servlet应用程序中，假定应用程序可能会阻塞当前线程（例如，用于远程调用），因此，servlet容器使用大线程池来吸收请求处理期间的潜在阻塞。
在Spring
WebFlux和一般非阻塞服务器中，假定应用程序不会阻塞，因此非阻塞服务器使用固定大小的小型线程池（事件循环工作程序）来处理请求。调用阻止API

但是请注意，Spring MVC应用程序还可能引入一些异步性（请参阅Servlet

3异步）。我建议在演示文稿时讨论Servlet 3.1 NIO和WebFlux。

回到文档：它还建议在使用反应流时，您可以控制一些：

如果确实需要使用阻止库怎么办？
Reactor和RxJava都提供了publishOn运算符以继续在其他线程上进行处理。

（有关更多信息，请参阅Reactor中的调度）

它还讨论了WebFlux应用程序中可能需要的线程（是我的）：

线程模型
您期望在运行Spring WebFlux的服务器上看到哪些线程？
在“原始” Spring WebFlux服务器上（例如，没有数据访问权限，也没有其他可选的依赖项），您可以期望
。但是，Servlet容器可能以更多线程（例如Tomcat上为10）开始，以同时支持Servlet，阻塞I / O和Servlet 3.1，即非阻塞I
/ O使用。
The reactive operates in . So you’ll
see a . However if Reactor
Netty is used for both client and server, the two will share event loop
resources by default.
Reactor和RxJava提供称为线程池抽象，以与配合使用，该
。该，如
与线程的数量有限，或有大量的线程。如果看到这样的线程，则意味着某些代码正在使用特定的线程池调度程序策略。
。