Spring Boot中Stomp与Amazon MQ连接异常及连接池配置咨询

当前出现的AMQ连接数异常情况，核心原因是缺少底层TCP连接池复用机制：

• 当并行Stomp连接数低于500时，系统资源充足，临时创建的AMQ连接能被及时回收或复用，所以总连接数低于Stomp连接数；
• 当连接数超过800后，高并发下无限制创建新的AMQ连接，加上Reactor Netty默认TCP客户端没有连接数限制，同时AMQ端可能存在连接回收延迟（比如TIME_WAIT状态连接未及时清理），最终导致连接数飙升至3500。

通过给Reactor Netty TCP客户端添加连接池配置，限制最大连接数、空闲超时等参数，实现连接复用，避免无限制创建连接。

修改后的完整配置代码 #

public void configureMessageBroker(MessageBrokerRegistry registry) {
    SslContext sslContext;
    try {
        sslContext = SslContextBuilder.forClient()
                .sslProvider(SslProvider.JDK)
                .trustManager(InsecureTrustManagerFactory.INSTANCE) // 生产环境请替换为可信CA证书管理器
                .build();

        // 配置Reactor Netty连接池核心参数
        ConnectionProvider connectionProvider = ConnectionProvider.create("amq-connection-pool",
                ConnectionProvider.builder()
                        .maxConnections(300) // 最大连接数，根据业务压测调整，建议200-500
                        .pendingAcquireTimeout(Duration.ofSeconds(10)) // 连接获取超时时间
                        .maxIdleTime(Duration.ofMinutes(5)) // 空闲连接自动回收时间
                        .build());

        ReactorNettyTcpClient<byte[]> client = new ReactorNettyTcpClient<>(
                tcpClient -> tcpClient
                        .connectionProvider(connectionProvider)
                        .remoteAddress(socketAddressSupplier())
                        .secure(ssl -> ssl.sslContext(sslContext)),
                new StompReactorNettyCodec());

        registry.enableStompBrokerRelay(stompBrokerConfigurationProperties.getRelay())
                .setAutoStartup(true)
                .setSystemLogin(stompBrokerConfigurationProperties.getLogin())
                .setSystemPasscode(stompBrokerConfigurationProperties.getPassword())
                .setClientLogin(stompProperties.getLogin())
                .setClientPasscode(stompProperties.getPassword())
                .setTcpClient(client);

        registry.setApplicationDestinationPrefixes(stompProperties.getAppDestinationPrefix());
        registry.setUserDestinationPrefix(stompProperties.getUserDestinationPrefix());
    } catch (SSLException e) {
        log.error(IpcLoggerConstants.EXCEPTION_OCCURRED, e);
    }
}

关键配置说明 #

• maxConnections：限制到AMQ的最大TCP连接数，从根源避免连接数无限制飙升，需结合业务峰值压测后调整；
• pendingAcquireTimeout：当连接池无可用连接时，设置等待超时时间，防止线程长期阻塞；
• maxIdleTime：自动回收闲置连接，释放不必要的资源；
• 生产环境必须替换InsecureTrustManagerFactory为加载可信CA证书的管理器，避免安全风险。

额外优化建议 #

• 复用系统连接：StompBrokerRelay的系统连接（用于发送消息到Broker）和客户端连接共用同一个连接池，减少连接创建开销；
• 配合AMQ端配置：在Amazon MQ控制台设置maxConnections、connectionTimeout等参数，和应用端连接池形成联动；
• 监控连接状态：通过Spring Boot Actuator或Amazon MQ监控面板，实时跟踪连接数、空闲连接数，动态调整配置参数。

内容的提问来源于stack exchange，提问作者Sibendra Pratap Singh