使用SftpRemoteFileTemplate删除远程文件时遇集成流异常求助

异常1：BeanCreationException（单向组件配置outputChannel错误） #

问题原因 #

SftpRemoteFileTemplate的remove()操作属于单向MessageHandler，无返回结果，因此不需要配置outputChannel。此前使用的SftpOutboundGateway是请求-响应模式，依赖输出通道，但模板的单向操作会导致集成流配置冲突，触发nullChannel()相关异常。

解决方案 #

调整集成流配置，移除该端点的outputChannel设置。示例代码：

@Bean
public IntegrationFlow deleteRemoteFileFlow(SftpRemoteFileTemplate sftpRemoteFileTemplate) {
    return IntegrationFlow.from("deleteFileChannel")
            // 从消息头提取信息，构建远程文件路径（返回String类型）
            .transform(message -> {
                MessageHeaders headers = message.getHeaders();
                return headers.get("remoteDir", String.class) + "/" + headers.get("fileName", String.class);
            })
            // 调用template的remove方法，无需指定outputChannel
            .handle(sftpRemoteFileTemplate, "remove")
            .get();
}

异常2：MessageTransformationException（String转Message类型转换错误） #

问题原因 #

改用get()后出现类型转换异常，是因为remove()方法需要的参数是String类型的远程路径，但当前消息转换逻辑错误地将String包装成了Message对象，或传入的payload并非String类型，导致框架尝试将String转换为Message时失败。

解决方案 #

确保transform步骤直接返回String类型的远程路径作为消息payload，而非Message对象。示例transform逻辑：

.transform(message -> {
    String remoteDir = message.getHeaders().get("remoteDir", String.class);
    String fileName = message.getHeaders().get("fileName", String.class);
    // 直接返回路径字符串，不要包装成Message
    return remoteDir + "/" + fileName;
})

额外注意事项 #

• 若需监控删除操作结果，可配置ErrorChannel捕获异常：在集成流中添加.errorChannel("sftpDeleteErrorChannel")，并监听该通道处理删除失败场景。
• SftpRemoteFileTemplate的操作是单向的，集成流中该端点之后无法连接其他处理组件，因为无输出消息。

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