Spring Integration Ftp.outboundAdapter动态会话工厂配置问题

你遇到的核心问题是集成流初始化时机与运行时动态参数的冲突：

• Spring Integration的IntegrationFlow在应用启动阶段完成初始化，你在handle方法的Lambda中尝试从消息头获取branch配置Ftp.outboundAdapter，这段代码实际是在初始化时执行的，而非消息处理的运行时。此时没有实际消息，branch值为null，导致创建的FTP适配器使用了无效的SessionFactory，但Spring Integration初始化阶段不会强制校验FTP连接，所以无报错，运行时自然无法发送文件。
• 硬编码branch时，SessionFactory在初始化阶段就被配置为有效实例，因此能正常发送文件。

最优雅的解决方案是用DelegatingSessionFactory，它可以根据消息头的branch参数，动态选择对应的FTP SessionFactory，无需在运行时重新创建适配器。

步骤1：配置多分支SessionFactory与DelegatingSessionFactory #

// 配置分支A的FTP SessionFactory
@Bean
public SessionFactory<FTPFile> ftpSessionFactoryBranchA() {
    DefaultFtpSessionFactory factory = new DefaultFtpSessionFactory();
    factory.setHost("branchA-host");
    factory.setUsername("branchA-user");
    factory.setPassword("branchA-pass");
    factory.setPort(21);
    // 按需添加被动模式、编码等额外配置
    return factory;
}

// 配置分支B的FTP SessionFactory
@Bean
public SessionFactory<FTPFile> ftpSessionFactoryBranchB() {
    DefaultFtpSessionFactory factory = new DefaultFtpSessionFactory();
    factory.setHost("branchB-host");
    factory.setUsername("branchB-user");
    factory.setPassword("branchB-pass");
    return factory;
}

// 配置DelegatingSessionFactory统一管理所有分支工厂
@Bean
public DelegatingSessionFactory<FTPFile> delegatingFtpSessionFactory() {
    Map<Object, SessionFactory<FTPFile>> branchFactories = new HashMap<>();
    branchFactories.put("branchA", ftpSessionFactoryBranchA());
    branchFactories.put("branchB", ftpSessionFactoryBranchB());
    
    DelegatingSessionFactory<FTPFile> delegatingFactory = new DelegatingSessionFactory<>(branchFactories);
    // 设置默认工厂（可选，当branch参数无效时使用）
    delegatingFactory.setDefaultSessionFactory(ftpSessionFactoryBranchA());
    // 指定从消息头获取branch值来匹配对应的SessionFactory
    delegatingFactory.setSessionFactorySelector(message -> message.getHeaders().get("branch"));
    
    return delegatingFactory;
}

步骤2：重构IntegrationFlow配置 #

使用DelegatingSessionFactory创建FTP出站适配器，同时通过表达式动态指定文件名和远程目录（可选）：

@Bean
public IntegrationFlow ftpOutboundFlow(DelegatingSessionFactory<FTPFile> delegatingSessionFactory) {
    return IntegrationFlow.from(FtpFileGateway.class)
            .handle(Ftp.outboundAdapter(delegatingSessionFactory)
                    .useTemporaryFileName(false) // 禁用临时文件名，直接使用指定文件名
                    .fileNameExpression("headers['fileName']") // 从消息头获取目标文件名
                    .remoteDirectoryExpression("'/remote/base/' + headers['branch']") // 可选：按分支划分远程目录
            )
            .get();
}

步骤3：定义Gateway接口 #

保持原有参数传递逻辑，确保branch被放入消息头：

public interface FtpFileGateway {
    @Gateway
    void sendFile(@Payload byte[] fileContent, 
                  @Header("fileName") String fileName, 
                  @Header("branch") String branch);
}

替代方案：使用内置SESSION_FACTORY_HEADER头 #

如果你不想自定义sessionFactorySelector，可以直接使用Spring Integration内置的IntegrationMessageHeaderAccessor.SESSION_FACTORY_HEADER头，将branch值放入该头中，DelegatingSessionFactory会自动匹配对应的SessionFactory：

public interface FtpFileGateway {
    @Gateway
    void sendFile(@Payload byte[] fileContent, 
                  @Header("fileName") String fileName, 
                  @Header(IntegrationMessageHeaderAccessor.SESSION_FACTORY_HEADER) String branch);
}

此时无需为DelegatingSessionFactory设置sessionFactorySelector，它会自动根据该头的value匹配对应的SessionFactory key。

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