如何基于响应体参数实现RestTemplate POST请求的重试机制

核心思路 #

RetryTemplate 默认只会对抛出的异常触发重试，你遇到的接口请求正常但业务状态失败的场景，需要手动将业务失败的情况转换成自定义异常，或者自定义重试判断逻辑来触发重试。
RetryState 用于有状态重试场景：比如重试过程中需要保持同一会话、做幂等性校验、跨请求上下文共享重试状态。如果你调用的 POST 接口是幂等的（重复调用不会产生额外副作用），用无状态重试也可以满足需求，确定需要用 RetryState 可参考下面的实现方案。

具体实现步骤 #

1. 引入依赖 #

Spring Boot 项目直接引入对应的 starter 即可：

<dependency>
    <groupId>org.springframework.retry</groupId>
    <artifactId>spring-retry</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-aspects</artifactId>
</dependency>

2. 自定义业务异常 #

用来标记业务返回失败的场景，方便触发重试：

public class BizServiceFailureException extends RuntimeException {
    public BizServiceFailureException(String message) {
        super(message);
    }
    // 可以扩展字段存储接口返回的其他响应内容，用于更复杂的重试判断
}

3. 构造 RetryTemplate 实例 #

配置重试策略、退避策略等规则：

import org.springframework.retry.policy.SimpleRetryPolicy;
import org.springframework.retry.support.RetryTemplate;
import org.springframework.retry.backoff.FixedBackOffPolicy;

RetryTemplate retryTemplate = new RetryTemplate();

// 配置重试策略：最大重试3次（包含首次调用），仅对自定义业务异常触发重试
SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
retryPolicy.setMaxAttempts(3);
retryTemplate.setRetryPolicy(retryPolicy);

// 配置退避策略：每次重试间隔2秒，也可以用指数退避等其他策略
FixedBackOffPolicy backOffPolicy = new FixedBackOffPolicy();
backOffPolicy.setBackOffPeriod(2000);
retryTemplate.setBackOffPolicy(backOffPolicy);

如果有其他依赖响应字段的重试场景，可以自定义重试策略，根据异常携带的响应信息判断是否需要重试。

4. 构造 RetryState 实例 #

用默认的 DefaultRetryState 即可，stateKey 为当前重试请求的唯一标识，比如请求流水号、幂等ID：

import org.springframework.retry.RetryState;
import org.springframework.retry.support.DefaultRetryState;

String requestId = "your_unique_request_id";
RetryState retryState = new DefaultRetryState(requestId);

5. 执行POST请求和重试逻辑 #

import org.springframework.web.client.RestTemplate;
import com.alibaba.fastjson.JSONObject;

RestTemplate restTemplate = new RestTemplate();
try {
    String finalResult = retryTemplate.execute(context -> {
        // 执行POST请求
        JSONObject response = restTemplate.postForObject("your_web_service_url", "your_request_body", JSONObject.class);
        String resultStatus = response.getString("result");
        if ("Failure".equals(resultStatus)) {
            // 业务失败，抛出自定义异常触发重试
            throw new BizServiceFailureException("接口返回业务失败：" + resultStatus);
        }
        // 其他依赖响应字段的重试场景在这里加判断，满足条件就抛出对应异常即可
        return resultStatus;
    }, context -> {
        // 可选：重试全部耗尽后的回退逻辑
        return "default_fallback_result";
    }, retryState);
    System.out.println("请求最终结果：" + finalResult);
} catch (BizServiceFailureException e) {
    // 重试全部失败后的异常处理逻辑
    e.printStackTrace();
}

注意事项 #

• 如果你调用的POST接口不是幂等的，不要盲目配置重试，避免重复提交产生脏数据
• 不需要跨上下文共享重试状态的场景，可以省略 RetryState 参数，直接调用无 state 的 execute 方法使用无状态重试，实现更简单

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