Spring Integration是否支持FTP代理？如何通过代理获取FTP服务器文件？

当然支持啦！Spring Integration的FTP模块完全可以配合代理访问远程FTP服务器，而且DefaultFtpSessionFactory（或是它的缓存版本CachingSessionFactory）就能搞定这个需求，下面我给你详细拆解具体的实现步骤：

一、给DefaultFtpSessionFactory配置代理信息 #

DefaultFtpSessionFactory底层依赖Apache Commons Net的FTPClient，所以我们可以直接通过它设置代理相关参数，两种配置方式供你选择：

方式1：直接设置代理属性 #

这种方式最简洁，适合基础的代理场景：

@Bean
public DefaultFtpSessionFactory ftpSessionFactory() {
    DefaultFtpSessionFactory factory = new DefaultFtpSessionFactory();
    // 基础FTP服务器配置
    factory.setHost("你的远程FTP服务器地址");
    factory.setPort(21);
    factory.setUsername("FTP登录用户名");
    factory.setPassword("FTP登录密码");
    
    // 设置HTTP代理（如果是SOCKS代理，把Proxy.Type.HTTP换成Proxy.Type.SOCKS即可）
    factory.setProxy(new Proxy(Proxy.Type.HTTP, new InetSocketAddress("代理服务器地址", 代理端口)));
    // 如果代理需要认证，添加这行
    factory.setProxyCredentials(new UsernamePasswordCredentials("代理用户名", "代理密码"));
    
    return factory;
}

方式2：自定义FTPClient配置 #

如果需要更细粒度的控制（比如特殊的代理类型配置），可以直接操作底层的FTPClient实例：

@Bean
public DefaultFtpSessionFactory ftpSessionFactory() {
    DefaultFtpSessionFactory factory = new DefaultFtpSessionFactory();
    // 基础FTP服务器配置...
    
    factory.setFtpsClientConfigurer(ftpClient -> {
        // 设置SOCKS代理
        ftpClient.setProxy(new Proxy(Proxy.Type.SOCKS, new InetSocketAddress("SOCKS代理地址", 1080)));
        // SOCKS代理带认证的话，额外设置认证信息
        if (ftpClient instanceof FTPClient) {
            ((FTPClient) ftpClient).setProxyAuth("代理用户名", "代理密码");
        }
    });
    
    return factory;
}

二、用CachingSessionFactory优化会话性能 #

如果你的应用需要频繁和FTP服务器交互，推荐用CachingSessionFactory包装DefaultFtpSessionFactory，它会缓存会话实例，避免重复创建连接，大幅提升性能：

@Bean
public CachingSessionFactory<FTPFile> cachingFtpSessionFactory(DefaultFtpSessionFactory ftpSessionFactory) {
    return new CachingSessionFactory<>(ftpSessionFactory);
}

三、构建文件同步的集成流 #

有了配置好的会话工厂，就可以搭建Spring Integration的FTP集成流来实现远程文件同步了，比如下面这个简单的示例：

@Bean
public IntegrationFlow ftpInboundFlow(CachingSessionFactory<FTPFile> cachingFtpSessionFactory) {
    return IntegrationFlows.from(Ftp.inboundAdapter(cachingFtpSessionFactory)
                    .remoteDirectory("/远程FTP上的目标目录")
                    .localDirectory(new File("本地存储文件的路径"))
                    .deleteRemoteFiles(false) // 按需设置是否删除远程文件
                    .filter(new FtpSimplePatternFileListFilter("*.txt"))), // 按需设置文件过滤规则
            e -> e.poller(Pollers.fixedDelay(5000))) // 轮询间隔，这里是5秒一次
            .handle(message -> {
                // 这里可以添加下载后的文件处理逻辑
                System.out.println("成功下载文件：" + message.getPayload());
            })
            .get();
}

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