Spring Integration报错：单向MessageHandler无法配置outputChannel问题排查

错误核心原因 #

你自定义的requestHandler是单向MessageHandler（执行后不返回任何消息），Spring Integration的流规则中，单向Handler是整个流的终点，不允许在其后续配置输出通道或继续串联下游流，这就是异常提示的核心原因。

另外你的配置还有两个明显问题：

• 手动给requestHandler(null)、sftpSessionFactory(null)传null，违背Spring依赖注入的规则，Spring会自动管理这些Bean的注入，不需要手动传参；
• 子流sftpTransferFlow()的连接方式错误，单向Handler后无法通过.to()链式调用下游流。

修正方案 #

根据你的需求（SFTP传输+禁用临时文件重命名），分两种场景给出修正代码：

场景1：requestHandler仅做消息预处理，需传递消息到SFTP流 #

如果requestHandler只是对FileSubmitRequest做预处理，然后要把处理后的文件传递给SFTP组件，应该将其改为消息转换器（Transformer），而非单向Handler：

// 把原requestHandler改为Transformer，返回要传输的File对象
@Bean
public GenericTransformer<FileSubmitRequest, File> requestTransformer(FileTransferService service) {
    return payload -> {
        // 这里执行你的业务逻辑，比如调用service处理请求，最终返回要上传的File
        return service.processRequestAndGetFile(payload);
    };
}

@Bean(name = "requestChannel")
public MessageChannel requestChannel() {
    return new DirectChannel();
}

// 整合SFTP逻辑到主流，直接链式调用
@Bean
public IntegrationFlow mainFlow(SftpSessionFactory sftpSessionFactory) throws IOException {
    return IntegrationFlow.from(requestChannel())
            .transform(requestTransformer(null)) // Spring自动注入FileTransferService
            .handle(Sftp.outboundAdapter(sftpSessionFactory)
                    .useTemporaryFileName(false)) // 禁用临时文件重命名
            .get();
}

// 确保sftpSessionFactory是正确配置的Bean，比如：
@Bean
public SftpSessionFactory sftpSessionFactory() {
    DefaultSftpSessionFactory factory = new DefaultSftpSessionFactory(true);
    factory.setHost("your-sftp-host");
    factory.setPort(22);
    factory.setUser("username");
    factory.setPassword("password");
    // 其他配置如密钥、超时等
    return factory;
}

场景2：requestHandler需独立处理逻辑，再主动触发SFTP传输 #

如果requestHandler必须作为独立的单向Handler，那么需要让它主动将消息发送到SFTP流的输入通道，而非通过链式调用：

@Bean
public MessageHandler requestHandler(FileTransferService service, MessageChannel sftpInputChannel) {
    return message -> {
        FileSubmitRequest payload = (FileSubmitRequest) message.getPayload();
        // 执行你的业务逻辑
        File fileToTransfer = service.send(payload);
        // 主动发送消息到SFTP流的输入通道
        sftpInputChannel.send(MessageBuilder.withPayload(fileToTransfer).build());
    };
}

@Bean(name = "requestChannel")
public MessageChannel requestChannel() {
    return new DirectChannel();
}

@Bean(name = "sftpInputChannel")
public MessageChannel sftpInputChannel() {
    return new DirectChannel();
}

// 主流仅处理requestHandler，作为流的终点
@Bean
public IntegrationFlow mainFlow() {
    return IntegrationFlow.from(requestChannel())
            .handle(requestHandler(null, sftpInputChannel()))
            .get();
}

// SFTP流从独立的输入通道接收消息
@Bean
public IntegrationFlow sftpTransferFlow(SftpSessionFactory sftpSessionFactory) throws IOException {
    return IntegrationFlow.from(sftpInputChannel())
            .handle(Sftp.outboundAdapter(sftpSessionFactory)
                    .useTemporaryFileName(false))
            .get();
}

关键注意点 #

• 所有Spring管理的Bean（如FileTransferService、SftpSessionFactory）都不需要手动传null，Spring会自动完成依赖注入；
• 单向MessageHandler（无返回消息）只能作为流的最后一个组件，不能在其后配置任何下游逻辑；
• useTemporaryFileName(false)的配置是正确的，该参数确实会禁用SFTP传输时的临时文件重命名机制。

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