如何在Spring Integration中处理RestTemplate的ResourceAccessException

首先明确两个核心问题：

1. 自定义ResponseErrorHandler不处理超时异常：它仅负责处理有HTTP响应返回的错误（如4xx/5xx状态码），而ResourceAccessException（含SocketTimeoutException）属于请求过程中的I/O异常，此时没有收到服务器的HTTP响应，因此不会触发ResponseErrorHandler。
2. 配置冲突：当Http.outboundGateway传入已配置好的RestTemplate时，框架要求错误处理器必须绑定在RestTemplate上，不能单独在网关层面设置，否则会抛出参数冲突异常。

方案一：针对单个HTTP网关的异常处理（推荐） #

使用Spring Integration提供的ExpressionEvaluatingRequestHandlerAdvice，直接在HTTP Outbound Gateway的处理器上添加异常捕获逻辑，精准处理超时异常并返回自定义响应。

修改flow2的配置： #

@Bean
public IntegrationFlow flow2() {
    // 构建异常处理Advice
    ExpressionEvaluatingRequestHandlerAdvice timeoutAdvice = new ExpressionEvaluatingRequestHandlerAdvice();
    // 开启异常捕获，不再向上抛出
    timeoutAdvice.setTrapException(true);
    // 自定义超时异常的返回内容（支持SpEL表达式）
    timeoutAdvice.setOnFailureExpressionString(
        "'服务调用超时，请稍后重试：' + #exception.cause.message"
    );
    // 指定返回结果的类型
    timeoutAdvice.setFailurePayloadType(String.class);

    return flow ->
        flow.channel(c -> c.executor(Executors.newCachedThreadPool()))
            .handle(
                Http.outboundGateway(
                        "http://localhost:4444/test", resttemplateconfig.restTemplate())
                    .extractPayload(true)
                    .httpMethod(HttpMethod.POST)
                    .expectedResponseType(String.class),
                // 为处理器绑定异常处理Advice
                handlerSpec -> handlerSpec.advice(timeoutAdvice)
            );
}

说明： #

• 该Advice会捕获HTTP网关执行过程中抛出的所有异常，包括ResourceAccessException。
• 可以通过onFailureExpressionString灵活定义返回内容，比如拼接异常详情、返回标准化错误JSON等。
• 如果需要更复杂的处理逻辑，可实现RequestHandlerAdvice接口自定义处理逻辑。

方案二：全局异常处理（适用于多流程场景） #

如果多个Integration Flow都需要统一处理这类异常，可以配置全局错误通道，集中捕获并处理所有未被局部处理的异常。

1. 定义全局错误通道和处理流程 #

@Bean
public MessageChannel globalErrorChannel() {
    return new DirectChannel();
}

@Bean
public IntegrationFlow globalErrorHandlingFlow() {
    return IntegrationFlows.from(globalErrorChannel())
        .handle(message -> {
            Throwable exception = (Throwable) message.getPayload();
            if (exception instanceof ResourceAccessException) {
                // 处理超时异常：记录日志、构建自定义响应
                System.out.println("全局捕获超时异常：" + exception.getMessage());
                // 可将处理后的消息发送到后续流程（如保存到DB）
            } else {
                // 处理其他类型异常
                System.out.println("全局捕获其他异常：" + exception.getMessage());
            }
        })
        .get();
}

2. 在主流程中绑定全局错误通道 #

@Bean
public IntegrationFlow mainFlow() {
    return flow ->
        flow.split()
            .channel(c -> c.executor(Executors.newCachedThreadPool()))
            .scatterGather(
                scatterer ->
                    scatterer
                        .applySequence(true)
                        .recipientFlow(flow1())
                        .recipientFlow(flow2()),
                gatherer ->
                    gatherer
                        .releaseLockBeforeSend(true)
                        .releaseStrategy(group -> group.size() == 1))
            .aggregate()
            // 绑定全局错误通道
            .channel(c -> c.errorChannel(globalErrorChannel()))
            .to(saveCDResponseToDB());
}

• 关于ResponseErrorHandler：你的自定义CustomServiceErrorHandler是生效的，但仅处理服务器返回的HTTP错误响应（如500、404），无需修改现有RestTemplate配置，也不要在Http.outboundGateway上重复设置errorHandler，避免冲突。
• 配置冲突解决：始终保持RestTemplate是唯一的错误处理器配置入口，网关层面不再单独设置，即可避免IllegalArgumentException异常。

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