Spring Integration SFTP入站适配器长期运行后无法下载文件求助

根据你的描述和配置代码，我之前碰到过类似的SFTP会话池资源泄漏和失效会话堆积的问题，结合Spring Integration和JSch的特性，给你梳理几个关键的修复方向：

1. 给缓存会话添加过期清理机制 #

你当前的CachingSessionFactory只设置了最大会话数8，但没配置会话过期时间。SFTP服务器一般会主动断开长时间空闲的会话，这些失效会话如果留在缓存池里，不仅会导致后续操作失败，还会占满池容量，让新会话无法创建——这很可能是你运行一段时间后下载停止的核心原因。

修改缓存会话工厂的配置，加上过期和定时清理：

@Bean(name="sessionFactoryCached") 
public CachingSessionFactory getCachingSessionFactory(){ 
    CachingSessionFactory cachingSessionFactory = new CachingSessionFactory(defaultSftpSessionFactory,8); 
    cachingSessionFactory.setTestSession(true);
    // 设置会话空闲30分钟后过期（可根据你的SFTP服务器超时配置调整）
    cachingSessionFactory.setSessionWaitTimeout(1800000);
    // 启用定时任务清理过期会话
    cachingSessionFactory.setTaskScheduler(sessionCleanupScheduler());
    return cachingSessionFactory; 
}

@Bean
public TaskScheduler sessionCleanupScheduler() {
    ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
    scheduler.setPoolSize(2);
    scheduler.setThreadNamePrefix("sftp-session-cleanup-");
    return scheduler;
}

sessionWaitTimeout会让空闲超时的会话被标记为失效，TaskScheduler则定期把这些失效会话从池子里清掉，保证缓存里的都是可用会话。

2. 修复Bean名称不匹配的问题 #

我注意到一个关键配置错误：你的Java配置里缓存会话工厂的Bean名称是sessionFactoryCached，但XML里的入站适配器引用的是cachedSftpSessionFactory！这意味着你的入站适配器根本没用到缓存会话工厂，而是直接用了未缓存的DefaultSftpSessionFactory——频繁创建销毁会话很容易触发SFTP服务器的连接限制，甚至导致资源耗尽，重启后就会出现挂起的情况。

必须统一Bean名称：
把Java配置里的缓存会话工厂Bean名称改成cachedSftpSessionFactory：

@Bean(name="cachedSftpSessionFactory") 
public CachingSessionFactory getCachingSessionFactory(){ 
    // 原有逻辑不变
}

确保XML里的session-factory="cachedSftpSessionFactory"和Java的Bean名称完全一致，这样才会真正复用会话。

3. 优化轮询频率与会话释放策略 #

你设置的fixed-rate="1000"每秒轮询一次太频繁了，会让会话池一直处于高负载状态，甚至出现会话被占满的情况。建议改成fixed-delay="5000"（每5秒轮询一次），给服务器和会话池留足喘息时间。

另外，启用CachingSessionFactory的resetOnClose属性，确保会话归还缓存时重置状态，避免残留的异常影响后续使用：

cachingSessionFactory.setResetOnClose(true);

4. 给JSch会话添加超时参数 #

因为你用了SOCKS5代理，重启后挂起很可能是会话建立阶段卡在代理连接上了。给JSch的会话配置加上超时参数：

@Bean(name="sessionConfig") 
public PropertiesFactoryBean getPropertiesFactoryBean(){ 
    PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean(); 
    Properties properties = new Properties(); 
    properties.setProperty("StrictHostKeyChecking", "no");
    // 会话建立超时30秒，避免进程挂起
    properties.setProperty("connectTimeout", "30000");
    // 每分钟发送心跳包，保持会话活跃
    properties.setProperty("serverAliveInterval", "60000");
    propertiesFactoryBean.setProperties(properties); 
    return propertiesFactoryBean; 
}

connectTimeout会限制会话建立的最长时间，防止重启后因代理或服务器问题导致进程挂起；serverAliveInterval定期发心跳，减少服务器主动断开会话的概率。

5. 优化共用通道的配置 #

多个入站适配器共用同一通道时，要防止消息堆积阻塞后续轮询。给通道加上缓冲队列：

<int:channel id="ftpInputChannel">
    <int:queue capacity="100"/>
</int:channel>

同时确保通道的消费端能及时处理消息，避免消息堆积占用内存，间接影响会话池的正常运作。

6. 添加会话池监控日志 #

加个监听器监控会话池的状态，方便排查问题：

@Slf4j
@Component
public class SftpSessionMonitor implements ApplicationListener<SessionEvent> {
    @Override
    public void onApplicationEvent(SessionEvent event) {
        if (event instanceof SessionCreatedEvent) {
            CachingSessionFactory factory = (CachingSessionFactory) event.getSource();
            log.info("新建SFTP会话，当前池大小: {}", factory.getSessionCacheSize());
        } else if (event instanceof SessionClosedEvent) {
            CachingSessionFactory factory = (CachingSessionFactory) event.getSource();
            log.info("关闭SFTP会话，当前池大小: {}", factory.getSessionCacheSize());
        } else if (event instanceof SessionFailedEvent) {
            log.error("SFTP会话失败", event.getException());
        }
    }
}

通过日志能直观看到会话的创建、关闭和失败情况，快速定位是否有会话泄漏或池耗尽的问题。

按照这些步骤调整后，应该能解决运行一段时间后下载停止、重启挂起的问题，保证系统长期稳定运行。

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