Java 重試框架 Sisyphus 配置的兩種方式

1、函數(shù)式配置概覽
為了滿足更加方便的配置,Retryer 類提供了許多可以配置的信息。
1.1 默認(rèn)配置
/**
* 默認(rèn)配置測(cè)試
*/
public void defaultConfigTest() {
Retryer.<String>newInstance()
.condition(RetryConditions.hasExceptionCause())
.retryWaitContext(RetryWaiter.<String>retryWait(NoRetryWait.class).context())
.maxAttempt(3)
.listen(RetryListens.noListen())
.recover(Recovers.noRecover())
.callable(new Callable<String>() {
@Override
public String call() throws Exception {
System.out.println("called...");
throw new RuntimeException();
}
}).retryCall();
}
和下面的代碼是等價(jià)的:
public void helloTest() {
Retryer.<String>newInstance()
.callable(new Callable<String>() {
@Override
public String call() throws Exception {
System.out.println("called...");
throw new RuntimeException();
}
}).retryCall();
}
2、方法說明
2.1 condition
重試觸發(fā)的條件,可以指定多個(gè)條件。
默認(rèn)為拋出異常。
2.2 retryWaitContext
重試等待的策略,可以指定多個(gè)。
默認(rèn)為不做任何等待。
2.3 maxAttempt
指定最大重試次數(shù),包括第一次執(zhí)行。
默認(rèn)值:3 次。
2.4 listen
指定重試的監(jiān)聽實(shí)現(xiàn),默認(rèn)為不做監(jiān)聽。
2.5 recover
當(dāng)重試完成之后,依然滿足重試條件,則可以指定恢復(fù)的策略。
默認(rèn)不做恢復(fù)。
2.6 callable
待重試執(zhí)行的方法。
2.7 retryCall
觸發(fā)重試執(zhí)行。
3、接口的詳細(xì)介紹
3.1 接口及其實(shí)現(xiàn)
所有的接口,都可以直接查看對(duì)應(yīng)的子類實(shí)例。
3.2 用戶自定義
基于替換的靈活性,用戶可以實(shí)現(xiàn)接口,定義更符合自己業(yè)務(wù)的實(shí)現(xiàn)。
3.3 sisyphus 注解
配置具有很高的靈活性,但是對(duì)于開發(fā)人員的使用,就沒有注解那樣簡單靈活。
所以本框架也實(shí)現(xiàn)了基于注解的重試。
4、設(shè)計(jì)的規(guī)范
保證接口和注解二者的統(tǒng)一性。
4.1 maven 引入
<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>sisyphus-annotation</artifactId>
<version>${project.version}</version>
</dependency>
注解:
核心注解主要有兩個(gè)。
4.2 Retry
用于指定重試的相關(guān)配置。
/**
* 重試注解
* 1. 實(shí)際需要,只允許放在方法上。
* 2. 如果放在接口上,是否所有的子類都生效?為了簡單明確,不提供這種實(shí)現(xiàn)。
* 3. 保持注解和接口的一致性。{@link com.github.houbb.sisyphus.api.core.Retry} 接口
* @author binbin.hou
* @since 0.0.3
*/
@Documented
@Inherited
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@RetryAble(DefaultRetryAbleHandler.class)
public @interface Retry {
/**
* 重試類實(shí)現(xiàn)
* @return 重試
* @since 0.0.5
*/
Class<? extends com.github.houbb.sisyphus.api.core.Retry> retry() default DefaultRetry.class;
/**
* 最大嘗試次數(shù)
* 1. 包含方法第一次正常執(zhí)行的次數(shù)
* @return 次數(shù)
*/
int maxAttempt() default 3;
/**
* 重試觸發(fā)的場(chǎng)景
* @return 重試觸發(fā)的場(chǎng)景
*/
Class<? extends RetryCondition> condition() default ExceptionCauseRetryCondition.class;
/**
* 監(jiān)聽器
* 1. 默認(rèn)不進(jìn)行監(jiān)聽
* @return 監(jiān)聽器
*/
Class<? extends RetryListen> listen() default NoRetryListen.class;
/**
* 恢復(fù)操作
* 1. 默認(rèn)不進(jìn)行任何恢復(fù)操作
* @return 恢復(fù)操作對(duì)應(yīng)的類
*/
Class<? extends Recover> recover() default NoRecover.class;
/**
* 等待策略
* 1. 支持指定多個(gè),如果不指定,則不進(jìn)行任何等待,
* @return 等待策略
*/
RetryWait[] waits() default {};
}
4.3 RetryWait
用于指定重試的等待策略。
package com.github.houbb.sisyphus.annotation.annotation;
import com.github.houbb.sisyphus.annotation.annotation.metadata.RetryWaitAble;
import com.github.houbb.sisyphus.annotation.handler.impl.DefaultRetryWaitAbleHandler;
import com.github.houbb.sisyphus.core.constant.RetryWaitConst;
import com.github.houbb.sisyphus.core.support.wait.NoRetryWait;
import java.lang.annotation.*;
/**
* 重試等待策略
* 1. 為了對(duì)應(yīng)重試策略,所有的內(nèi)置注解應(yīng)該實(shí)現(xiàn)當(dāng)前的注解。
* 2. 是否允許自定義注解?
*
* 當(dāng)注解+對(duì)象同時(shí)出現(xiàn)的時(shí)候,視為組合。
*
* @author binbin.hou
* @since 0.0.3
*/
@Retention(RetentionPolicy.RUNTIME)
@Inherited
@Documented
@Target(ElementType.ANNOTATION_TYPE)
@RetryWaitAble(DefaultRetryWaitAbleHandler.class)
public @interface RetryWait {
/**
* 默認(rèn)值
* 1. fixed 模式,則對(duì)應(yīng)固定等待時(shí)間
* 2. 遞增
* @return 默認(rèn)值
*/
long value() default RetryWaitConst.VALUE_MILLS;
/**
* 最小值
* @return 最小值
*/
long min() default RetryWaitConst.MIN_MILLS;
/**
* 最大值
* @return 最大值
*/
long max() default RetryWaitConst.MAX_MILLS;
/**
* 影響因數(shù)
* 1. 遞增重試,默認(rèn)為 {@link RetryWaitConst#INCREASE_MILLS_FACTOR}
* 2. 指數(shù)模式。默認(rèn)為 {@link RetryWaitConst#MULTIPLY_FACTOR}
* @return 影響因數(shù)
*/
double factor() default Double.MIN_VALUE;
/**
* 指定重試的等待時(shí)間 class 信息
* @return 重試等待時(shí)間 class
*/
Class<? extends com.github.houbb.sisyphus.api.support.wait.RetryWait> retryWait() default NoRetryWait.class;
}
5、注解的使用
定義好了注解,肯定要有注解的相關(guān)使用。
關(guān)于注解的使用,主要有兩種方式。
5.1 Proxy+CGLIB
基于代理模式和字節(jié)碼增強(qiáng)。
如果是項(xiàng)目中沒有使用 spring,直接使用這種方式比較方便。
5.2 Spring-AOP
可以和 spring 直接整合。
使用方式和 spring-retry 是一樣的。
這些內(nèi)容將放在下一節(jié)進(jìn)行詳細(xì)講解。
小結(jié):
靈活的配置才能更加符合實(shí)際生產(chǎn)使用中的各種需求。一般實(shí)際使用推薦使用注解的配置方式,非常的簡單方便。
到此這篇關(guān)于Java 重試框架 Sisyphus 配置的兩種方式的文章就介紹到這了,更多相關(guān)Java 重試框架 Sisyphus 配置方式內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
JDK9的新特性之String壓縮和字符編碼的實(shí)現(xiàn)方法
這篇文章主要介紹了JDK9的新特性之String壓縮和字符編碼的實(shí)現(xiàn)方法,本文通過實(shí)例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2020-05-05
spring?boot?使用?@Scheduled?注解和?TaskScheduler?接口實(shí)現(xiàn)定時(shí)任務(wù)
這篇文章主要介紹了spring?boot?使用?@Scheduled?注解和?TaskScheduler?接口實(shí)現(xiàn)定時(shí)任務(wù),本文通過實(shí)例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2023-06-06
springtask 的使用方法和 cron 表達(dá)式解析
這篇文章主要介紹了springtask 的使用方法和 cron 表達(dá)式解析,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-10-10
使用Java實(shí)現(xiàn)5種負(fù)載均衡算法實(shí)例
負(fù)載均衡指由多臺(tái)服務(wù)器以對(duì)稱的方式組成一個(gè)服務(wù)器集合,每臺(tái)服務(wù)器都具有等價(jià)的地位,都可以單獨(dú)對(duì)外提供服務(wù)而無須其他服務(wù)器的輔助,這篇文章主要給大家介紹了關(guān)于使用Java實(shí)現(xiàn)5種負(fù)載均衡算法的相關(guān)資料,需要的朋友可以參考下2021-09-09
Java中String.split()的最詳細(xì)源碼解讀及注意事項(xiàng)
以前經(jīng)常使用String.split()方法,但是從來沒有注意,下面這篇文章主要給大家介紹了關(guān)于Java中String.split()最詳細(xì)源碼解讀及注意事項(xiàng)的相關(guān)資料,文中通過圖文介紹的非常詳細(xì),需要的朋友可以參考下2022-07-07
Springboot實(shí)現(xiàn)密碼的加密解密
這篇文章主要為大家詳細(xì)介紹了Springboot實(shí)現(xiàn)密碼的加密解密,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2017-11-11

