关于spring-cloud:SpringCloud升级之路20200x版34验证重试配置正确性3

38次阅读

共计 3604 个字符，预计需要花费 10 分钟才能阅读完成。

本系列代码地址：https://github.com/JoJoTec/sp…

咱们持续上一节针对咱们的重试进行测试

咱们能够通过 httpbin.org 的 /delay/ 响应工夫秒 来实现申请响应超时。例如 /delay/3 就会提早三秒后返回。这个接口也是能够承受任何类型的 HTTP 申请办法。

咱们先来指定对于 Feign 超时的配置 Options：

//SpringExtension 也蕴含了 Mockito 相干的 Extension，所以 @Mock 等注解也失效了
@ExtendWith(SpringExtension.class)
@SpringBootTest(properties = {
        // 敞开 eureka client
        "eureka.client.enabled=false",
        // 默认申请重试次数为 3
        "resilience4j.retry.configs.default.maxAttempts=3",
        // 指定默认响应超时为 2s
        "feign.client.config.default.readTimeout=2000",
})
@Log4j2
public class OpenFeignClientTest {
    @SpringBootApplication
    @Configuration
    public static class App {
        @Bean
        public DiscoveryClient discoveryClient() {
            // 模仿两个服务实例
            ServiceInstance service1Instance1 = Mockito.spy(ServiceInstance.class);
            ServiceInstance service1Instance3 = Mockito.spy(ServiceInstance.class);
            Map<String, String> zone1 = Map.ofEntries(Map.entry("zone", "zone1")
            );
            when(service1Instance1.getMetadata()).thenReturn(zone1);
            when(service1Instance1.getInstanceId()).thenReturn("service1Instance1");
            when(service1Instance1.getHost()).thenReturn("httpbin.org");
            when(service1Instance1.getPort()).thenReturn(80);
            DiscoveryClient spy = Mockito.spy(DiscoveryClient.class);
            // 微服务 testService1 有一个实例即 service1Instance1
            Mockito.when(spy.getInstances("testService1"))
                    .thenReturn(List.of(service1Instance1));
            return spy;
        }
    }
}

咱们别离定义会超时和不会超时的接口：

@FeignClient(name = "testService1", contextId = "testService1Client")
public interface TestService1Client {@GetMapping("/delay/1")
    String testGetDelayOneSecond();

    @GetMapping("/delay/3")
    String testGetDelayThreeSeconds();}

编写测试，还是通过获取调用负载平衡获取实例的次数确定申请调用了多少次。

@Test
public void testTimeOutAndRetry() throws InterruptedException {Span span = tracer.nextSpan();
    try (Tracer.SpanInScope cleared = tracer.withSpanInScope(span)) {
        // 避免断路器影响
        circuitBreakerRegistry.getAllCircuitBreakers().asJava().forEach(CircuitBreaker::reset);
        long l = span.context().traceId();
        RoundRobinWithRequestSeparatedPositionLoadBalancer loadBalancerClientFactoryInstance
                = (RoundRobinWithRequestSeparatedPositionLoadBalancer) loadBalancerClientFactory.getInstance("testService1");
        AtomicInteger atomicInteger = loadBalancerClientFactoryInstance.getPositionCache().get(l);
        int start = atomicInteger.get();
        // 不超时，则不会有重试，也不会有异样导致 fallback
        String s = testService1Client.testGetDelayOneSecond();
        // 没有重试，只会申请一次
        Assertions.assertEquals(1, atomicInteger.get() - start);

        // 避免断路器影响
        circuitBreakerRegistry.getAllCircuitBreakers().asJava().forEach(CircuitBreaker::reset);
        start = atomicInteger.get();
        // 超时，并且办法能够重试，所以会申请 3 次
        try {s = testService1Client.testGetDelayThreeSeconds();
        } catch(Exception e) {}
        Assertions.assertEquals(3, atomicInteger.get() - start);
    }
}

对于 GET 办法，咱们默认是能够重试的。然而个别扣款这种波及批改申请的接口，咱们会应用其余办法例如 POST。这一类办法个别申请超时咱们不会间接重试的。咱们还是通过 httporg.bin 的提早接口进行测试：

@FeignClient(name = "testService1", contextId = "testService1Client")
public interface TestService1Client {@PostMapping("/delay/3")
    String testPostDelayThreeSeconds();}

编写测试，还是通过获取调用负载平衡获取实例的次数确定申请调用了多少次。

@Test
public void testTimeOutAndRetry() throws InterruptedException {Span span = tracer.nextSpan();
    try (Tracer.SpanInScope cleared = tracer.withSpanInScope(span)) {
        // 避免断路器影响
        circuitBreakerRegistry.getAllCircuitBreakers().asJava().forEach(CircuitBreaker::reset);
        long l = span.context().traceId();
        RoundRobinWithRequestSeparatedPositionLoadBalancer loadBalancerClientFactoryInstance
                = (RoundRobinWithRequestSeparatedPositionLoadBalancer) loadBalancerClientFactory.getInstance("testService1");
        AtomicInteger atomicInteger = loadBalancerClientFactoryInstance.getPositionCache().get(l);
        int start = atomicInteger.get();
        // 不超时，则不会有重试，也不会有异样导致 fallback
        String s = testService1Client.testPostDelayThreeSeconds();
        // 没有重试，只会申请一次
        Assertions.assertEquals(1, atomicInteger.get() - start);
    }
}