Spring Integration中处理HTTP响应异常并继续聚合流程的方案

错误原因分析 #

你遇到的EL1008E错误，根源是setOnFailureExpressionString("Failed")中的Failed未用单引号包裹。SpEL解析时会把它当作Message对象的属性名，而非字符串常量，进而因找不到对应属性抛出异常。

修正后的代码 #

异常处理Advice配置 #

@Bean
public Advice expressionAdvice() {
    ExpressionEvaluatingRequestHandlerAdvice advice = new ExpressionEvaluatingRequestHandlerAdvice();
    advice.setSuccessChannelName("success.input");
    advice.setOnSuccessExpressionString("payload + ' was successful'");
    advice.setFailureChannelName("failure.input");
    // 用单引号包裹字符串常量，让SpEL正确识别为字符串
    advice.setOnFailureExpressionString("'Failed'");
    // 若需要返回null，替换为下面一行
    // advice.setOnFailureExpressionString("null");
    advice.setReturnFailureExpressionResult(true);
    advice.setTrapException(true);
    return advice;
}

flow2配置（无需修改，确保Advice绑定正确） #

@Bean
public IntegrationFlow flow2() {
    return integrationFlowDefinition ->
        integrationFlowDefinition
            .channel(c -> c.executor(Executors.newCachedThreadPool()))
            .handle(
                (payload, header) ->
                    lionService.prepareSomeRequest(
                        (LionRequest) payload,
                        (SourceSystem) (Objects.requireNonNull(header.get("sourceSystem")))))
            .handle(
                Http.outboundGateway(someurl)
                    .httpMethod(HttpMethod.POST)
                    .expectedResponseType(String.class),
                c -> c.advice(expressionAdvice()));
}

关键配置说明 #

• SpEL字符串常量规则：必须用单引号包裹，否则会被解析为对象属性，这是解决当前错误的核心。
• setTrapException(true)：捕获HTTP网关抛出的所有异常，避免异常向上传播导致整个Scatter-Gather流程终止。
• setReturnFailureExpressionResult(true)：将异常处理表达式的结果作为当前handle步骤的返回值，让后续流程（包括aggregate阶段）能继续执行，拿到"Failed"字符串或null进行后续处理。

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