springboot集成spring-retry实现接口重试

ゝ一世哀愁。 2023-07-15 13:19 19阅读 0赞

今天需要通过http接口推送数据，根据协议接口失败情况下，需要重试3次。

springboot 版本1.5，

1.maven依赖

<dependency>
         <groupId>org.springframework.retry</groupId>
         <artifactId>spring-retry</artifactI
    </dependency>
    <dependency>
        <groupId>org.aspectj</groupId>
        <artifactId>aspectjweaver</artifactId>
    </dependency>

2.springboot启动类 启动重试 ,添加  @EnableRetry  注解

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1YW5neWluZ3Bvc3Vv_size_16_color_FFFFFF_t_70][]

3.在需要重试的方法上添加注解  @Retryable

@Retryable(value = {Exception.class}, maxAttempts = 3, backoff = @Backoff(delay = 1000L, multiplier = 1))
        public boolean httpPushRetry(String url, String body) throws Exception {
            String result = HttpUtils.goddHttpPost(url, body);
            logger.warn("**传输内容:{},返回结果:{}", body, result);
            AntResponseDto dto = JSONObject.parseObject(result, AntResponseDto.class);
            if (dto == null) {
                throw new Exception("");
            }
            Boolean success = dto.getSuccess();
            Integer status = dto.getStatus();
            if (success && status == 0) {
                return true;
            }
            throw new Exception("返回值为失败:" + dto);
        }

4、重试次数超过规定次数，调用回调方法 @Recover

/**
         * 达到最大重试次数,或抛出了一个没有指定进行重试的异常
         * recover 机制
         *
         * @param e 异常
         */
        @Recover
        public boolean recover(Exception e, String param) {
            logger.error("达到最大重试次数,或抛出了一个没有指定进行重试的异常:", e);
            return false;
        }

@Retryable(value = \{Exception.class\}, maxAttempts = 3, backoff = @Backoff(delay = 1000L, multiplier = 1))

value ：需要重试的异常种类

maxAttempts ：重试次数

delay ：重试间隔时间 delay = 1000L 为1秒

multiplier = 1：间隔时间倍数

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1YW5neWluZ3Bvc3Vv_size_16_color_FFFFFF_t_70]: /images/20230528/0231803c88ba4043a715ba42edb73b45.png