Java使用@Retryable注解实现HTTP请求重试

更新时间：2024年10月20日 08:42:16 作者：niaonao

HTTP调用是Java应用与外部API进行交互时重要的访问方式之一,为了确保在遇到临时性问题时能自动重试,我们可以设计一个灵活的重试机制,在Java中,我们可以通过注解来实现这一功能,文将介绍如何使用注解@Retryable来实现HTTP调用的重试机制,需要的朋友可以参考下

1. 引言

在应用程序中，网络请求可能会因为各种原因（如网络不稳定、服务器故障等）而失败。为了提高系统的可靠性，通常需要实现一个重试机制。

HTTP调用是Java应用与外部API进行交互时重要的访问方式之一。为了确保在遇到临时性问题时能自动重试，我们可以设计一个灵活的重试机制。

在Java中，我们可以通过注解来实现这一功能，从而简化代码并增强可读性。本文将介绍如何使用注解@Retryable来实现HTTP调用的重试机制，以应对网络交互中的不确定性。

2. 核心代码解析

2.1 POM依赖

<!-- Spring Retry-->
<dependency>
    <groupId>org.springframework.retry</groupId>
    <artifactId>spring-retry</artifactId>
</dependency>

2.2 SpringBoot启动类注解

此处顺便介绍了几个常用注解。不是本次介绍的重点。关注@EnableRetry注解即可。

@SpringBootApplication为应用提供基本配置，@EnableApolloConfig和@EnableConfigurationProperties用于配置管理，@EnableRetry增强了网络请求的稳定性，而@EnableAsync则提供了异步处理能力。

import com.ctrip.framework.apollo.spring.annotation.EnableApolloConfig;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.retry.annotation.EnableRetry;
import org.springframework.scheduling.annotation.EnableAsync;

@SpringBootApplication
@EnableApolloConfig
@EnableConfigurationProperties
@EnableRetry
@EnableAsync
public class BootApplication {

    public static void main(String[] args) {
        SpringApplication.run(BootApplication.class, args);
    }

}

@SpringBootApplication是一个组合注解，通常用于Spring Boot应用的主类。包括下面三个注解。

@Configuration：表明该类是一个配置类，Spring会从这个类中读取配置信息。

@EnableAutoConfiguration：启用Spring Boot的自动配置功能，根据添加的依赖自动配置Spring应用。

@ComponentScan：启用组件扫描，允许Spring查找合适的组件、配置和服务。

@EnableApolloConfig

@EnableApolloConfig是Apollo配置中心的注解，用于在Spring Boot应用中启用Apollo的配置管理。Apollo是一个开源的配置管理中心，能够帮助开发者管理应用的配置，支持动态更新和多环境配置。使用此注解会自动加载Apollo中配置的属性。

@EnableConfigurationProperties

@EnableConfigurationProperties用于将外部配置转换为Java对象。通过结合使用@ConfigurationProperties注解，Spring Boot可以将properties或YAML文件中的配置属性映射到POJO（Plain Old Java Object）中，使得配置更加类型安全且易于管理。使用此注解通常用于启用对特定配置类的支持。

@EnableRetry

@EnableRetry是Spring Retry模块中的注解，用于启用重试机制。通过此注解，应用程序可以借助Spring的重试机制在调用过程中自动处理失败的请求。这有助于提高系统的可靠性，尤其是在通过网络调用外部服务时，可以有效地处理临时性错误。

@EnableAsync

@EnableAsync用于启用Spring的异步方法执行。通过在某个方法上加上@Async注解，可以将该方法标记为异步执行。这意味着调用线程不会被阻塞，调用者可以继续执行其他任务。这在处理IO密集型操作或者耗时的处理任务时非常有用。启用此注解后，需要确保有相应的线程池配置，以避免线程资源耗尽。

2.3 核心代码

import pers.niaonao.ErrorCode;
import pers.niaonao.BusinessException;
import lombok.extern.slf4j.Slf4j;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.retry.annotation.Backoff;
import org.springframework.retry.annotation.Retryable;
import org.springframework.stereotype.Service;

@Slf4j
@Service
public class HttpRetryService {

