Java重試框架Sisyphus配置的方式有哪些

本篇內(nèi)容主要講解“Java重試框架Sisyphus配置的方式有哪些”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學(xué)習(xí)“Java重試框架Sisyphus配置的方式有哪些”吧!

1、函數(shù)式配置概覽

為了滿足更加方便的配置，Retryer 類提供了許多可以配置的信息。

1.1 默認(rèn)配置

/** 
 * 默認(rèn)配置測試 
 */ 
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(); 
}

和下面的代碼是等價的：

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ā)的條件，可以指定多個條件。

默認(rèn)為拋出異常。

2.2 retryWaitContext

重試等待的策略，可以指定多個。

默認(rèn)為不做任何等待。

2.3 maxAttempt

指定最大重試次數(shù)，包括第一次執(zhí)行。

默認(rèn)值：3 次。

2.4 listen

指定重試的監(jiān)聽實現(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 接口及其實現(xiàn)

所有的接口，都可以直接查看對應(yīng)的子類實例。

3.2 用戶自定義

基于替換的靈活性，用戶可以實現(xiàn)接口，定義更符合自己業(yè)務(wù)的實現(xiàn)。

3.3 sisyphus 注解

配置具有很高的靈活性，但是對于開發(fā)人員的使用，就沒有注解那樣簡單靈活。

所以本框架也實現(xiàn)了基于注解的重試。

4、設(shè)計的規(guī)范

保證接口和注解二者的統(tǒng)一性。

4.1 maven 引入

<dependency> 
    <groupId>${project.groupId}</groupId> 
    <artifactId>sisyphus-annotation</artifactId> 
    <version>${project.version}</version> 
</dependency>

注解：

核心注解主要有兩個。

4.2 Retry

用于指定重試的相關(guān)配置。

/** 
 * 重試注解 
 * 1. 實際需要，只允許放在方法上。 
 * 2. 如果放在接口上，是否所有的子類都生效？為了簡單明確，不提供這種實現(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 { 
 
    /** 
     * 重試類實現(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ā)的場景 
     * @return 重試觸發(fā)的場景 
     */ 
    Class<? extends RetryCondition> condition() default ExceptionCauseRetryCondition.class; 
 
    /** 
     * 監(jiān)聽器 
     * 1. 默認(rèn)不進行監(jiān)聽 
     * @return 監(jiān)聽器 
     */ 
    Class<? extends RetryListen> listen() default NoRetryListen.class; 
 
    /** 
     * 恢復(fù)操作 
     * 1. 默認(rèn)不進行任何恢復(fù)操作 
     * @return 恢復(fù)操作對應(yīng)的類 
     */ 
    Class<? extends Recover> recover() default NoRecover.class; 
 
    /** 
     * 等待策略 
     * 1. 支持指定多個，如果不指定，則不進行任何等待， 
     * @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. 為了對應(yīng)重試策略，所有的內(nèi)置注解應(yīng)該實現(xiàn)當(dāng)前的注解。 
 * 2. 是否允許自定義注解？ 
 * 
 * 當(dāng)注解+對象同時出現(xiàn)的時候，視為組合。 
 * 
 * @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 模式，則對應(yīng)固定等待時間 
     * 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; 
 
    /** 
     * 指定重試的等待時間 class 信息 
     * @return 重試等待時間 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é)碼增強。

如果是項目中沒有使用 spring，直接使用這種方式比較方便。

5.2 Spring-AOP

可以和 spring 直接整合。

使用方式和 spring-retry 是一樣的。

這些內(nèi)容將放在下一節(jié)進行詳細(xì)講解。

到此，相信大家對“Java重試框架Sisyphus配置的方式有哪些”有了更深的了解，不妨來實際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進入相關(guān)頻道進行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！