快捷導(dǎo)航

Spring boot使用spring retry重試機(jī)制的方法示例

更新時(shí)間：2020年01月03日 10:28:21 作者：java_small_ant

這篇文章主要介紹了Spring boot使用spring retry重試機(jī)制的方法示例，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

當(dāng)我們調(diào)用接口的時(shí)候由于網(wǎng)絡(luò)原因可能失敗，再嘗試就成功了，這就是重試機(jī)制。非冪等的情況下要小心使用重試。

tips：冪等性

HTTP/1.1中對(duì)冪等性的定義是：一次和多次請(qǐng)求某一個(gè)資源對(duì)于資源本身應(yīng)該具有同樣的結(jié)果（網(wǎng)絡(luò)超時(shí)等問(wèn)題除外）。也就是說(shuō)，其任意多次執(zhí)行對(duì)資源本身所產(chǎn)生的影響均與一次執(zhí)行的影響相同。

注解方式使用Spring Retry

(一)Maven依賴

<!-- 重試機(jī)制 -->
<dependency>
  <groupId>org.springframework.retry</groupId>
  <artifactId>spring-retry</artifactId>
  <version>1.2.4.RELEASE</version>
</dependency>

<dependency>
  <groupId>org.aspectj</groupId>
  <artifactId>aspectjweaver</artifactId>
  <version>1.9.4</version>
</dependency>

（二）配置類添加注解 @EnableRetry

@EnableRetry
@Configuration
public class RetryConfiguration {

}

（三）Service方法編寫

@Retryable注解:

value: 拋出指定異常才會(huì)重試

include：和value一樣，默認(rèn)為空，當(dāng)exclude也為空時(shí)，默認(rèn)所以異常

exclude：指定不處理的異常

maxAttempts：最大重試次數(shù)，默認(rèn)3次

backoff：重試等待策略，默認(rèn)使用@Backoff，@Backoff的value默認(rèn)為1000L；multiplier（指定延遲倍數(shù)）

@Recover注解：

當(dāng)重試達(dá)到指定次數(shù)時(shí)候該注解的方法將被回調(diào)

發(fā)生的異常類型需要和@Recover注解的參數(shù)一致

@Retryable注解的方法不能有返回值，不然@Recover注解的方法無(wú)效

@Service
public class RetryService {

 private Logger logger = LoggerFactory.getLogger(RetryService.class);

 @Retryable(value = Exception.class, maxAttempts = 3, backoff = @Backoff(delay = 2000L, multiplier = 2))
 public void devide(double a, double b){
   logger.info("開始進(jìn)行除法運(yùn)算");
   if (b == 0) {
     throw new RuntimeException();
   }
   logger.info("{} / {} = {}", a, b, a / b);
 }

 @Recover
 public void recover() {
   logger.error("被除數(shù)不能為0");
 }

}

（四）測(cè)試

@RunWith(SpringRunner.class)
@SpringBootTest
public class BootdemoApplicationTests {

  @Autowired
  private RetryService retryService;

  private Logger logger = LoggerFactory.getLogger(BootdemoApplication.class);

  @Test
  public void retryTest() {
    //int count = retryService.retry(-1);
    retryService.retry(-1);
    //logger.info("庫(kù)存為：" + count);
  }
}

注意事項(xiàng)

@Retryable不能在本類使用，不然不會(huì)生效。如果直接調(diào)用execute重試機(jī)制將不會(huì)生效，調(diào)用devide則重試生效。

public void execute(double a, double b) throws DevideException {
    devide(a, b);
  }

  @Retryable(value = DevideException.class, maxAttempts = 3, backoff = @Backoff(delay = 2000L, multiplier = 2))
  public void devide(double a, double b) throws DevideException {
    logger.info("開始進(jìn)行除法運(yùn)算");
    if (b == 0) {
      throw new DevideException("被除數(shù)不能為0");
    }
    logger.info("{} / {} = {}", a, b, a / b);
  }

使用@Retryable不能使用try catch捕獲異常為簡(jiǎn)單

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: