在JPA存储库上的Spring重试

Question

我是spring的新手，作为项目实现的一部分，我应该在调用JPA存储库的服务方法上添加一个spring重试。代码如下所示

@Retryable(value = {Exception.class},maxAttempts = 1,backoff = @Backoff(300))
public Page<Account> findAllAccounts(AccountSearchRequest account, Pageable pageable) {
    try {
        return map(accountSearchRepository.findAll(account, pageable));
    }catch (Exception e){
        System.out.println("SQL EXCEPTION CAUGTH!!!!!!!!!");
    }
    return null;
}
@Recover
public void recover(Exception e){
    System.out.println("!!!!!!!!!to get connection!!!!");
}

数据库：Postgresql

应用程序：Java (公开Rest以获取所有帐户)

HikariPool MaximumPoolSize **：**1

Hikari ConnectionTimeout **：**1000

JMeter用于发送10,000 API请求。

Problem：我可以看到SQL异常CAUGTH！打印，但我认为重试不起作用，因为我没有看到恢复方法的打印。我是不是遗漏了什么？

下面是gradle依赖项

// https://mvnrepository.com/artifact/org.springframework.retry/spring-retry
compile group: 'org.springframework.retry', name: 'spring-retry', version: '1.2.4.RELEASE'


// https://mvnrepository.com/artifact/org.springframework/spring-aspects
compile group: 'org.springframework', name: 'spring-aspects', version: '3.2.4.RELEASE'

// https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-aop
compile group: 'org.springframework.boot', name: 'spring-boot-starter-aop', version: '2.1.3.RELEASE'


// https://mvnrepository.com/artifact/org.springframework/spring-aop
compile group: 'org.springframework', name: 'spring-aop', version: '5.1.5.RELEASE'

Answer 1

谢谢你的支持。

我发现问题在于@Recover方法的数据类型与@Retryable不同。在上述场景中重新尝试工作的条件

@Recover和@Retryable应该是公共的，并且返回类型相同。

Answer 2

试一试

@Retryable(value = {SQLException.class},maxAttempts = 1,backoff = @Backoff(300))
public Page<Account> findAllAccounts(AccountSearchRequest account, Pageable pageable) throws SQLException {    
       throw new SQLException("test");
}

@Recover
public void recover(Exception e){
    System.out.println("!!!!!!!!!to get connection!!!!");
}