如何为Spring JmsTemplate配置连接池并提升MQ消息发送TPS？

1. Spring JmsTemplate 是否可以使用连接池？ #

完全可以。默认配置的JmsTemplate每次发送消息都会创建新的连接和会话，频繁的资源创建销毁会导致性能低下。使用连接池（或缓存工厂）复用连接、会话，能大幅降低开销提升性能。

你当前使用的CachingConnectionFactory是Spring提供的会话缓存实现，通过设置sessionCacheSize=10已经在复用会话资源。如果需要更精细化的连接池管理，也可以结合Apache Commons Pool实现PooledConnectionFactory，不过CachingConnectionFactory对大多数生产场景已经足够。

2. 如何增加异步线程数，提升TPS？ #

你用@Async实现异步发送，但Spring默认的异步线程池核心线程数为8，这就是同时只有8个线程执行的原因。需要自定义异步线程池来调整线程配额：

步骤1：配置自定义异步线程池 #

创建配置类定义自定义线程池：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executor;

@Configuration
@EnableAsync
public class AsyncConfig {

    @Bean(name = "mqAsyncExecutor")
    public Executor mqAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(20); // 核心线程数，根据CPU核数、MQ负载调整
        executor.setMaxPoolSize(50); // 最大线程数
        executor.setQueueCapacity(1000); // 任务队列容量，避免任务堆积溢出
        executor.setThreadNamePrefix("MQ-Sender-"); // 线程名前缀，便于日志排查
        executor.initialize();
        return executor;
    }
}

步骤2：指定@Async使用自定义线程池 #

修改JMSConfiguration2中的注解，绑定自定义线程池：

@Async("mqAsyncExecutor") // 指定使用自定义线程池
public void insertIntoMQ(String kafkaMessage) {
    // 原有业务逻辑保持不变
}

3. 额外性能优化建议 #

• 优化CachingConnectionFactory配置：设置cacheProducers=true缓存生产者，cacheConsumers=false（无需缓存消费者）；开启reconnectOnException=true，避免连接异常后无法复用资源。
• 批量发送消息：如果业务允许，将多条消息批量发送，减少网络交互次数，比如通过JmsTemplate的send方法结合MessageCreator批量构建消息。
• 调整IBM MQ客户端参数：开启客户端自动重连（setClientReconnectOptions），调整通道的发送窗口大小、最大消息长度等参数，适配高并发场景。
• 监控瓶颈点：用Spring Boot Actuator监控线程池的活跃线程数、队列长度，同时监控IBM MQ的队列深度、连接数，排查是否是MQ端的资源限制导致性能上不去。

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