重試在功能設(shè)計上需要根據(jù)應(yīng)用場景進行設(shè)計，讀數(shù)據(jù)的接口比較適合重試的場景，寫數(shù)據(jù)的接口就需要注意接口的冪等性了，還有就是重試次數(shù)如果太多的話會導(dǎo)致請求量加倍，給后端造成更大的壓力，設(shè)置合理的重試機制是關(guān)鍵；

Spring Retry重試框架

Spring boot使用spring retry重試機制

1.pom引用

<dependency>
  <groupId>org.springframework.retry</groupId>
  <artifactId>spring-retry</artifactId>
</dependency>

2.應(yīng)用啟動類開啟retry

@EnableRetry
public class Application {
    .......
}

3.在指定方法上標(biāo)記@Retryable來開啟重試

@Retryable(value={RuntimeException.class},maxAttempts=5,backoff = @Backoff(delay = 2000,multiplier = 1.5))
public void retryTest() throws Exception {
    System.out.println(Thread.currentThread().getName()+" do something...");
    throw new RuntimeException();
}

value: 指定發(fā)生的異常進行重試

include: 和value一樣，默認空，當(dāng)exclude也為空時，所有異常都重試

exclude: 指定異常不重試，默認空，當(dāng)include也為空時，所有異常都重試

maxAttemps: 重試次數(shù)，默認3

backoff: 重試補償機制，默認沒有

4.在指定方法上標(biāo)記@Recover來開啟重試失敗后調(diào)用的方法(注意,需跟重處理方法在同一個類中)

@Recover
 public void recover(RuntimeException e) {
   // ... do something
 }

使用詳解
spring-retry通過AOP實現(xiàn)對目的方法的封裝，執(zhí)行在當(dāng)前線程下，所以重試過程中當(dāng)前線程會堵塞。如果BackOff時間設(shè)置比較長，最好起異步線程重試（也可以加@Async注解）。

@Retryable注解

被注解的方法發(fā)生異常時會重試

value:指定發(fā)生的異常進行重試

include:和value一樣，默認空，當(dāng)exclude也為空時，所有異常都重試

exclude:指定異常不重試，默認空，當(dāng)include也為空時，所有異常都重試

maxAttemps:重試次數(shù)，默認3

backoff:重試補償機制，默認沒有

@Backoff注解
delay:指定延遲后重試

multiplier:指定延遲的倍數(shù)，比如delay=5000l,multiplier=2時，第一次重試為5秒后，第二次為10秒，第三次為20秒

@Recover
當(dāng)重試到達指定次數(shù)時，被注解的方法將被回調(diào)，可以在該方法中進行日志處理。需要注意的是發(fā)生的異常和入?yún)㈩愋鸵恢聲r才會回調(diào)

spring-retry踩坑

一、@Retryable未生效可能原因

@Retryable方法必須為 public

下面情況下@Retryable不生效，即重試方法與調(diào)用它的非重試方法在同一個類中。

// 注意 此方法不生效?。?！
@EnableRetry(proxyTargetClass = true)
class test{
	public void methodA(){
		methodB();
	}
  @Retryable
  public void methodB(){
  
  }
}

解決方案：將重試方法單獨寫了一個Service。

3.每個類中對一種異常只有一個重試方法。兩個重試方法捕捉Exception，重試失效。

二、@Recover未生效可能原因

①返回值必須和被重試的函數(shù)返回值一致；
②參數(shù)中除了第一個是觸發(fā)的異常外，后面的參數(shù)需要和被重試函數(shù)的參數(shù)列表一致；
③當(dāng)然這里的返回值部分也可以再做一次手動重試，但是已經(jīng)嘗試那么多次都失敗了，所以在兜底函數(shù)中再做一次也意義不大。因此我的考慮是，這里就用來做日志記錄就好。

以上就是SpringBoot使用spring retry重試機制的操作詳解的詳細內(nèi)容，更多關(guān)于SpringBoot使用spring retry的資料請關(guān)注腳本之家其它相關(guān)文章！

最新評論