static CheckedFunction0 decorateCheckedSupplier(CircuitBreaker circuitBreaker, CheckedFunction0 supplier) { return () -> {
// 申请执行函数方法supplier.apply()的许可
// 具体逻辑在CircuiBreakerStateMachine中的CircuitBreakerState中实现 circuitBreaker.acquirePermission(); final long start = circuitBreaker.getCurrentTimestamp(); try {
// 执行目标方法 T result = supplier.apply(); long duration = circuitBreaker.getCurrentTimestamp() - start;
//目标方法执行完调用onResult(),check result最终调用onSuccess() circuitBreaker.onResult(duration, circuitBreaker.getTimestampUnit(), result); return result; } catch (Exception exception) { // Do not handle java.lang.Error long duration = circuitBreaker.getCurrentTimestamp() - start;
// 如果出现异常就调用onError(),执行onError策略的逻辑 circuitBreaker.onError(duration, circuitBreaker.getTimestampUnit(), exception); throw exception; } }; }

@Override public void transitionToDisabledState() { stateTransition(DISABLED, currentState -> new DisabledState()); } @Override public void transitionToMetricsOnlyState() { stateTransition(METRICS_ONLY, currentState -> new MetricsOnlyState()); } @Override public void transitionToForcedOpenState() { stateTransition(FORCED_OPEN, currentState -> new ForcedOpenState(currentState.attempts() + 1)); } @Override public void transitionToClosedState() { stateTransition(CLOSED, currentState -> new ClosedState()); } @Override public void transitionToOpenState() { stateTransition(OPEN, currentState -> new OpenState(currentState.attempts() + 1, currentState.getMetrics())); } @Override public void transitionToHalfOpenState() { stateTransition(HALF_OPEN, currentState -> new HalfOpenState(currentState.attempts())); }

private void publishResetEvent() { final CircuitBreakerOnResetEvent event = new CircuitBreakerOnResetEvent(name); publishEventIfPossible(event); }private void publishCallNotPermittedEvent() { final CircuitBreakerOnCallNotPermittedEvent event = new CircuitBreakerOnCallNotPermittedEvent( name); publishEventIfPossible(event); }private void publishSuccessEvent(final long duration, TimeUnit durationUnit) { final CircuitBreakerOnSuccessEvent event = new CircuitBreakerOnSuccessEvent(name, Duration.ofNanos(durationUnit.toNanos(duration))); publishEventIfPossible(event); }private void publishCircuitErrorEvent(final String name, final long duration, TimeUnit durationUnit, final Throwable throwable) { final CircuitBreakerOnErrorEvent event = new CircuitBreakerOnErrorEvent(name, Duration.ofNanos(durationUnit.toNanos(duration)), throwable); publishEventIfPossible(event); }private void publishCircuitIgnoredErrorEvent(String name, long duration, TimeUnit durationUnit, Throwable throwable) { final CircuitBreakerOnIgnoredErrorEvent event = new CircuitBreakerOnIgnoredErrorEvent(name, Duration.ofNanos(durationUnit.toNanos(duration)), throwable); publishEventIfPossible(event); }private void publishCircuitFailureRateExceededEvent(String name, float failureRate) { final CircuitBreakerOnFailureRateExceededEvent event = new CircuitBreakerOnFailureRateExceededEvent(name, failureRate); publishEventIfPossible(event); }private void publishCircuitSlowCallRateExceededEvent(String name, float slowCallRate) { final CircuitBreakerOnSlowCallRateExceededEvent event = new CircuitBreakerOnSlowCallRateExceededEvent(name, slowCallRate); publishEventIfPossible(event); }private void publishCircuitThresholdsExceededEvent(Result result, CircuitBreakerMetrics metrics) { if (Result.hasFailureRateExceededThreshold(result)) { publishCircuitFailureRateExceededEvent(getName(), metrics.getFailureRate()); } if (Result.hasSlowCallRateExceededThreshold(result)) { publishCircuitSlowCallRateExceededEvent(getName(), metrics.getSlowCallRate()); } }

org.springframework.cloud spring-cloud-starter-contract-stub-runner test

/** * get the CircuitBreaker status and metrics * * @param prefixName * @param circuitBreaker * @return circuitBreaker state */ public static String getCircuitBreakerStatus(String prefixName, CircuitBreaker circuitBreaker) {CircuitBreaker.Metrics metrics = circuitBreaker.getMetrics(); float failureRate = metrics.getFailureRate(); int failedCalls = metrics.getNumberOfFailedCalls(); int successfulCalls = metrics.getNumberOfSuccessfulCalls(); long notPermittedCalls = metrics.getNumberOfNotPermittedCalls(); int bufferedCalls = metrics.getNumberOfBufferedCalls(); float slowCallRate = metrics.getSlowCallRate(); int slowCalls = metrics.getNumberOfSlowCalls(); int slowFailedCalls = metrics.getNumberOfSlowFailedCalls(); int slowSuccessfulCalls = metrics.getNumberOfSlowSuccessfulCalls(); log.info(prefixName + " state=" + circuitBreaker.getState() + " , metrics[ failureRate=" + failureRate + ", failedCalls=" + failedCalls + ", successCalls=" + successfulCalls + ", notPermittedCalls=" + notPermittedCalls + ", bufferedCalls=" + bufferedCalls + ", \n\tslowCallRate=" + slowCallRate + ", slowCalls=" + slowCalls + ", slowFailedCalls=" + slowFailedCalls + ", slowSuccessfulCalls=" + slowSuccessfulCalls + " ]" ); log.info(prefixName + " circuitBreaker tags:{}", circuitBreaker.getTags()); return circuitBreaker.getState().name(); }public static void circuitBreakerEventListener(CircuitBreaker circuitBreaker) { circuitBreaker.getEventPublisher() .onSuccess(event -> log.info("---------- CircuitBreakerEvent:{}CircuitBreakerName:{}", event.getEventType(), event.getCircuitBreakerName())) .onError(event -> { log.info("---------- CircuitBreakerEvent:{}CircuitBreakerName:{}", event.getEventType(), event.getCircuitBreakerName()); Throwable throwable = event.getThrowable(); if (throwable instanceof TimeoutException) { // TODO record to slow call } }) .onIgnoredError(event -> log.info("---------- CircuitBreakerEvent:{}CircuitBreakerName:{}", event.getEventType(), event.getCircuitBreakerName())) .onReset(event -> log.info("---------- CircuitBreakerEvent:{}CircuitBreakerName:{}", event.getEventType(), event.getCircuitBreakerName())) .onStateTransition(event -> log.info("---------- CircuitBreakerEvent:{}CircuitBreakerName:{}", event.getEventType(), event.getCircuitBreakerName())) .onCallNotPermitted(event -> log.info("---------- CircuitBreakerEvent:{}CircuitBreakerName:{}", event.getEventType(), event.getCircuitBreakerName())) .onFailureRateExceeded(event -> log.info("---------- CircuitBreakerEvent:{}CircuitBreakerName:{}", event.getEventType(), event.getCircuitBreakerName())) .onSlowCallRateExceeded(event -> log.info("---------- CircuitBreakerEvent:{}CircuitBreakerName:{}", event.getEventType(), event.getCircuitBreakerName())); }

@Rule public WireMockRule wireMockRule = new WireMockRule(wireMockConfig().port(8080)); private WebTestClient testClient; private CircuitBreakerRegistry circuitBreakerRegistry; private CircuitBreaker circuitBreaker; private CircuitBreaker circuitBreakerWithTags; private CircuitBreakerConfig circuitBreakerConfig; private String PATH_200 = "/api/pancake/v1/yee/query"; private String PATH_400 = "/api/hk/card/v1/er/query"; private String PATH_408 = "/api/pancake/v1/coin/query"; private String PATH_500 = "/api/hk/card/v1/card/query"; @Before public void setup() { HttpClient httpClient = HttpClient.create().wiretap(true); testClient = WebTestClient.bindToServer(new ReactorClientHttpConnector(httpClient)) .baseUrl("http://localhost:8080") .responseTimeout(Duration.ofDays(1)) .build(); circuitBreakerRegistry = new InMemoryCircuitBreakerRegistry(); circuitBreakerConfig = CircuitBreakerConfig .custom() .failureRateThreshold(70) .slowCallRateThreshold(90) .slowCallDurationThreshold(Duration.ofMillis(1000 * 1)) .minimumNumberOfCalls(10) .slidingWindowType(CircuitBreakerConfig.SlidingWindowType.COUNT_BASED) .slidingWindowSize(10) .build(); circuitBreaker = circuitBreakerRegistry.circuitBreaker("resilience4jTest", circuitBreakerConfig); Resilience4jTestHelper.circuitBreakerEventListener(circuitBreaker); stubFor(post(urlMatching(PATH_200)) .willReturn(okJson("{}"))); stubFor(post(urlMatching(PATH_400)) .willReturn(badRequest())); stubFor(post(urlMatching(PATH_408)) .willReturn(okJson("{\"message\":\"time out\"}").withFixedDelay(1000 * 2))); stubFor(post(urlMatching(PATH_500)) .willReturn(serverError())); }@Test public void When_Test_CircuitBreaker_Expect_Close() { AtomicInteger count = new AtomicInteger(); for (int i = 0; i < 10; i++) { Resilience4jTestHelper.recordResponseToCircuitBreaker(circuitBreaker, testClient, PATH_200); Resilience4jTestHelper.getCircuitBreakerStatus(">>>>>>>>>> end call " + count.incrementAndGet(), circuitBreaker); } assertEquals(CircuitBreaker.State.CLOSED.name(), circuitBreaker.getState().name()); }@Test public void When_CircuitBreaker_Expect_Open() { circuitBreakerWithTags = circuitBreakerRegistry.circuitBreaker("circuitBreakerWithTags", circuitBreakerConfig, HashMap.of("resilience4jTest", "When_CircuitBreaker_Expect_Open")); Resilience4jTestHelper.circuitBreakerEventListener(circuitBreakerWithTags); AtomicInteger count = new AtomicInteger(); for (int i = 0; i < 10; i++) { Resilience4jTestHelper.recordResponseToCircuitBreaker(circuitBreakerWithTags, testClient, PATH_400); Resilience4jTestHelper.getCircuitBreakerStatus(">>>>>>>>>> end call " + count.incrementAndGet(), circuitBreakerWithTags); } assertEquals(CircuitBreaker.State.OPEN.name(), circuitBreakerWithTags.getState().name()); }@Test public void When_Test_CircuitBreaker_Expect_SlowCall() throws Throwable { AtomicInteger count = new AtomicInteger(); for (int i = 0; i < 10; i++) { circuitBreaker.executeCheckedSupplier(() -> { Resilience4jTestHelper.recordSlowCallResponseToCircuitBreaker(circuitBreaker, testClient, PATH_408); return null; }); Resilience4jTestHelper.getCircuitBreakerStatus(">>>>>>>>>> end call " + count.incrementAndGet(), circuitBreaker); } assertEquals(CircuitBreaker.State.OPEN.name(), circuitBreaker.getState().name()); }@Test public void When_CircuitBreaker_Expect_Fallback() { AtomicInteger count = new AtomicInteger(); for (int i = 0; i < 20; i++) { String path = PATH_500; CheckedFunction0 response = circuitBreaker.decorateCheckedSupplier(() -> Resilience4jTestHelper.responseToCircuitBreaker(circuitBreaker, testClient, path)); Try result = Try.of(response).map(val -> { Resilience4jTestHelper.getCircuitBreakerStatus(">>>>>>>>>> call success " + count.incrementAndGet(), circuitBreaker); return val; }).recover(CallNotPermittedException.class, throwable -> { Resilience4jTestHelper.getCircuitBreakerStatus(">>>>>>>>>> open CircuitBreaker " + count.incrementAndGet(), circuitBreaker); return "hit CallNotPermittedException"; }).recover(throwable -> { Resilience4jTestHelper.getCircuitBreakerStatus(">>>>>>>>>> call fallback " + count.incrementAndGet(), circuitBreaker); return "hit fallback"; }); log.info(">>>>>>>>>> result:{}", result.get()); if (count.get() > 10) { assertEquals("hit CallNotPermittedException", result.get()); } } }

1. 使用信号量SemaphoreBulkhead 2. 使用有界队列和固定线程池FixedThreadPoolBulkhead

static CheckedFunction0 decorateCheckedSupplier(Bulkhead bulkhead, CheckedFunction0 supplier) { return () -> { bulkhead.acquirePermission(); try { return supplier.apply(); } finally { bulkhead.onComplete(); } }; }

public static String responseToBulkhead(Bulkhead bulkhead, WebTestClient testClient, String path) { WebTestClient.ResponseSpec responseSpec = testClient.post().uri(path).exchange(); if (bulkhead.getMetrics().getAvailableConcurrentCalls() < 1) { throw BulkheadFullException.createBulkheadFullException(bulkhead); } try { responseSpec.expectStatus().is4xxClientError(); throw new RuntimeException("<<<<< hit 4XX >>>>>"); } catch (Throwable error) { }try { responseSpec.expectStatus().is5xxServerError(); throw new RuntimeException("<<<<< hit 5XX >>>>>"); } catch (Throwable error) { } responseSpec.expectStatus().is2xxSuccessful(); return "hit 200"; }/** * get the Bulkhead status and metrics * * @param prefixName * * @param bulkhead */ public static void getBulkheadStatus(String prefixName, Bulkhead bulkhead) { Bulkhead.Metrics metrics = bulkhead.getMetrics(); int availableCalls = metrics.getAvailableConcurrentCalls(); int maxCalls = metrics.getMaxAllowedConcurrentCalls(); log.info(prefixName + "bulkhead metrics[ availableCalls=" + availableCalls + ", maxCalls=" + maxCalls + " ],tags=" + bulkhead.getTags()); }public static void bulkheadEventListener(Bulkhead bulkhead) { bulkhead.getEventPublisher() .onCallRejected(event -> log.info("---------- BulkheadEvent:{}BulkheadName:{}", event.getEventType(), event.getBulkheadName())) .onCallFinished(event -> log.info("---------- BulkheadEvent:{}BulkheadName:{}", event.getEventType(), event.getBulkheadName())); }static int[] container = new int[100]; // 模拟一定概率的不释放资源 public static boolean releasePermission() { if (container[0] != 1) { for (int i = 0; i < 70; i++) { container[i] = 1; } for (int i = 70; i < 100; i++) { container[i] = 0; } } int index = (int) (Math.random() * 100); return container[index] == 1; }

private BulkheadRegistry bulkheadRegistry; private String PATH_200 = "/api/pancake/v1/yee/query"; private String PATH_400 = "/api/hk/card/v1/er/query"; private String PATH_408 = "/api/pancake/v1/coin/query"; private String PATH_500 = "/api/hk/card/v1/card/query"; @Before public void setup() { HttpClient httpClient = HttpClient.create().wiretap(true); testClient = WebTestClient.bindToServer(new ReactorClientHttpConnector(httpClient)) .baseUrl("http://localhost:8080") .responseTimeout(Duration.ofDays(1)) .build(); bulkheadRegistry = new InMemoryBulkheadRegistry(); stubFor(post(urlMatching(PATH_200)) .willReturn(okJson("{}"))); stubFor(post(urlMatching(PATH_400)) .willReturn(badRequest())); stubFor(post(urlMatching(PATH_408)) .willReturn(okJson("{\"message\":\"time out\"}").withFixedDelay(1000 * 2))); stubFor(post(urlMatching(PATH_500)) .willReturn(serverError())); }@Test public void When_Test_CircuitBreaker_With_Bulkhead_Expect_Hit_BulkheadFullException() { AtomicInteger count = new AtomicInteger(); ExecutorService executorService = Executors.newFixedThreadPool(50); Bulkhead bulkhead1 = bulkheadRegistry.bulkhead("bulkhead1", BulkheadConfig .custom() .maxConcurrentCalls(20) .maxWaitDuration(Duration.ofMillis(100)) .build()); Resilience4jTestHelper.bulkheadEventListener(bulkhead1); for (int i = 0; i < 100; i++) { if (bulkhead1.tryAcquirePermission()) { log.info(">>>>>>>>>> acquire permission {}", count.incrementAndGet()); Future futureStr = executorService.submit(() -> Resilience4jTestHelper.responseToBulkhead(bulkhead1, testClient, PATH_200)); Try.of(futureStr::get).andThen(val -> log.info(">>>>>>>>>> success {}: {}", count.get(), val)).recover(throwable -> { if (throwable instanceof ExecutionException) { Throwable cause = (ExecutionException) throwable.getCause(); if (cause instanceof BulkheadFullException) { log.info(">>>>>>>>>> BulkheadFullException {}: {}", count.get(), throwable.getMessage()); } else { log.info(">>>>>>>>>> ExecutionException {}: {}", count.get(), throwable.getMessage()); } } return "hit ExecutionException"; }); if (releasePermission()) { bulkhead1.onComplete(); log.info("---------- release permission"); } Resilience4jTestHelper.getBulkheadStatus(")))))))))) ", bulkhead1); } else { log.info(">>>>>>>>>> tryAcquirePermission false {}", count.incrementAndGet()); continue; } } executorService.shutdown(); }

RateLimiterConfig.custom() .timeoutDuration(Duration.ofMillis(1000*5)) .limitRefreshPeriod(Duration.ofSeconds(1)) .limitForPeriod(1000) .build());

/** * get the RateLimiter status and metrics * * @param prefixName * * @param rateLimiter */ public static void getRateLimiterStatus(String prefixName, RateLimiter rateLimiter) { RateLimiter.Metrics metrics = rateLimiter.getMetrics(); int availablePermissions = metrics.getAvailablePermissions(); int waitingThreads = metrics.getNumberOfWaitingThreads(); log.info(prefixName + "rateLimiter metrics[ availablePermissions=" + availablePermissions + ", waitingThreads=" + waitingThreads + " ]" ); }public static void rateLimiterEventListener(RateLimiter rateLimiter) { rateLimiter.getEventPublisher() .onSuccess(event -> log.info("---------- rateLimiter success:{}", event)) .onFailure(event -> log.info("---------- rateLimiter failure:{}", event)); }public static String responseToRateLimiter(RateLimiter rateLimiter,WebTestClient testClient, String path) { WebTestClient.ResponseSpec responseSpec = testClient.post().uri(path).exchange(); try { responseSpec.expectStatus().is4xxClientError(); rateLimiter.onError(new RuntimeException("<<<<< hit 4XX >>>>>")); throw new RuntimeException("<<<<< hit 4XX >>>>>"); } catch (Throwable error) { }try { responseSpec.expectStatus().is5xxServerError(); rateLimiter.onError(new RuntimeException("<<<<< hit 5XX >>>>>")); throw new RuntimeException("<<<<< hit 5XX >>>>>"); } catch (Throwable error) { } responseSpec.expectStatus().is2xxSuccessful(); rateLimiter.onSuccess(); return "hit 200"; }

private RateLimiterRegistry rateLimiterRegistry; private RateLimiter rateLimiter; rateLimiterRegistry = new InMemoryRateLimiterRegistry(); rateLimiter = rateLimiterRegistry.rateLimiter("resilience4jTest", RateLimiterConfig .custom() .timeoutDuration(Duration.ofMillis(100)) .limitRefreshPeriod(Duration.ofSeconds(1)) .limitForPeriod(20) .build()); Resilience4jTestHelper.rateLimiterEventListener(rateLimiter); @Test public void When_Test_CircuitBreaker_Expect_Hit_RateLimiter() throws Exception { AtomicInteger count = new AtomicInteger(); ExecutorService executorService = Executors.newFixedThreadPool(50); String path = expectError() ? PATH_500 : PATH_200; for (int i = 0; i < 100; i++) { Future futureStr = executorService.submit(() -> Resilience4jTestHelper.responseToRateLimiter(rateLimiter, testClient, path)); try { Future stringFuture = rateLimiter.executeCallable(() -> futureStr); Try.of(stringFuture::get).andThen(val -> { log.info(">>>>>>>>>> success {}: {}", count.incrementAndGet(), val); }).recover(throwable -> { log.info(">>>>>>>>>> exception {}: {}", count.incrementAndGet(), throwable.getMessage()); return "hit fallback"; }); Resilience4jTestHelper.getRateLimiterStatus(")))))))))) ", rateLimiter); } catch (RequestNotPermitted exception){ assertEquals("RateLimiter 'resilience4jTest' does not permit further calls" , exception.getMessage()); } } executorService.shutdown(); }

/** * get the Retry status and metrics * * @param prefixName * * @param retry */ public static void getRetryStatus(String prefixName, Retry retry) {Retry.Metrics metrics = retry.getMetrics(); long successfulCallsWithRetryAttempt = metrics.getNumberOfSuccessfulCallsWithRetryAttempt(); long successfulCallsWithoutRetryAttempt = metrics.getNumberOfSuccessfulCallsWithoutRetryAttempt(); long failedCallsWithRetryAttempt = metrics.getNumberOfFailedCallsWithRetryAttempt(); long failedCallsWithoutRetryAttempt = metrics.getNumberOfFailedCallsWithoutRetryAttempt(); log.info(prefixName + " -> retry metrics[ successfulCallsWithRetry=" + successfulCallsWithRetryAttempt + ", successfulCallsWithoutRetry=" + successfulCallsWithoutRetryAttempt + ", failedCallsWithRetry=" + failedCallsWithRetryAttempt + ", failedCallsWithoutRetry=" + failedCallsWithoutRetryAttempt + " ]" ); }public static void retryEventListener(Retry retry) { retry.getEventPublisher() .onSuccess(event -> log.info("))))))))))) retry service success:{}", event)) .onError(event -> { log.info("))))))))))) retry service failed:{}", event); Throwable exception = event.getLastThrowable(); if (exception instanceof TimeoutException) { // TODO } }) .onIgnoredError(event -> log.info("))))))))))) retry service failed and ignore:{}", event)) .onRetry(event -> log.info("))))))))))) retry call service: {}", event.getNumberOfRetryAttempts())); }public static String responseToRetry(Retry retry, WebTestClient testClient, String path) { WebTestClient.ResponseSpec responseSpec = testClient.post().uri(path).exchange(); try { responseSpec.expectStatus().is4xxClientError(); return "HIT_ERROR_4XX"; } catch (Throwable error) { } try { responseSpec.expectStatus().is5xxServerError(); return "HIT_ERROR_5XX"; } catch (Throwable error) { } responseSpec.expectStatus().is2xxSuccessful(); return "HIT_200"; }

private RetryRegistry retryRegistry; private Retry retry; retryRegistry = new InMemoryRetryRegistry(); retry = retryRegistry.retry("resilience4jTest", RetryConfig .custom() .maxAttempts(5) .waitDuration(Duration.ofMillis(500)) .retryOnResult(val -> val.toString().contains("HIT_ERROR_")) //.retryExceptions(RuntimeException.class) .build()); Resilience4jTestHelper.retryEventListener(retry); @Test public void When_Test_CircuitBreaker_Expect_Retry() { AtomicInteger count = new AtomicInteger(); for (int i = 0; i < 30; i++) { String path = expectError() ? PATH_200 : PATH_400; Callable response = Retry.decorateCallable(retry, () -> Resilience4jTestHelper.responseToRetry(retry, testClient, path)); Try.of(response::call).andThen(val -> log.info(">>>>>>>>>> result {}: {}", count.incrementAndGet(), val)); Resilience4jTestHelper.getRetryStatus("))))))))))", retry); } }

public static void timeLimiterEventListener(TimeLimiter timeLimiter) { timeLimiter.getEventPublisher() .onSuccess(event -> log.info("---------- timeLimiter success:{}", event)) .onError(event -> log.info("---------- timeLimiter error:{}", event)) .onTimeout(event -> log.info("---------- rateLimiter timeout:{}", event)); }public static String responseToTimeLimiter(TimeLimiter timeLimiter, CircuitBreaker circuitBreaker, WebTestClient testClient, String path) { WebTestClient.ResponseSpec responseSpec = testClient.post().uri(path).exchange(); try { responseSpec.expectStatus().is4xxClientError(); circuitBreaker.onError(0, TimeUnit.MILLISECONDS, new RuntimeException("<<<<< hit 4XX >>>>>")); timeLimiter.onError(new RuntimeException("<<<<< hit 4XX >>>>>")); throw new RuntimeException("<<<<< hit 4XX >>>>>"); } catch (Throwable error) { }try { responseSpec.expectStatus().is5xxServerError(); circuitBreaker.onError(0, TimeUnit.MILLISECONDS, new RuntimeException("<<<<< hit 5XX >>>>>")); timeLimiter.onError(new RuntimeException("<<<<< hit 5XX >>>>>")); throw new RuntimeException("<<<<< hit 5XX >>>>>"); } catch (Throwable error) { } responseSpec.expectStatus().is2xxSuccessful(); timeLimiter.onSuccess(); return "hit 200"; }

private TimeLimiterRegistry timeLimiterRegistry; private TimeLimiter timeLimiter; timeLimiterRegistry = new InMemoryTimeLimiterRegistry(); timeLimiter = timeLimiterRegistry.timeLimiter("resilience4jTest", TimeLimiterConfig .custom() .timeoutDuration(Duration.ofMillis(1000 * 1)) .cancelRunningFuture(true) .build()); Resilience4jTestHelper.timeLimiterEventListener(timeLimiter); @Test public void When_Test_CircuitBreaker_Expect_Timeout() { AtomicInteger count = new AtomicInteger(); ExecutorService executorService = Executors.newFixedThreadPool(10); for (int i = 0; i < 30; i++) { String path = expectError() ? PATH_408 : PATH_200; Future futureStr = executorService.submit(() -> Resilience4jTestHelper.responseToTimeLimiter(timeLimiter, circuitBreaker, testClient, path)); Callable stringCallable = timeLimiter.decorateFutureSupplier(() -> futureStr); Callable response = circuitBreaker.decorateCallable(stringCallable); Try.of(response::call).andThen(val -> log.info(">>>>>>>>>> success {} {}", count.incrementAndGet(), val)) .recover(CallNotPermittedException.class, throwable -> { Resilience4jTestHelper.getCircuitBreakerStatus(">>>>>>>>>> open CircuitBreaker " + count.incrementAndGet(), circuitBreaker); return "hit CircuitBreaker"; }).recover(throwable -> { Resilience4jTestHelper.getCircuitBreakerStatus(">>>>>>>>>> call fallback " + count.incrementAndGet(), circuitBreaker); log.error(">>>>>>>>>> fallback:{}", throwable.getMessage()); return "hit Fallback"; }); } }

推荐阅读

• 

  蓝牙耳机声音有延迟怎么解决
• 

  u盘通常长什么样子，u盘都有什么型号
• 

  鲡鱼段的做法 美味鲡鱼的做法！
• 

  河蟹怎么蒸蒸多长时间
• 

  防范Win10系统监控你的个人隐私的办法
• 

  子日贤哉回也一箪食一瓢饮在陋巷人不堪其忧咋翻译
• 

  北京亲子酒店排名榜 北京亲子主题酒店排名
• 

  M版是什么意思 电商M版是什么意思，电商m端是什么意思
• 

  拔牙后要痛几天才不痛 拔牙后疼多久
• 

  我来教你99围棋怎样进入注册页面
• 

  注册公司费用 品牌注册怎么注册流程，代办注册公司
• 

  猫咪无规律的咳嗽怎么办
• 

  爱普生350清零图解
• 

  武松事迹概括 武松主要事迹概括
• 

  第一次吃佛跳墙,看着材料列表里清一色的海鲜,想问下这样一锅会不会很腥臭？
• 

  喝几种茶水远离亚健康
• 

  苹果酥怎么做? 苹果酥怎么做
• 

  吃鸭血有什么好处、、
• 

  佳能6d晚上拍摄人像模式 佳能6d晚上拍摄人像
• 

  尼康d7100对比佳能70d 尼康d7100对比佳能760

• 任时光绽放成六月繁花
• 赢在人生六项精进二阶Day3复盘
• 财商智慧课（六）
• 六步搭建ES6语法环境
• 社保代缴公司服务费包含哪些
• 六月更新的......
• 六一礼物
• 六项精进20180530
• 2018年8月25日|2018年8月25日 星期六 晴 亲子日记第259篇
• 私有化轻量级持续集成部署方案--03-部署web服务（下）