Spring Retry в репозитории JPA - PullRequest
Новая
       18

Spring Retry в репозитории JPA

0 голосов
/ 22 марта 2019

Я новичок в Spring. В рамках реализации моего проекта я должен добавить пружинную повторную попытку в метод сервиса, который вызывает JPA-репозиторий. Код выглядит примерно так: 

@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("!!!!!!!!!!!Failed to get connection!!!!!!");
}

База данных : Postgresql,

Приложение : Java Spring Boot (Exposed Rest API для получения всех учетных записей)

HikariPool MaximumPoolSize **: ** 1

Время подключения Hikari **: **1000* 1017 *

JMeter используется для отправки 10 000 запросов API.

Проблема : я могу видеть SQL EXCEPTION 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'

Ответы [ 2 ]

0 голосов
/ 25 марта 2019

Спасибо за поддержку.

Я обнаружил, что проблема в том, что метод @Recover имеет тип данных, отличный от @Retryable.Условия для повтора для работы в вышеуказанном сценарии

@Recover и @Retryable должны быть открытыми и иметь одинаковый тип возврата

0 голосов
/ 22 марта 2019

Попробуйте 

@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("!!!!!!!!!!!Failed to get connection!!!!!!");
}
...