    @Retryable(maxAttempts = 3, backoff = @Backoff(delay = 1000, multiplier = 2))
    public Response execute(OkHttpClient client, Request request) throws BusinessException{
        try {
            Response response = client.newCall(request).execute();
            log.info("service res:{}", response.toString());
            if (response.code() != 200){
                log.error("service code not is 200");
                throw new BusinessException(ErrorCode.HTTP_ERROR);
            }
            return response;
        }catch (Exception e){
            log.error("服务调用异常", e);
            throw new BusinessException(ErrorCode.HTTP_ERROR);
        }
    }
}

@Retryable(maxAttempts = 3, backoff = @Backoff(delay = 1000, multiplier = 2))

该注解指明了当方法调用失败时，最多重试3次，每次重试之间的等待时间逐渐增加。初始延迟为1000毫秒，每次重试后乘以2，这意味着第二次重试后延迟2秒，第三次重试后延迟4秒。

总结

Http调用：在execute方法中，使用OkHttpClient来发送HTTP请求。如果请求成功并且返回码为200，则返回响应。如果返回码不是200，抛出一个自定义的BusinessException。
异常处理：若在调用过程中发生任何异常，将记录错误日志并抛出异常，以便重试机制能够识别并执行重试。

3. Spring 注解说明

3.1 @Retryable注解

import org.springframework.stereotype.Component;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Retryable {
    int maxAttempts() default 3; // 最大重试次数
    Backoff backoff() default @Backoff; // 重试间隔及倍数
}

3.2 @Backoff注解

import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;

@Retention(RetentionPolicy.RUNTIME)
public @interface Backoff {
    long delay() default 1000; // 延迟时间
    double multiplier() default 1; // 每次重试的倍数
}

4. 如何使用

在代码中直接使用@Retryable注解标记需要重试的方法，如之前的execute方法即可。当调用该方法时，如果发生异常，它会根据配置自动进行重试。

5. 总结

本文展示了如何使用Spring注解在Java中实现HTTP调用的重试机制。通过@Retryable注解，我们能够轻松地为任意方法中的HTTP调用增加重试功能，不仅实现了代码的简洁性，也提高了系统的可靠性。使用这种设计模式后，开发者可以更专注于业务逻辑，而将错误处理和重试机制的复杂性从业务代码中剥离。

以上就是Java使用@Retryable注解实现HTTP请求重试的详细内容，更多关于Java @Retryable HTTP请求重试的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

Java中怎样处理空指针异常
程序中的变量是 null，就意味着它没有引用指向或者说没有指针。这时，我们对这个变量进行任何操作，都必然会引发空指针异常，本文主要介绍了Java中怎样处理空指针异常，感兴趣的可以了解一下
2022-05-05
浅谈对象与Map相互转化
这篇文章主要介绍了利用BeanMap进行对象与Map的相互转换，在文中列举了完整代码，需要的朋友可以参考下。
2017-09-09
Maven镜像地址配置示例大全
这篇文章主要介绍了Maven镜像地址配置示例大全，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2020-06-06
java实现角色及菜单权限的项目实践
在Java中,实现角色及菜单权限管理涉及定义实体类、设计数据库表、实现服务层和控制器层,这种管理方式有助于有效控制用户权限,适用于企业级应用,感兴趣的可以一起来了解一下
2024-09-09
Java数据结构之哈夫曼树概述及实现
文中详细讲了关于Java哈夫曼树的概述以及用Java实现的方法,对各位正在学习java数据结构的小伙伴们有很大的帮助哟,需要的朋友可以参考下
2021-05-05
java实现学生选课系统
这篇文章主要为大家详细介绍了java实现学生选课系统，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2019-02-02
关于消息中间件RocketMQ的基本概念及功能
这篇文章主要介绍了关于消息中间件RocketMQ的基本概念及功能,RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件，支持事务消息、顺序消息、批量消息、定时消息、消息回溯等,需要的朋友可以参考下
2023-05-05
java判断请求是来自PC端还是手机端小技巧
这篇文章主要为大家介绍了java判断请求是来自PC端还是手机端小技巧，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-06-06
JAVA多线程并发下的单例模式应用
单例模式应该是设计模式中比较简单的一个，也是非常常见的，但是在多线程并发的环境下使用却是不那么简单了，今天给大家分享一个我在开发过程中遇到的单例模式的应用。
2017-03-03
HTTP基本认证(Basic Authentication)的JAVA实例代码
下面小编就为大家带来一篇HTTP基本认证(Basic Authentication)的JAVA实例代码。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2016-11-11