使用注释式 Resilience4j 测试 SpringBoot

我正在使用注释式 Resilience4j春季启动应用程序 https://github.com/SidekickJohn/demo称为“演示”。通过 RestTemplate 调用外部后端时，我想使用 TimeLimiter 和 Retry 来实现以下目标：

1. 将 REST 调用持续时间限制为 5 秒 --> 如果需要更长的时间，则会失败并出现 TimeoutException
2. 重试 TimeoutException --> 最多尝试 2 次

为了查看我的弹性设置的配置是否按设计工作，我编写了一个集成测试。此测试在配置文件“test”下运行，并使用“application-test.yml”进行配置：

1. 使用 TestRestTemplate 向我的“SimpleRestEndpointController”发送调用
2. 控制器调用我的业务服务“CallExternalService”，它有一个带注释的方法“getPersonById”（注释：@TimeLimiter、@Retry）
3. 从此方法中，使用模拟的 RestTemplate 来调用“FANCY_URL”处的外部后端
4. 使用 Mockito，RestTemplate 对外部后端的调用会减慢（使用 Thread.sleep）
5. 我希望 TimeLimiter 在 5 秒后取消调用，并且 Retry 确保再次尝试 RestTemplate 调用（验证 RestTemplate 已被调用两次）

PROBLEM:TimeLimiter 和 Retry 已注册，但不执行其工作（TimeLimiter 不限制调用持续时间）。因此 RestTemplate 仅被调用一次，传递空的Person（请参阅代码以进行说明）。可以克隆链接的示例项目并在运行测试时展示问题。

Code of application-test.yml（也在这里：链接到 application-test.yml https://github.com/SidekickJohn/demo/blob/main/src/test/resources/application-test.yml):

resilience4j:
  timelimiter:
    configs:
      default:
        timeoutDuration: 5s
        cancelRunningFuture: true
    instances:
      MY_RESILIENCE_KEY:
        baseConfig: default
  retry:
    configs:
      default:
        maxRetryAttempts: 2
        waitDuration: 100ms
        retryExceptions:
          - java.util.concurrent.TimeoutException
    instances:
      MY_RESILIENCE_KEY:
        baseConfig: default

此测试的代码（也在这里：链接到 IntegrationTest.java https://github.com/SidekickJohn/demo/blob/main/src/test/java/com/sidekickjohn/demo/IntegrationTest.java):

@RunWith(SpringRunner.class)
@SpringBootTest(classes = {DemoApplication.class}, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
@EnableAutoConfiguration
@ActiveProfiles("test")
public class IntegrationTest {
    private TestRestTemplate testRestTemplate;
    public final String FANCY_URL = "https://my-fancy-url-doesnt-matter.com/person";
    private String apiUrl;
    private HttpHeaders headers;
    
    @LocalServerPort
    private String localServerPort;
    
    @MockBean
    RestTemplate restTemplate;
    
    @Autowired
    CallExternalService callExternalService;
    
    @Autowired
    SimpleRestEndpointController simpleRestEndpointController;
    
    @Before
    public void setup() {
        this.headers = new HttpHeaders();
        this.testRestTemplate = new TestRestTemplate("username", "password");
        this.apiUrl = String.format("http://localhost:%s/person", localServerPort);
    }
    
    @Test
    public void testShouldRetryOnceWhenTimelimitIsReached() {
        // Arrange
        Person mockPerson = new Person();
        mockPerson.setId(1);
        mockPerson.setFirstName("First");
        mockPerson.setLastName("Last");
        ResponseEntity<Person> mockResponse = new ResponseEntity<>(mockPerson, HttpStatus.OK);
            
        
        Answer customAnswer = new Answer() {
            private int invocationCount = 0;
            @Override
            public Object answer(InvocationOnMock invocationOnMock) throws Throwable {
                invocationCount++;
                if (invocationCount == 1) {
                    Thread.sleep(6000);
                    return new ResponseEntity<>(new Person(), HttpStatus.OK);
                } else {
                    return mockResponse;
                }
            }
        };
        
        doAnswer(customAnswer)
        .when(restTemplate).exchange(
                FANCY_URL,
                HttpMethod.GET,
                new HttpEntity<>(headers),
                new ParameterizedTypeReference<Person>() {});
        
        
        // Act
        ResponseEntity<Person> result = null;
        try {
            result = this.testRestTemplate.exchange(
                    apiUrl,
                    HttpMethod.GET,
                    new HttpEntity<>(headers),
                    new ParameterizedTypeReference<Person>() {
                    });
        } catch(Exception ex) {
            System.out.println(ex);         
        }
        
        
        // Assert
        verify(restTemplate, times(2)).exchange(
                FANCY_URL,
                HttpMethod.GET,
                new HttpEntity<>(headers),
                new ParameterizedTypeReference<Person>() {});
        Assert.assertNotNull(result);
        Assert.assertEquals(mockPerson, result.getBody());      
        
    }
}

我的应用程序的代码显示了问题： https://github.com/SidekickJohn/demo https://github.com/SidekickJohn/demo

我创建了一个“逻辑”泳道图作为 README.md 的一部分：https://github.com/SidekickJohn/demo/blob/main/README.md https://github.com/SidekickJohn/demo/blob/main/README.md

如果你想嘲笑真实的RestTemplate你使用的beanCallExternalService ，你必须使用 Mockito Spy ->https://www.baeldung.com/mockito-spy https://www.baeldung.com/mockito-spy

但我通常更喜欢并推荐使用 WireMock 而不是 Mockito 来模拟 HTTP 端点。