Reactor Netty TCP客户端maxConnections配置不生效问题求助

你的代码仅创建了单个TCP连接，并未触发连接池的多连接逻辑，因此无论请求量多大，始终只会有1个通道/套接字。

核心问题点 #

你调用connectNow()只获取了1个连接实例，随后通过connection.onDispose().block()阻塞了该连接的生命周期，整个程序只会维持这一个连接，连接池配置的maxConnections=50完全没有被触发的机会。连接池的作用是在存在多个并发请求需要处理时，自动复用空闲连接或创建新连接，而非主动预创建50个连接。

修正后的示例代码 #

以下是调整后的代码，模拟多并发请求以触发连接池创建多个连接：

import reactor.netty.Connection;
import reactor.netty.resources.ConnectionProvider;
import reactor.netty.tcp.TcpClient;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import java.time.Duration;

public class Application {

    public static void main(String[] args) {
        ConnectionProvider provider =
                ConnectionProvider.builder("fixed")
                                  .maxConnections(50)
                                  .pendingAcquireTimeout(Duration.ofSeconds(60))
                                  .build();

        TcpClient tcpClient = TcpClient.create(provider)
                                      .host("example.com")
                                      .port(80);

        // 模拟100个并发请求，每个请求通过连接池获取连接发送数据
        Flux.range(1, 100)
            .flatMap(i -> tcpClient.connect()
                                   .flatMap(connection -> 
                                       connection.outbound()
                                                 .sendString(Mono.just("Request " + i))
                                                 .then()
                                                 // 请求完成后归还连接到池
                                                 .doFinally(signal -> connection.dispose())
                                   ))
            .blockLast();

        // 关闭连接池释放资源
        provider.disposeLater().block();
    }
}

关键说明 #

• 不再直接调用connectNow()获取单个连接，而是通过TcpClient.connect()让连接池负责连接的获取与管理。
• 用Flux.range配合flatMap模拟并发请求，当请求数超过当前空闲连接数时，连接池会自动创建新连接，直到达到maxConnections=50的上限。
• 每个请求完成后调用connection.dispose()，将连接归还连接池以便复用。
• 程序结束前调用provider.disposeLater()关闭连接池，释放所有资源。

额外提示 #

如果希望连接池优先复用连接而非每次创建新连接，可以移除doFinally中的connection.dispose()，此时连接池会自动复用空闲连接。当请求并发量较高时，连接数会逐步增长到maxConnections上限，之后将持续复用现有连接。

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