SpringCloud升级之路2020.0.x版-34.验证重试配置正确性(2)
2021-11-14 08:44
549 查看
本系列代码地址:https://github.com/JoJoTec/spring-cloud-parent
我们继续上一节针对我们的重试进行测试
验证针对限流器异常的重试正确
通过系列前面的源码分析,我们知道 spring-cloud-openfeign 的 FeignClient 其实是懒加载的。所以我们实现的断路器也是懒加载的,需要先调用,之后才会初始化线程隔离。所以这里如果我们要模拟线程隔离满的异常,需要先手动读取载入线程隔离,之后才能获取对应实例的线程隔离,将线程池填充满。
我们先定义一个 FeignClient:
@FeignClient(name = "testService1", contextId = "testService1Client") public interface TestService1Client { @GetMapping("/anything") HttpBinAnythingResponse anything(); }
使用前面同样的方式,给这个微服务添加实例:
//SpringExtension也包含了 Mockito 相关的 Extension,所以 @Mock 等注解也生效了 @ExtendWith(SpringExtension.class) @SpringBootTest(properties = { //关闭 eureka client "eureka.client.enabled=false", //默认请求重试次数为 3 "resilience4j.retry.configs.default.maxAttempts=3", //增加断路器配置 "resilience4j.circuitbreaker.configs.default.failureRateThreshold=50", "resilience4j.circuitbreaker.configs.default.slidingWindowType=COUNT_BASED", "resilience4j.circuitbreaker.configs.default.slidingWindowSize=5", "resilience4j.circuitbreaker.configs.default.minimumNumberOfCalls=2", }) @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); when(service1Instance3.getMetadata()).thenReturn(zone1); when(service1Instance3.getInstanceId()).thenReturn("service1Instance3"); //这其实就是 httpbin.org ,为了和第一个实例进行区分加上 www when(service1Instance3.getHost()).thenReturn("www.httpbin.org"); DiscoveryClient spy = Mockito.spy(DiscoveryClient.class); //微服务 testService3 有两个实例即 service1Instance1 和 service1Instance4 Mockito.when(spy.getInstances("testService1")) .thenReturn(List.of(service1Instance1, service1Instance3)); return spy; } } }
然后,编写测试代码:
@Test public void testRetryOnBulkheadException() { //防止断路器影响 circuitBreakerRegistry.getAllCircuitBreakers().asJava().forEach(CircuitBreaker::reset); this.testService1Client.anything(); ThreadPoolBulkhead threadPoolBulkhead; try { threadPoolBulkhead = threadPoolBulkheadRegistry .bulkhead("testService1Client:httpbin.org:80", "testService1Client"); } catch (ConfigurationNotFoundException e) { //找不到就用默认配置 threadPoolBulkhead = threadPoolBulkheadRegistry .bulkhead("testService1Client:httpbin.org:80"); } //线程队列我们配置的是 1,线程池大小是 10,这样会将线程池填充满 for (int i = 0; i < 10 + 1; i++) { threadPoolBulkhead.submit(() -> { try { //这样任务永远不会结束了 Thread.currentThread().join(); } catch (InterruptedException e) { e.printStackTrace(); } }); } //调用多次,调用成功即对断路器异常重试了 for (int i = 0; i < 10; i++) { this.testService1Client.anything(); } }
运行测试,日志中可以看出,针对线程池满的异常进行重试了:
2021-11-13 03:35:16.371 INFO [,,] 3824 --- [ main] c.g.j.s.c.w.f.DefaultErrorDecoder : TestService1Client#anything() response: 584-Bulkhead 'testService1Client:httpbin.org:80' is full and does not permit further calls, should retry: true
验证针对非 2xx 响应码可重试的方法重试正确
我们通过使用 http.bin 的
/status/{statusCode}接口,这个接口会根据路径参数
statusCode返回对应状态码的响应:
@FeignClient(name = "testService1", contextId = "testService1Client") public interface TestService1Client { @GetMapping("/status/500") String testGetRetryStatus500(); }
我们如何感知被重试三次呢?每次调用,就会从负载均衡器获取一个服务实例。在负载均衡器代码中,我们使用了根据当前 sleuth 的上下文的 traceId 的缓存,每次调用,traceId 对应的 position 值就会加 1。我们可以通过观察这个值的变化获取到究竟本次请求调用了几次负载均衡器,也就是做了几次调用。
编写测试:
@Test public void testNon2xxRetry() { 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(); try { //get 方法会重试 testService1Client.testGetRetryStatus500(); } catch (Exception e) { } //因为每次调用都会失败,所以会重试配置的 3 次 Assertions.assertEquals(3, atomicInteger.get() - start); } }
验证针对非 2xx 响应码不可重试的方法没有重试
我们通过使用 http.bin 的
/status/{statusCode}接口,这个接口会根据路径参数
statusCode返回对应状态码的响应,并且支持各种 HTTP 请求方式:
@FeignClient(name = "testService1", contextId = "testService1Client") public interface TestService1Client { @PostMapping("/status/500") String testPostRetryStatus500(); }
默认情况下,我们只会对 GET 方法重试,对于其他 HTTP 请求方法,是不会重试的:
@Test public void testNon2xxRetry() { 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(); try { //post 方法不会重试 testService1Client.testPostRetryStatus500(); } catch (Exception e) { } //不会重试,因此只会被调用 1 次 Assertions.assertEquals(1, atomicInteger.get() - start); } }
微信搜索“我的编程喵”关注公众号,每日一刷,轻松提升技术,斩获各种offer:
相关文章推荐
- SpringCloud升级之路2020.0.x版-19.Eureka的服务端设计与配置
- SpringCloud升级之路2020.0.x版-20. 启动一个 Eureka Server 集群
- SpringCloud升级之路2020.0.x版-18.Eureka的客户端核心设计和配置
- SpringCloud升级之路2020.0.x版-23.订制Spring Cloud LoadBalancer
- SpringCloud升级之路2020.0.x版-26.OpenFeign的组件
- SpringCloud升级之路2020.0.x版-24.测试Spring Cloud LoadBalancer
- SpringCloud升级之路2020.0.x版-28.OpenFeign的生命周期-进行调用
- Spring Cloud Zuul的重试配置详解
- Spring Cloud 升级之路 - 2020.0.x - 3. Undertow 的 acces
- SpringCloud升级之路2020.0.x版-29.Spring Cloud OpenFeign 的解析(1)
- SpringCloud系列三:SpringSecurity 安全访问(配置安全验证、服务消费端处理、无状态 Session 配置、定义公共安全配置程序类)
- 为Spring Cloud Ribbon配置请求重试(Camden.SR2+)
- Spring Cloud 升级之路 - 2020.0.x - 2. 使用 Undertow 作为我们
- SpringCloud Config SSH拉取gitHub配置文件,验证失败的坑
- SpringCloud重试机制配置
- spring cloud zuul 重试配置
- 为Spring Cloud Ribbon/Zuul配置请求重试
- SpringCloud升级之路2020.0.x版-29.Spring Cloud OpenFeign 的解析(2)
- SpringCloud升级之路2020.0.x版-21.Spring Cloud LoadBalancer简介
- spring cloud zuul网关服务重试请求配置和源码分析