快捷導(dǎo)航

淺談spring的重試機(jī)制無(wú)效@Retryable@EnableRetry

更新時(shí)間：2020年09月18日 10:28:43 作者：Singlerr

這篇文章主要介紹了淺談spring的重試機(jī)制無(wú)效@Retryable@EnableRetry，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧

spring-retry模塊支持方法和類、接口、枚舉級(jí)別的重試

方式很簡(jiǎn)單，引入pom包

<parent>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-parent</artifactId>
  <version>lastest</version>
</parent>
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- https://mvnrepository.com/artifact/org.springframework.retry/spring-retry -->
<dependency>
  <groupId>org.springframework.retry</groupId>
  <artifactId>spring-retry</artifactId>
  <version>1.1.2.RELEASE</version>
</dependency>
<dependency>
  <groupId>org.aspectj</groupId>
  <artifactId>aspectjweaver</artifactId>
  <version>1.8.6</version>
</dependency>

然后在@Configuration注解的類中添加@EnableRetry

最后在想要重試的方法上添加@Retryable(Exception.class)

由于retry用到了aspect增強(qiáng)，所有會(huì)有aspect的坑，就是方法內(nèi)部調(diào)用，會(huì)使aspect增強(qiáng)失效，那么retry當(dāng)然也會(huì)失效。

例如

public class demo {
  public void A() {
    B();
  }

  @Retryable(Exception.class)
  public void B() {
    throw new RuntimeException("retry...");
  }
}

這種情況B()不會(huì)重試。

補(bǔ)充知識(shí)：Springboot整合Spring Retry實(shí)現(xiàn)重試機(jī)制

在項(xiàng)目開(kāi)發(fā)過(guò)程中，經(jīng)常會(huì)有這樣的情況：第一次執(zhí)行一個(gè)操作不成功，考慮到可能是網(wǎng)絡(luò)原因造成，就多執(zhí)行幾次操作，直到得到想要的結(jié)果為止，這就是重試機(jī)制。

Springboot可以通過(guò)整合Spring Retry框架實(shí)現(xiàn)重試。

下面講一下在之前新建的ibatis項(xiàng)目基礎(chǔ)上整合Spring Retry框架的步驟：

1、首先要在pom.xml配置中加入spring-retry的依賴：

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

2、在啟動(dòng)類中加入重試注解@EnableRetry。

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.retry.annotation.EnableRetry;

@EnableRetry //重試注解
@MapperScan("com.batis.mapper")
@SpringBootApplication
public class BatisApplication {
  public static void main(String[] args) {
    SpringApplication.run(BatisApplication.class, args);
  }
}

3、新建重試接口RetryService和實(shí)現(xiàn)類RetryServiceImpl

重試接口：

public interface RetryService {
  void retryTransferAccounts(int fromAccountId, int toAccountId, float money) throws Exception;
}

接口實(shí)現(xiàn)類：

import com.batis.mapper.AccountMapper;
import com.batis.model.Account;
import com.batis.service.RetryService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.retry.annotation.Backoff;
import org.springframework.retry.annotation.Recover;
import org.springframework.retry.annotation.Retryable;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class RetryServiceImpl implements RetryService {
  @Autowired
  private AccountMapper accountMapper;

  @Transactional
  @Retryable(value = Exception.class, maxAttempts = 3, backoff = @Backoff(delay = 3000, multiplier = 1, maxDelay = 10000))
  @Override
  public void retryTransferAccounts(int fromAccountId, int toAccountId, float money) throws Exception {
    Account fromAccount = accountMapper.findOne(fromAccountId);
    fromAccount.setBalance(fromAccount.getBalance() - money);
    accountMapper.update(fromAccount);

    int a = 2 / 0;
    Account toAccount = accountMapper.findOne(toAccountId);
    toAccount.setBalance(toAccount.getBalance() + money);
    accountMapper.update(toAccount);
    throw new Exception();
  }

  @Recover
  public void recover(Exception e) {
    System.out.println("回調(diào)方法執(zhí)行！?。?);
  }
}

@Retryable：標(biāo)記當(dāng)前方法會(huì)使用重試機(jī)制

value：重試的觸發(fā)機(jī)制，當(dāng)遇到Exception異常的時(shí)候，會(huì)觸發(fā)重試

maxAttempts：重試次數(shù)（包括第一次調(diào)用）

delay：重試的間隔時(shí)間

multiplier：delay時(shí)間的間隔倍數(shù)

maxDelay：重試次數(shù)之間的最大時(shí)間間隔，默認(rèn)為0，如果小于delay的設(shè)置，則默認(rèn)為30000L

@Recover：標(biāo)記方法為回調(diào)方法，傳參與@Retryable的value值需一致

4、新建重試控制器類RetryController

import com.batis.service.RetryService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/retry")
public class RetryController {
  @Autowired
  private RetryService retryService;

  @RequestMapping(value = "/transfer", method = RequestMethod.GET)
  public String transferAccounts() {
    try {
      retryService.retryTransferAccounts(1, 2, 200);
      return "ok";
    } catch (Exception e) {
      return "no";
    }
  }
}

5、啟動(dòng)ibatis項(xiàng)目進(jìn)行測(cè)試，在瀏覽器地址欄輸入：http://localhost:8080/retry/transfer