Spring Integration RSS Feed Adapter接收数据时线程阻塞问题咨询

根因分析 #

从提供的线程栈信息可明确两个核心问题：

1. org.springframework.integration.feed.inbound.FeedEntryMessageSource 类的 doReceive、getFeed 方法自带实例级对象锁，设计上同一时间单实例仅允许一个线程执行RSS拉取逻辑。你给Poller配置多线程池的方案不会生效，所有线程争夺同一把实例锁，自然会出现8个线程阻塞等待1个持锁线程的情况。
2. 当前持锁的线程卡在SocketInputStream.socketRead0 原生调用，是因为Spring Integration Feed 5.5.0版本默认使用的Rome工具库、JDK内置HttpURLConnection均未配置读超时，当目标RSS源服务无响应、网络链路不稳定时，线程会无限期阻塞在网络读操作上，长期持锁导致所有拉取任务完全停滞。

解决方案 #

• 配置网络超时控制：自定义Rome的FeedFetcher实现，显式设置连接超时、读超时参数，替换FeedEntryMessageSource默认使用的无超时Fetcher，避免线程无限期阻塞在网络调用上。
• 调整并行拉取实现：如果需要并行拉取多个不同的RSS源，不要复用同一个FeedEntryMessageSource实例，每个RSS源单独创建独立的FeedEntryMessageSource实例，各实例持有独立的锁，避免不同源的拉取任务互相阻塞。
• 优化线程池配置：给公共ThreadPoolTaskExecutor添加线程存活超时设置、合理的拒绝策略，避免阻塞线程长期占满池资源影响其他业务逻辑运行。
• 可选升级依赖：可升级到spring-integration-feed 5.5.x系列最新维护版本，官方后续版本对锁的持有逻辑做了优化，缩短了锁的持有时长，可大幅降低线程阻塞概率。

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