3

我在 Spring Boot 项目中使用 Resilience4J 来调用 REST 客户端，如下所示：

@Retry(name = "customerService")
public Customer getCustomer(String customerNumber) {
    restTemplate.exchange("https://customer-service.net", HttpMethod.GET, ..., customerNumber);
}

使用此配置：

resilience4j.retry:
    instances:
        customerService:
            maxAttempts: 3
            waitDuration: 10s
            retryExceptions:
                - org.springframework.web.client.HttpServerErrorException

我的期望是如果restTemplate.exchange()被调用并且客户服务以 a 响应，则在等待十秒钟后HttpServerErrorException，该getCustomer()方法将再调用 3 次。

然而，这种情况并非如此。

永远不会再次调用此方法，并立即抛出异常。

看到示例中包含一个备用方法，我决定添加它，即使我真的不想调用不同的方法，我只想再次调用我的原始方法。

无论如何，我指定了一个后备：

@Retry(name = "customerService", fallback = "customerFb")
public Customer getCustomer(String customerNumber) {
    return getCustomer();
}

private Customer customerFb(String customerNumber, HttpServerErrorException ex) {
    log.error("Could not retrieve customer... retrying...");
    return getCustomer();
}

private Customer getCustomer(String customerNumber) {
    return restTemplate.exchange("https://customer-service.net", HttpMethod.GET, ..., customerNumber);
}

现在，我看到正在重试回退方法，但是每次都会抛出 HttpServerErrorException，这意味着消费者将收到一个异常作为对其调用的响应。

我的问题是：

是否需要实施后备方法才能使重试功能起作用？

和

抛出异常是预期的行为吗？难道我做错了什么？在进行所有重试尝试之前，我不希望此服务的调用者收到异常。

谢谢

4

1 回答 1

4

问：是否需要实施回退方法才能使重试功能正常工作？

回答：不，回退在 Resilience4J 重试功能中是可选的。

的 行为Resilience4J Retry：

  1. 在启动时，弹性重试从 application.properties/yml 加载配置，如果配置 else 将使用文档中提到的默认值初始化。

  2. 当调用带有 @Retry 注释的方法时，它将处于重试监控之下。

  3. 如果resilience4j.retry.instances.<instance name>.retryExceptions显式配置了属性，则仅将配置的异常视为失败，并且仅针对这些失败触发重试，而对于其余异常，它在没有重试功能的情况下表现正常。

  4. 当在带注释的方法下发生预期的异常时@retry，它不会记录有关异常的任何内容，但它会根据maxAttempts配置的属性重试相同的方法。maxAttempts属性的默认值为3。在 maxAttempts 之后，它会抛出异常并且可以在日志中看到。

  5. 还有像waitDuration, intervalFunction, ignoreExceptions.. e.tc 这样的属性可以显式配置。有关更多信息，请查看文档链接。

  6. 要在使用 注释的方法中实际查看异常事件期间发生的情况@retry，请启用 RetryRegistry 事件使用者以打印接收到的事件。

RetryRegistry 事件监听器的示例代码：

package com.resilience.retry.config;

import javax.annotation.PostConstruct;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import io.github.resilience4j.retry.RetryRegistry;
import lombok.extern.slf4j.Slf4j;

@Component
@Slf4j
public class RetryRegistryEventListener {

    @Autowired
    private RetryRegistry registry;


    @PostConstruct
    public void postConstruct() {
        //registry.retry(<resilience retry instance name>)
        registry.retry("sample-api").getEventPublisher()
                .onRetry(ev -> log.info("#### RetryRegistryEventListener message: {}", ev));
    }
}

示例日志：

2021-11-01 14:55:12.337  INFO 18176 --- [nio-8080-exec-1] c.r.retry.controller.RetryController     : Sample Api call receieved
2021-11-01 14:55:12.345  INFO 18176 --- [nio-8080-exec-1] c.r.r.config.RetryRegistryEventListener  : #### RetryRegistryEventListener message: 2021-11-01T14:55:12.344325600+05:30[Asia/Calcutta]: Retry 'sample-api', waiting PT10S until attempt '1'. Last attempt failed with exception 'org.springframework.web.client.HttpServerErrorException: 500 INTERNAL_SERVER_ERROR'.
2021-11-01 14:55:12.350  INFO 18176 --- [nio-8080-exec-1] c.r.retry.controller.RetryController     : messsage: 2021-11-01T14:55:12.344325600+05:30[Asia/Calcutta]: Retry 'sample-api', waiting PT10S until attempt '1'. Last attempt failed with exception 'org.springframework.web.client.HttpServerErrorException: 500 INTERNAL_SERVER_ERROR'.
2021-11-01 14:55:22.359  INFO 18176 --- [nio-8080-exec-1] c.r.retry.controller.RetryController     : Sample Api call receieved
2021-11-01 14:55:22.360  INFO 18176 --- [nio-8080-exec-1] c.r.r.config.RetryRegistryEventListener  : #### RetryRegistryEventListener message: 2021-11-01T14:55:22.360672900+05:30[Asia/Calcutta]: Retry 'sample-api', waiting PT10S until attempt '2'. Last attempt failed with exception 'org.springframework.web.client.HttpServerErrorException: 500 INTERNAL_SERVER_ERROR'.
2021-11-01 14:55:22.361  INFO 18176 --- [nio-8080-exec-1] c.r.retry.controller.RetryController     : messsage: 2021-11-01T14:55:22.360672900+05:30[Asia/Calcutta]: Retry 'sample-api', waiting PT10S until attempt '2'. Last attempt failed with exception 'org.springframework.web.client.HttpServerErrorException: 500 INTERNAL_SERVER_ERROR'.

@FerdTurgusen：我相信您的代码中有一些错误，否则它会正常工作。根据问题中的给定信息，我无法准确找到问题。因此，我创建了一个带有弹性 4j 示例的示例 spring boot，复制了您的问题，它对我来说工作正常，因此上传到 Github 供您参考。我建议您添加 RetryRegistryEventListener 类并在事件日志中查找问题，如果仍未解决请分享事件监听器日志。

Github 参考：示例 spring-boot 与弹性 4j 重试项目

于 2021-11-01T09:49:54.573 回答