Spring Integration流程中如何在HTTP请求重试失败（状态非200）时执行自定义操作

嘿，刚上手Spring Integration的话，这个需求其实不难实现，我给你分享两种最常用的方案，都能完美适配你现有的流程：

Spring Retry本身提供了RecoveryCallback机制，专门用来处理所有重试尝试耗尽后仍失败的场景，刚好匹配你的需求。你只需要给现有的myRetryAdvice添加上这个回调即可：

// 1. 定义你的失败恢复回调逻辑
RecoveryCallback<Message<?>> failureRecoveryCallback = new RecoveryCallback<Message<?>>() {
    @Override
    public Message<?> recover(RetryContext context) throws Exception {
        // 从重试上下文里拿到原始请求消息
        Message<?> originalMessage = (Message<?>) context.getAttribute("message");
        
        // 这里执行你的自定义操作：比如把失败数据保存到数据库
        yourDatabaseService.saveFailedRequest(originalMessage.getPayload());
        
        // 可选：返回一个错误标记消息，供后续流程处理（也可以返回null终止流程）
        return MessageBuilder.withPayload("请求重试耗尽后失败").build();
    }
};

// 2. 把回调绑定到你的RetryAdvice上
RetryTemplate retryTemplate = new RetryTemplate();
// 配置你的重试策略（比如最大重试3次）
SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
retryPolicy.setMaxAttempts(3);
retryTemplate.setRetryPolicy(retryPolicy);

// 初始化RetryAdvice时传入recoveryCallback
myRetryAdvice = new RetryAdvice(retryTemplate, failureRecoveryCallback);

这样配置后，当myOutboundGateway调用外部资源重试3次都失败（返回非200状态码），就会自动触发recover方法里的数据库保存逻辑。

另一种更灵活的方式是通过**错误通道（Error Channel）**来统一处理失败消息。当重试耗尽后，异常会被路由到错误通道，你只需要监听这个通道就能执行自定义操作：

// 1. 在原流程里指定专属的错误通道
IntegrationFlows.from(MY_CHANNEL)
    .handle(myOutboundGateway, e -> e.advice(myRetryAdvice)
        .errorChannel("myFailureHandlingChannel")) // 绑定流程级错误通道
    .wireTap(logResponse())
    .get();

// 2. 定义监听错误通道的处理流程
IntegrationFlows.from("myFailureHandlingChannel")
    .handle(message -> {
        // 解析错误消息：payload是原始请求消息，headers里包含异常信息
        Message<?> failedRequest = (Message<?>) message.getPayload();
        Throwable failureException = (Throwable) message.getHeaders().get(MessageHeaders.EXCEPTION);
        
        // 执行自定义操作：保存失败数据到数据库
        yourDatabaseService.saveFailedRequest(failedRequest.getPayload());
        
        // 可选：打印错误日志
        log.error("请求重试耗尽后失败，已保存到数据库", failureException);
    })
    .get();

这种方案的优势是可以集中处理多个流程的失败逻辑，如果你后续有其他流程也需要类似的失败处理，直接复用这个错误通道即可。

关键注意点 #

不管用哪种方案，你都需要确保myOutboundGateway在收到非200 HTTP状态码时会抛出异常——因为Spring Retry只会捕获异常才会触发重试。比如可以给网关配置一个自定义错误处理器，把非200状态码转换成RuntimeException：

myOutboundGateway.setErrorHandler(response -> {
    ClientHttpResponse httpResponse = (ClientHttpResponse) response;
    if (!HttpStatus.OK.equals(httpResponse.getStatusCode())) {
        throw new RuntimeException("外部资源调用失败，状态码：" + httpResponse.getStatusCode());
    }
});

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