使用自定义Apache HttpAsyncClient的AsyncRestTemplate线程数异常问题

我之前也遇到过类似的问题，咱们一步步拆解原因和解决方案：

问题根源分析 #

1. 默认AsyncRestTemplate的线程模型
   当你直接用new AsyncRestTemplate()创建实例时，底层默认使用SimpleAsyncTaskExecutor——这个执行器的特点是每次请求都会新建一个线程，所以你看到的线程名是SimpleAsyncTaskExecutor-1..n。它适合低并发场景，但高并发下容易出现线程爆炸的问题。

2. 切换到HttpComponentsAsyncClientHttpRequestFactory后的线程限制
   当你引入自定义的HttpComponentsAsyncClientHttpRequestFactory后，AsyncRestTemplate会依赖Apache HttpAsyncClient的NIO线程池来处理网络I/O。而HttpAsyncClient的默认I/O线程数只有2，所有的回调逻辑都会复用这两个线程，一旦回调有耗时操作（比如业务计算、DB调用），就会阻塞I/O线程，导致整个客户端的处理能力骤降，这就是你业务逻辑出问题的核心原因。

解决方案：自定义HttpAsyncClient线程池+分离回调线程 #

我们需要从两个方面调整：一是扩大HttpAsyncClient的I/O线程池，二是把回调任务放到单独的线程池执行，避免阻塞I/O线程。

1. 配置自定义HttpAsyncClient（包含SSL和线程池参数） #

先实现你的自定义SSL逻辑，然后配置HttpAsyncClient的I/O线程池和连接池参数：

// 1. 实现你的自定义SSL上下文逻辑
SSLContext sslContext = ...; // 这里替换成你实际的SSL配置代码

// 2. 配置I/O反应器（调整I/O线程数）
IOReactorConfig ioReactorConfig = IOReactorConfig.custom()
        .setIoThreadCount(10) // 根据你的并发需求调整，比如8-16个线程
        .setConnectTimeout(5000) // 连接超时
        .setSoTimeout(5000) // 读取超时
        .build();

// 3. 创建自定义HttpAsyncClient
CloseableHttpAsyncClient asyncHttpClient = HttpAsyncClients.custom()
        .setSSLContext(sslContext)
        .setDefaultIOReactorConfig(ioReactorConfig)
        .setMaxConnTotal(50) // 全局最大连接数
        .setMaxConnPerRoute(20) // 单路由最大连接数
        .build();

2. 配置AsyncRestTemplate，分离回调线程 #

为了避免回调逻辑阻塞I/O线程，我们给AsyncRestTemplate单独配置一个回调线程池：

// 创建回调专用的线程池
ThreadPoolTaskExecutor callbackExecutor = new ThreadPoolTaskExecutor();
callbackExecutor.setCorePoolSize(10); // 核心线程数
callbackExecutor.setMaxPoolSize(20); // 最大线程数
callbackExecutor.setQueueCapacity(100); // 任务队列容量
callbackExecutor.setThreadNamePrefix("AsyncRest-Callback-"); // 线程名前缀，方便日志排查
callbackExecutor.initialize();

// 创建HttpRequestFactory并传入自定义HttpAsyncClient
HttpComponentsAsyncClientHttpRequestFactory requestFactory = new HttpComponentsAsyncClientHttpRequestFactory(asyncHttpClient);

// 初始化AsyncRestTemplate，传入回调线程池和请求工厂
AsyncRestTemplate asyncRestTemplate = new AsyncRestTemplate(callbackExecutor, requestFactory);

关键注意点 #

• I/O线程不能阻塞：HttpAsyncClient的I/O线程是用来处理网络读写的，绝对不能在回调里执行耗时操作（比如同步DB查询、复杂计算），否则会拖垮整个客户端的处理能力。
• 线程池参数要适配业务：ioThreadCount、连接池大小、回调线程池的参数都需要根据你的实际并发量调整，比如高并发场景下可以适当增大线程数和连接数。
• 资源释放：在应用关闭时，记得关闭CloseableHttpAsyncClient和线程池，避免资源泄漏。

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