Spring WebFlux和Reactor的线程模型

1 回答

• 4

  在问题之后，present documentation does provide some clues about the concurrency model和人们可以预期的线程（但我仍然认为从多线程角度更清楚/更好地描述场景中发生的事情将受到Spring新人的高度赞赏） .

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

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

  但请注意，Spring MVC应用程序还可以引入一些异步性（参见Servlet 3 Async） . 我建议this presentation讨论Servlet 3.1 NIO和WebFlux .

  回到文档：它还表明，在使用反应流时，您可以控制：

  如果您确实需要使用阻止库，该怎么办？ Reactor和RxJava都提供了publishOn运算符以继续在不同的线程上进行处理 .

  （有关详细信息，请参阅scheduling in Reactor）

  它还讨论了WebFlux应用程序中您可能期望的线程（ bold 是我的）：

  线程模型您希望在运行Spring WebFlux的服务器上看到哪些线程？在“vanilla”Spring WebFlux服务器上（例如，没有数据访问，也没有其他可选的依赖项），您可以期望服务器有一个线程，而其他几个用于请求处理（通常与CPU核心数一样多） . 但是，Servlet容器可能以更多线程（例如Tomcat上的10个）开始，支持servlet，阻塞I / O和servlet 3.1，非阻塞I / O使用 . 被动WebClient以事件循环方式运行 . 因此，您将看到与此相关的少量固定数量的处理线程，例如“reactor-http-nio-”与Reactor Netty连接器 . 但是，如果Reactor Netty用于客户端和服务器，则默认情况下两者将共享事件循环资源 . Reactor和RxJava提供线程池抽象，称为调度程序，与publishOn运算符一起使用，该运算符用于将处理切换到不同的线程池 . 调度程序具有建议特定并发策略的名称，例如， “并行”用于具有有限数量线程的CPU绑定工作，或“弹性”用于具有大量线程的I / O绑定工作 . 如果您看到这样的线程，则意味着某些代码正在使用特定的线程池调度程序策略 . 数据访问库和其他第三方依赖项也可以创建和使用自己的线程 .

  在某种程度上，您可以通过配置配置线程模型的详细信息

  要配置服务器的线程模型，您需要使用特定于服务器的配置API，或者如果使用Spring Boot，请检查每个服务器的Spring Boot配置选项 . 可以直接配置WebClient . 对于所有其他库，请参阅其各自的文档 .

  而且，例如，讨论Default number of threads in Spring boot 2.0 reactive webflux configuration强调，

  请求处理的默认线程数由底层Web服务器确定;默认情况下，Spring Boot 2.0使用Reactor Netty，它使用的是Netty的默认值

  它是默认组件及其默认值（以及整体配置，包括通过注释透明注入的）的问题 - 它们也可能在Spring / Boot版本和相应的依赖项之间发生变化 . 说，你的猜测似乎是正确的 .

  回复于 2024-04-24T13:55:55+08:00