Reactor Netty HTTP服务器连接限制及指标发布问题咨询

1. 获取并修改Reactor Netty HTTP服务器默认最大连接数 #

默认值获取 #

Reactor Netty 0.9.20中，HTTP服务器的最大连接数由两部分控制：

• 连接池最大活跃连接数：默认使用FixedConnectionProvider，默认值为500。可通过代码直接获取：

  int defaultMaxConnections = HttpServer.create().connectionProvider().maxConnections();
  

• TCP背队列大小（SO_BACKLOG）：默认值为100，控制等待被接受的连接队列长度，可通过ChannelOption.SO_BACKLOG查看。

修改参数的两种方式 #

方式一：Spring Boot配置文件

直接通过配置属性覆盖默认值：

server:
  netty:
    max-connections: 1000  # 修改连接池最大活跃连接数
    backlog: 200            # 修改TCP背队列大小
    connection-timeout: 30000  # 可选：连接超时时间，单位毫秒

方式二：编程式自定义配置

通过NettyServerCustomizer Bean手动配置HttpServer：

import reactor.netty.http.server.HttpServer;
import reactor.netty.resources.ConnectionProvider;
import org.springframework.boot.web.embedded.netty.NettyServerCustomizer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import io.netty.channel.ChannelOption;

@Configuration
public class NettyServerConfig {
    @Bean
    public NettyServerCustomizer nettyServerCustomizer() {
        return httpServer -> httpServer
                // 自定义连接池，设置最大连接数为1000
                .connectionProvider(ConnectionProvider.fixed("custom-http-pool", 1000))
                // 设置TCP背队列大小
                .option(ChannelOption.SO_BACKLOG, 200);
    }
}

2. 发布Reactor Netty HTTP服务器的连接/事件循环延迟指标 #

问题原因 #

你配置的management.metrics.enable.reactor.netty.http.server.connections=true在Spring Boot 2.3.x + Reactor Netty 0.9.x版本中无法自动生效，因为该版本的Reactor Netty不会自动注册HTTP服务器指标，需要手动绑定MetricsRecorder并启用调度器指标。

解决方案 #

步骤1：确保依赖齐全

确认pom.xml（Maven）或build.gradle（Gradle）中包含Micrometer相关依赖：

<!-- Maven -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
    <groupId>io.micrometer</groupId>
    <artifactId>micrometer-registry-prometheus</artifactId>
</dependency>

步骤2：配置HTTP服务器指标

通过NettyServerCustomizer绑定MeterRegistry，启用HTTP服务器的连接、请求等指标：

import io.micrometer.core.instrument.MeterRegistry;
import reactor.netty.http.server.HttpServer;
import reactor.netty.http.server.HttpServerMetricsRecorder;
import org.springframework.boot.web.embedded.netty.NettyServerCustomizer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class NettyMetricsConfig {
    @Bean
    public NettyServerCustomizer nettyServerMetricsCustomizer(MeterRegistry meterRegistry) {
        return httpServer -> httpServer
                // 启用指标，第二个参数可自定义URI标签规则（比如忽略特定路径）
                .metrics(true, uri -> uri)
                // 绑定MeterRegistry，指定指标前缀
                .metricsRecorder(new HttpServerMetricsRecorder(meterRegistry, "reactor.netty.http.server"));
    }
}

步骤3：启用事件循环延迟指标

在配置文件中开启Reactor调度器的指标，即可获取事件循环延迟数据：

management:
  metrics:
    enable:
      reactor:
        scheduler: true  # 启用Reactor调度器（事件循环）的延迟指标
    tags:
      application: your-application-name  # 可选：给指标添加全局标签
  endpoints:
    web:
      exposure:
        include: metrics,prometheus  # 暴露metrics和prometheus端点

验证指标 #

启动应用后，访问/actuator/prometheus端点，可查看以下相关指标：

• reactor_netty_http_server_connections_active：当前活跃连接数
• reactor_netty_http_server_connections_total：总连接数
• reactor_scheduler_delay_seconds：事件循环延迟指标

内容的提问来源于stack exchange，提问作者Arpit