如何在 spring boot 2 中配置 netty

Question

默认情况下spring web flux 使用单线程事件循环netty。如何配置 spring 启动以便为每个内核创建一个线程。

谢谢，

洛克什

Answer 1

如 Spring Boot reference documentation 中所述，您可以使用 NettyServerCustomizer.

自定义 Reactor Netty Web 服务器

下面是 Spring Boot 2.1 的示例：

@Component
public class MyNettyWebServerCustomizer
        implements WebServerFactoryCustomizer<NettyReactiveWebServerFactory> {

    @Override
    public void customize(NettyReactiveWebServerFactory factory) {
        factory.addServerCustomizers(new EventLoopNettyCustomizer());
    }
}

class EventLoopNettyCustomizer implements NettyServerCustomizer {

    @Override
    public HttpServer apply(HttpServer httpServer) {
        LoopResources loopResources = LoopResources.create(...);
        return httpServer.runOn(loopResources);
    }
}

Answer 2

您可以更改依赖项：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
    <exclusions>
        <!-- Exclude the Tomcat dependency -->
        <exclusion>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-tomcat</artifactId>
        </exclusion>
    </exclusions>
</dependency>
<!-- Use Jetty instead -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-jetty</artifactId>
</dependency>

https://docs.spring.io/spring-boot/docs/current/reference/html/howto-embedded-web-servers.html

如何在 spring boot 2 中配置 netty

How to configure netty in spring boot 2

spring-boot

reactor-netty

spring-webflux