Spring TCP Support高CPU使用率问题排查求助

嘿，我之前也踩过Spring TCP Support搭建服务器时CPU飙高的坑，结合你给出的代码片段（虽然没贴全），大概率是线程模型或者连接处理逻辑出了问题，我给你梳理几个常见的排查方向和解决办法：

1. 检查线程池配置，避免单线程忙等待 #

默认情况下，Spring TCP的TcpNetServerConnectionFactory如果没指定任务执行器，可能会用单线程处理连接和消息。如果你的消息处理逻辑有阻塞或者循环，很容易直接把CPU占满。

解决方案：给TCP适配器配置一个线程池，让连接处理并行化，避免单线程过载：

@Bean
public ThreadPoolTaskExecutor tcpTaskExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(5);
    executor.setMaxPoolSize(10);
    executor.setQueueCapacity(20);
    executor.initialize();
    return executor;
}

// 在适配器中关联线程池
@Bean
public TcpReceivingChannelAdapter tcpReceivingChannelAdapter() {
    TcpReceivingChannelAdapter adapter = new TcpReceivingChannelAdapter();
    adapter.setConnectionFactory(tcpServerConnectionFactory());
    adapter.setOutputChannel(tcpInputChannel());
    adapter.setTaskExecutor(tcpTaskExecutor()); // 关键配置
    return adapter;
}

2. 排查是否存在无限循环的消息流转 #

如果你的消息处理逻辑中，不小心把处理后的消息又发回了输入通道（比如DirectChannel的下游处理器错误路由），就会触发无限循环，直接拉满CPU。

解决方案：

• 给通道添加日志拦截器，追踪消息的流转路径，比如配置LoggingChannelInterceptor；
• 检查@ServiceActivator或者自定义消息处理器的逻辑，确保处理完的消息不会重新进入输入通道。

3. 配置连接超时，避免空闲连接的忙等待 #

如果客户端发送请求后没有正确关闭连接，服务器端的read()操作可能会进入非阻塞轮询状态，导致CPU持续高负载。

解决方案：给连接工厂设置合理的超时时间，让空闲连接自动关闭：

@Bean
public TcpConnectionFactory tcpServerConnectionFactory() {
    TcpNetServerConnectionFactory factory = new TcpNetServerConnectionFactory(port);
    factory.setSoTimeout(5000); // 设置5秒超时，空闲连接自动关闭
    return factory;
}

另外，在消息处理完成后，也可以主动关闭连接：

@ServiceActivator(inputChannel = "tcpInputChannel")
public String handleMessage(String payload, @Header(IpHeaders.CONNECTION_ID) String connectionId) {
    // 处理消息逻辑
    String response = "处理完成";
    // 主动关闭连接
    tcpConnectionFactory.getConnection(connectionId).close();
    return response;
}

调试小技巧 #

• 用VisualVM或者JProfiler查看线程栈，定位占用CPU最高的线程，看它卡在哪个代码片段；
• 开启Spring Integration的DEBUG日志，观察消息的接收、处理和发送流程，是否有异常循环。

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