项目
博客
文档
归档
资源链接
关于我
项目
博客
文档
归档
资源链接
关于我
高性能百万级任务重试框架Fast-Retry
2024-07-30
·
·
原创
·
GitHub依赖包
·
本文共 389个字，预计阅读需要 2分钟。
GitHub：https://github.com/burukeYou/fast-retry Fast-Retry是一个高性能任务重试框架，支持百万级别任务的并发重试处理。 与主流的Spring-Retry, Guava-Retry等同步重试框架不同，Fast-Retry是一个**支持异步重试框架，支持异步任务的重试、超时等待、回调**。 Spring-Retry, Guava-Retry均无法支持大批量任务的重试，因为会占用过多线程资源导致大量任务在等待处理，随着任务数的增加，系统吞吐量大大降低，性能指数级降低，Fast-Retry的性能是前者的指数倍。 下图是三者的性能对比 - 测试线程池: 8个固定线程 - 单个任务逻辑: 轮询5次，隔2秒重试一次，总耗时10秒 - 未测预计公式： 当我们使用线程池的时候， 一般线程池中 总任务处理耗时 = 任务数/并发度 x 单个任务重试耗时 | 任务数 | FastRetry | Spring-Retry | Guava-Retry | | ------- | --------- | ------------------- | ------------------- | | 1 | 10秒 | 10秒 | 10秒 | | 10 | 10.066秒 | 20.092秒 | 20.078秒 | | 50 | 10.061秒 | 70.186秒 | 70.168秒 | | 100 | 10.077秒 | 130.33秒 | 130.31秒 | | 500 | 10.154秒 | 631.420秒 | 631.53秒 | | 1000 | 10.237秒 | 1254.78秒 | 1256.28秒 | | 5000 | 10.482秒 | 没测预计：6250秒 | 没测预计：6250秒 | | 10000 | 10.686秒 | 没测预计：12520秒 | 没测预计：12520秒 | | 100000 | 13.71秒 | 没测预计：125000秒 | 没测预计：125000秒 | | 500000 | 28.89秒 | 没测预计：625000秒 | 没测预计：625000秒 | | 1000000 | 58.05秒 | 没测预计：1250000秒 | 没测预计：1250000秒 | 可以看到即使是处理100万个任务，Fast-Retry的性能也比Spring-Retry和Guava-Retry处理在50个任务时的性能还要快的多的多， 这么快的秘密在于除了是异步，更重要是当别人在重试间隔里休息的时候，Fast-Retry还在不停忙命的工作着。 ### 引入依赖 ```xml <dependency> <groupId>io.github.burukeyou</groupId> <artifactId>fast-retry-all</artifactId> <version>0.2.0</version> </dependency> ``` ### 快速开始 有以下三种方式去构建我们的重试任务 #### 1、使用重试队列 ```java ExecutorService executorService = Executors.newFixedThreadPool(8); RetryQueue queue = new FastRetryQueue(executorService); RetryTask<String> task = new RetryTask<String>() { int result = 0 ; @Override public long waitRetryTime() { return 2000; } @Override public boolean retry() { return ++result < 5; } @Override public String getResult() { return result + ""; } }; CompletableFuture<String> future = queue.submit(task); log.info("任务结束 结果:{}",future.get()); ``` #### 2、使用FastRetryBuilder ```java RetryResultPolicy<String> resultPolicy = result -> result.equals("444"); FastRetryer<String> retryer = FastRetryBuilder.<String>builder() .attemptMaxTimes(3) .waitRetryTime(3, TimeUnit.SECONDS) .retryIfException(true) .retryIfExceptionOfType(TimeoutException.class) .exceptionRecover(true) .resultPolicy(resultPolicy) .build(); CompletableFuture<String> future = retryer.submit(() -> { log.info("重试"); //throw new Exception("test"); //int i = 1/0; if (0 < 10){ throw new TimeoutException("test"); } return "444"; }); String o = future.get(); log.info("结果{}", o); ``` #### 3、使用FastRetry注解 - 依赖Spring环境，所以需要在配置上加上@EnableFastRetry注解启用配置才生效 - 如果将结果类型使用CompletableFuture包装，自动进行异步轮询返回，否则同步阻塞等待重试结果。 下面定义等价于 FastRetryer.execute方法 ```java @FastRetry(retryWait = @RetryWait(delay = 2)) public String retryTask(){ return "success"; } ``` 下面定义等价于 FastRetryer.submit方法,支持异步轮询 ```java @FastRetry(retryWait = @RetryWait(delay = 2)) public CompletableFuture<String> retryTask(){ return CompletableFuture.completedFuture("success"); } ``` 使用参考： https://blog.csdn.net/weixin_41347419/article/details/136217043