@Recover не работает, если @Retryable возвращает значение - PullRequest
1 голос
/ 26 апреля 2020

Я пытаюсь реализовать повторную логику c. мой код работает, как и ожидалось, пока возвращаемый тип метода повтора не имеет значения. в тот момент, когда я изменяю его на String, @Recover перестает работать.

 @Component
  public class AdapterImpl {
      int count = 0;

    @Retryable(include = {NullPointerException.class, IllegalStateException.class}, backoff = @Backoff(delay = 100, maxDelay = 101), maxAttempts = 5)
    public void retry(String foo) {
        System.out.println(foo + " " + count++);
        if (foo.equals("foo")) {
            throw new NullPointerException("foo");
        } else if (foo.equals("bar")) {
            throw new IllegalStateException("bar");
        }
//        return "hi";
    }

    @Recover
    public void connectionException(NullPointerException e) {
        System.out.println("Retry failure NullPointerException");
    }

    @Recover
    public void connectionException(IllegalStateException e) {
        System.out.println("Retry failure IllegalStateException");
    }
}

как для foo, так и для bar, лог повторных попыток c работает. Журналы, как показано ниже

bar 0
bar 1
bar 2
bar 3
bar 4
Retry failure IllegalStateException

, но когда я изменяю тип возвращаемого значения метода повторения на String, метод @Recover перестает работать.

@Retryable(include = {NullPointerException.class, IllegalStateException.class}, backoff = @Backoff(delay = 100, maxDelay = 101), maxAttempts = 5)
public String retry(String foo) {
    System.out.println(foo + " " + count++);
    if (foo.equals("foo")) {
        throw new NullPointerException("foo");
    } else if (foo.equals("bar")) {
        throw new IllegalStateException("bar");
    }
    return "hi";
}

Журналы такие же, как показано ниже

bar 0
bar 1
bar 2
bar 3
bar 4
2020-04-26 23:28:30.800 ERROR 59644 --- [nio-8087-exec-3] o.a.c.c.C.[.[.[/].[dispatcherServlet]    : Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.retry.ExhaustedRetryException: Cannot locate recovery method; nested exception is java.lang.IllegalStateException: bar] with root cause

java.lang.IllegalStateException: bar

Мой build.gradle -

   plugins {
    id 'java'
    id 'org.springframework.boot' version '2.2.6.RELEASE'
    id 'io.spring.dependency-management' version '1.0.9.RELEASE'
}

group 'com.demo.web'
version '1.0-SNAPSHOT'

repositories {
    mavenCentral()
}

dependencies {
    compile 'org.springframework.boot:spring-boot-starter-web'
    compile 'org.springframework.retry:spring-retry'
    compile 'org.springframework:spring-aspects'
    compileOnly 'org.projectlombok:lombok'
    annotationProcessor 'org.projectlombok:lombok'
    testCompile group: 'junit', name: 'junit', version: '4.12'
}

что я делаю не так?

1 Ответ

1 голос
/ 26 апреля 2020

Существуют определенные правила, использующие @ Recover с пружиной @ Retryable

  • Аннотация для вызова метода, который является обработчиком восстановления.
  • Подходящий обработчик восстановления имеет первый параметр типа Throwable (или подтип Throwable) и возвращаемое значение того же типа, что и метод @Retryable для восстановления.
  • Первый аргумент Throwable является необязательным (но метод без него будет вызываться только при отсутствии совпадений с другими). ​​
  • Последующие аргументы заполняются из списка аргументов сбойный метод по порядку.

Поэтому убедитесь, что у вас есть соответствующий восстанавливаемый метод с вышеуказанными правилами

 @Recover
public String connectionException(NullPointerException e, String foo) {
    System.out.println("Retry failure NullPointerException");
}

@Recover
public String connectionException(IllegalStateException e, String foo) {
    System.out.println("Retry failure IllegalStateException");
}
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...