Spring Integration：EIP组件错误处理策略不一致问题咨询

在实际使用Spring Integration的过程中，我发现各类EIP组件的错误处理策略存在明显的不一致性，以下是几个典型案例：

案例1：handle组件 #

return IntegrationFlows.from(inputChannel)
    .enrichHeaders(spec -> spec.header(ERROR_CHANNEL, ARTIFACTORY_ERROR_CHANNEL, true))
    .handle(WebFlux.outboundGateway(uri, webClient)
        .expectedResponseType(ArtifactSearchResponse.class)
        .httpMethod(GET)
        .mappedRequestHeaders(ACCEPT))
    .log(LoggingHandler.Level.INFO, CLASS_NAME, Message::getPayload)
    .handle(transformer)
    .channel(outputChannel)
    .get();

这个场景下，如果handle(transformer)抛出异常，消息确实会按预期发送到ARTIFACTORY_ERROR_CHANNEL，但异常仍会返回给调用方，导致测试时必须用try-catch包裹才能避免测试失败：

try {
    inputChannel.send(new GenericMessage<>("start"));
} catch (Exception e) {
    // nop-op
}
verify(mockMessageHandler, timeout.times(1)).handleMessage(any(ErrorMessage.class));

案例2：transform组件 #

把案例1中的handle(transformer)替换成transform(transformer)后，异常永远不会发送到ARTIFACTORY_ERROR_CHANNEL，完全不符合预期的错误流转逻辑。

案例3：Gateway组件 #

public IntegrationFlow fileStreamingFlow() {
    return IntegrationFlows.from(inputChannel)
        .gateway(f -> f.handle(String.class, (fileName, headers) -> {
            throw new RuntimeException();
        }), spec -> spec.requiresReply(false).errorChannel(S3_ERROR_CHANNEL))
        .channel(outputChannel)
        .get();
}

调用这个流程时会出现永久阻塞的问题，相关问题编号为#2451。

案例4：handle结合routeByException #

return IntegrationFlows.from(s3Properties.getFileStreamingInputChannel())
    .enrichHeaders(spec -> spec.header(ERROR_CHANNEL, S3_ERROR_CHANNEL, true))
    .handle(String.class, (fileName, h) -> {
        return new ErrorMessage(new RuntimeException(), h);
    }, spec -> spec.requiresReply(false))
    .channel(outputChannel)
    .routeByException(r -> r.channelMapping(Exception.class, S3_ERROR_CHANNEL))
    .get();

要把异常发送到S3_ERROR_CHANNEL，必须手动将异常转换为ErrorMessage，而且就算已经配置了ERROR_CHANNEL头部，还得额外添加routeByException才能生效，步骤繁琐且不符合直觉。

期望的统一错误处理逻辑 #

我认为理想的错误处理逻辑应该具备以下特性：

• 如果用户已经定义了错误通道，所有异常都应该发送到该通道；
• 如果错误通道关联的错误处理器返回null，则终止流程；如果返回其他内容，则继续流程；
• 当未定义错误通道时，自动将异常发送到框架的默认错误通道；
• 以上逻辑应该不受流程中使用的EIP组件类型影响，保持全局一致性。

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