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方法内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • IntelliJ IDEA创建maven web项目的图文步骤(IDEA新手适用)

    IntelliJ IDEA创建maven web项目的图文步骤(IDEA新手适用)

    这篇文章主要介绍了IntelliJ IDEA创建maven web项目的图文步骤,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-03-03
  • Java之遍历枚举值问题

    Java之遍历枚举值问题

    这篇文章主要介绍了Java之遍历枚举值问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-07-07
  • Java设计模式之观察者模式解析

    Java设计模式之观察者模式解析

    这篇文章主要介绍了Java设计模式之观察者模式解析,观察者模式,又被称为发布/订阅模式,它定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象,这个主题对象在状态变化时,会通知所有的观察者对象,使他们能够自动更新自己,需要的朋友可以参考下
    2023-09-09
  • Java 使用Axis调用WebService的示例代码

    Java 使用Axis调用WebService的示例代码

    这篇文章主要介绍了Java 使用Axis调用WebService的示例代码,帮助大家更好的理解和使用Java,感兴趣的朋友可以了解下
    2020-09-09
  • Jenkins如何实现自动打包部署linux

    Jenkins如何实现自动打包部署linux

    这篇文章主要介绍了Jenkins如何实现自动打包部署linux,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-11-11
  • JDK源码之Vector与HashSet解析

    JDK源码之Vector与HashSet解析

    HashSet、HashMap、ArrayList、LinkedList、Vector这几个在Java编程中经常用到,他们之间有很多联系,有很多相通的地方,我们这次先了解一下Vector与HashSet
    2021-06-06
  • Spring中@ExceptionHandler注解的工作原理详解

    Spring中@ExceptionHandler注解的工作原理详解

    这篇文章主要介绍了Spring中@ExceptionHandler注解的工作原理详解,Spring Web注解@ExceptionHandler可以用来指定处理某类异常的控制器方法,从而在这些异常发生时,会有相应的控制器方法来处理此类异常,需要的朋友可以参考下
    2024-01-01
  • Java知识点归纳总结

    Java知识点归纳总结

    本篇文章对Java的一些知识点进行了归纳总结分析。需要的朋友参考下
    2013-05-05
  • 数据同步利器DataX简介及如何使用

    数据同步利器DataX简介及如何使用

    DataX 是阿里云 DataWorks数据集成 的开源版本,使用Java 语言编写,在阿里巴巴集团内被广泛使用的离线数据同步工具/平台,今天给大家分享一个阿里开源的数据同步工具DataX,在Github拥有14.8k的star,非常受欢迎
    2024-02-02
  • 详解Java Cglib动态代理

    详解Java Cglib动态代理

    这篇文章主要介绍了Java Cglib动态代理的相关资料,帮助大家更好的理解和学习Java代理,感兴趣的朋友可以了解下
    2020-08-08

最新评论