Java中Retry方法的简单实现

 更新时间:2024年01月29日 10:18:55   作者:Smallc0de  
这篇文章主要介绍了Java中Retry方法的简单实现,Retry主要是利用Java的lambda表达式和线程接口实现有返回值和无返回值的重试,思考了下就写了一个简易Retry功能分享出来,需要的朋友可以参考下

前言

最近有一个需求,要调用外部API满足业务逻辑,然后就用到了重试机制,又联想到不止API,其实很多中间件,比如Reids、各类MQ、Kafka,这些涉及到连接失败的读取写入需求都应该有重试机制。

虽然最终需求使用了Spring自带的Retry机制,但是这一套还是太重了,思考了下就写了一个简易Retry功能分享出来。

主要是利用Java的lambda表达式和线程接口实现有返回值和无返回值的重试。

代码

public class Retry {
    public static <T> T retry(Callable<T> callable, int num) {
        Retry.check(num >= 1, "次数需要大于0");
        Exception exception = null;
        for (int i = 0; i < num; i++) {
            try {
                return callable.call();
            } catch (Exception e) {
                exception = e;
            }
        }
        throw Retry.runtimeException(exception);
    }
    public static void retry(Runnable runnable, int num) {
        Retry.check(num >= 1, "次数需要大于0");
        Exception exception = null;
        for (int i = 0; i < num; i++) {
            try {
                runnable.run();
                return;
            } catch (Exception e) {
                exception = e;
            }
        }
        throw Retry.runtimeException(exception);
    }
    public static void check(boolean check, String message) {
        if (!check) {
            if (Objects.isNull(message)) {
                throw new IllegalArgumentException("Check Requirement Error.");
            } else {
                throw new IllegalArgumentException("Check Requirement Error:" + message);
            }
        }
    }
    public static RuntimeException runtimeException(Exception exception) {
        Retry.check(Objects.nonNull(exception), "传入参数为null");
        if (exception instanceof RuntimeException) {
            throw new RuntimeException(exception);
        }
        throw new RuntimeException();
    }
}

使用样例

public class RetryTest implements Runnable{
    public static void main(String[] args) {
        RetryTest test=new RetryTest();
        //直接用Runnable做参数,可以换成Callable的实例
        Retry.retry(test, 3);
        //使用方法做参数
        Retry.retry(()->supplierTestNoReturn("a"), 3);
        //使用方法做参数接受返回值
        String back = Retry.retry(()->supplierTest("a"), 3);
        System.out.println(back);
        //直接写有返回值
        Retry.retry(()->{
            //TODO 业务逻辑调用外部API等等
            System.out.println("返回值");
            return "返回值";
        }, 3);
 		//直接写无返回值
        Retry.retry(()->{
            //TODO 业务逻辑调用外部API等等
            System.out.println("无返回值");
        }, 3);
    }
    //非静态直接使用
    public void test(){
        Retry.retry(()->normal("aa"), 3);
    }
    @Override
    public void run() {
        //TODO 业务逻辑、调用外部API等等
        System.out.println("Runnable Test");
    }
    public static String supplierTest(String str){
        //TODO 业务逻辑、调用外部API等等
        return "Test "+ str;
    }
    public static void supplierTestNoReturn(String str){
        //TODO 业务逻辑、调用外部API等等
        System.out.println("No Return "+str);
    }
    public String normal(String a){
        //TODO 业务逻辑、调用外部API等等
        return "Test";
    }
}

另一个版本

例子写出来以后,觉得也可以用Supplier去替代Callable也是可以的,只需要一些小改动,如下一样可以使用。

    public static <T> T retry(Supplier<T> supplier, int num) {
        Retry.check(num >= 1, "次数需要大于0");
        Exception exception = null;
        for (int i = 0; i < num; i++) {
            try {
                return supplier.get();
            } catch (Exception e) {
                exception = e;
            }
        }
        throw Retry.runtimeException(exception);
    }

到此这篇关于Java中Retry方法的简单实现的文章就介绍到这了,更多相关Java的Retry方法内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • JDK 14的新特性:文本块Text Blocks的使用

    JDK 14的新特性:文本块Text Blocks的使用

    这篇文章主要介绍了JDK 14的新特性:文本块Text Blocks的使用,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-05-05
  • JVM 参数配置详细介绍

    JVM 参数配置详细介绍

    这篇文章主要介绍了JVM 参数配置详细介绍的相关资料,需要的朋友可以参考下
    2017-02-02
  • Spring的自动装配常用注解详解

    Spring的自动装配常用注解详解

    这篇文章主要介绍了Spring的自动装配常用注解详解,自动装配就是指 Spring 容器在不使用 <constructor-arg> 和<property> 标签的情况下,可以自动装配相互协作的 Bean 之间的关联关系,将一个 Bean 注入其他 Bean 的 Property 中,需要的朋友可以参考下
    2023-08-08
  • SpringBoot Starter的工作原理解析

    SpringBoot Starter的工作原理解析

    SpringBootStarter是SpringBoot项目中用于简化配置的工具,通过自动配置和条件加载机制,它自动生成所需的组件和服务,减少了开发时间和配置工作,本文介绍SpringBoot Starter的工作原理,感兴趣的朋友一起看看吧
    2025-02-02
  • SpringBoot整合阿里云OSS对象存储服务的实现

    SpringBoot整合阿里云OSS对象存储服务的实现

    这篇文章主要介绍了SpringBoot整合阿里云OSS对象存储服务的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-08-08
  • Java中的关键字_动力节点Java学院整理

    Java中的关键字_动力节点Java学院整理

    关键字也称为保留字,是指Java语言中规定了特定含义的标示符。对于保留字,用户只能按照系统规定的方式使用,不能自行定义
    2017-04-04
  • SpringBoot2零基础到精通之配置文件与web开发

    SpringBoot2零基础到精通之配置文件与web开发

    SpringBoot是一种整合Spring技术栈的方式(或者说是框架),同时也是简化Spring的一种快速开发的脚手架,本篇让我们一起学习配置文件以及web相关的开发
    2022-03-03
  • SpringBoot项目启动时如何读取配置以及初始化资源

    SpringBoot项目启动时如何读取配置以及初始化资源

    这篇文章主要给大家介绍了关于SpringBoot项目启动时如何读取配置以及初始化资源的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者使用SpringBoot具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧
    2020-06-06
  • 深入了解Spring中的FactoryBean

    深入了解Spring中的FactoryBean

    这篇文章主要介绍了深入了解Spring中的FactoryBean,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-09-09
  • SpringBoot YAML语法基础详细整理

    SpringBoot YAML语法基础详细整理

    YAML 是 “YAML Ain’t Markup Language”(YAML 不是一种标记语言)的递归缩写。在开发的这种语言时,YAML 的意思其实是:“Yet Another Markup Language”(仍是一种标记语言),本文给大家介绍的非常详细,需要的朋友可以参考下
    2022-10-10

最新评论