forked from LianjiaTech/retrofit-spring-boot-starter
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
yukdawn
committed
Apr 10, 2022
1 parent
2bde477
commit 14fd4d2
Showing
13 changed files
with
184 additions
and
146 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -3,25 +3,21 @@ | |
| import java.lang.annotation.*; | ||
|
|
||
| /** | ||
| * @author 陈添明 | ||
| * 应仅采用异常比例模式来控制熔断，超时导致的报错应在okhttp这一层做 | ||
| * @author 陈添明 [email protected] | ||
| */ | ||
| @Retention(RetentionPolicy.RUNTIME) | ||
| @Target({ElementType.METHOD, ElementType.TYPE}) | ||
| @Documented | ||
| public @interface Degrade { | ||
|
|
||
| /** | ||
| * RT threshold or exception ratio threshold count. | ||
| * 异常比例 | ||
| */ | ||
| double count(); | ||
| float count(); | ||
|
|
||
| /** | ||
| * Degrade recover timeout (in seconds) when degradation occurs. | ||
| * 时间窗口size，单位：秒 | ||
| */ | ||
| int timeWindow() default 5; | ||
|
|
||
| /** | ||
| * Degrade strategy (0: average RT, 1: exception ratio). | ||
| */ | ||
| DegradeStrategy degradeStrategy() default DegradeStrategy.AVERAGE_RT; | ||
| } | ||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -3,16 +3,27 @@ | |
| import java.io.IOException; | ||
| import java.util.List; | ||
|
|
||
| import okhttp3.Response; | ||
|
|
||
| /** | ||
| * @author [email protected] 2022/4/5 23:14 | ||
| */ | ||
| public interface DegradeRuleRegister { | ||
|
|
||
| void register(RetrofitDegradeRule retrofitDegradeRule); | ||
|
|
||
| /** | ||
| * 批量注册规则 | ||
| * @param retrofitDegradeRuleList 规则描述对象集合 | ||
| */ | ||
| void batchRegister(List<RetrofitDegradeRule> retrofitDegradeRuleList); | ||
|
|
||
| <T> T exec(String resourceName, DegradeProxyMethod<T> func) throws IOException; | ||
| /** | ||
| * 使用规则代理执行目标方法 | ||
| * @param resourceName 资源名称 | ||
| * @param func 目标方法 | ||
| * @return okhttp响应 | ||
| * @throws IOException IOException | ||
| */ | ||
| Response exec(String resourceName, DegradeProxyMethod<Response> func) throws IOException; | ||
|
|
||
| @FunctionalInterface | ||
| interface DegradeProxyMethod<R>{ | ||
|
|
||
17 changes: 0 additions & 17 deletions
17
src/main/java/com/github/lianjiatech/retrofit/spring/boot/degrade/DegradeStrategy.java
This file was deleted.
Oops, something went wrong.
89 changes: 89 additions & 0 deletions
89
.../com/github/lianjiatech/retrofit/spring/boot/degrade/Resilience4jDegradeRuleRegister.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,89 @@ | ||
| package com.github.lianjiatech.retrofit.spring.boot.degrade; | ||
|
|
||
| import java.io.IOException; | ||
| import java.time.Duration; | ||
| import java.util.List; | ||
| import java.util.Objects; | ||
| import java.util.concurrent.TimeUnit; | ||
|
|
||
| import io.github.resilience4j.circuitbreaker.CallNotPermittedException; | ||
| import io.github.resilience4j.circuitbreaker.CircuitBreaker; | ||
| import io.github.resilience4j.circuitbreaker.CircuitBreakerConfig; | ||
| import io.github.resilience4j.circuitbreaker.CircuitBreakerRegistry; | ||
| import io.github.resilience4j.core.StopWatch; | ||
| import okhttp3.Response; | ||
| import org.springframework.util.CollectionUtils; | ||
|
|
||
| /** | ||
| * @author [email protected] 2022/4/5 23:15 | ||
| */ | ||
| public class Resilience4jDegradeRuleRegister implements DegradeRuleRegister{ | ||
|
|
||
| private final CircuitBreakerRegistry circuitBreakerRegistry; | ||
|
|
||
| public Resilience4jDegradeRuleRegister(CircuitBreakerRegistry circuitBreakerRegistry) { | ||
| this.circuitBreakerRegistry = circuitBreakerRegistry; | ||
| } | ||
|
|
||
| @Override | ||
| public void batchRegister(List<RetrofitDegradeRule> ruleList) { | ||
| if (CollectionUtils.isEmpty(ruleList)){ | ||
| return; | ||
| } | ||
| for (RetrofitDegradeRule rule : ruleList) { | ||
| circuitBreakerRegistry.circuitBreaker(rule.getResourceName(), this.convert(rule)); | ||
| } | ||
|
|
||
| } | ||
|
|
||
| @Override | ||
| public Response exec(String resourceName, DegradeProxyMethod<Response> func) throws IOException { | ||
| CircuitBreaker circuitBreaker = circuitBreakerRegistry.circuitBreaker(resourceName); | ||
| System.out.println("当前断路器状态: "+ circuitBreaker.getState()); | ||
|
|
||
| final StopWatch stopWatch = StopWatch.start(); | ||
| try { | ||
| circuitBreaker.acquirePermission(); | ||
| final Response response = func.get(); | ||
| circuitBreaker.onResult(stopWatch.stop().toNanos(), TimeUnit.NANOSECONDS, response); | ||
| return response; | ||
| }catch (CallNotPermittedException e){ | ||
| throw new RetrofitBlockException(e); | ||
| } catch (Exception exception) { | ||
| circuitBreaker.onError(stopWatch.stop().toNanos(), TimeUnit.NANOSECONDS, exception); | ||
| throw exception; | ||
| } | ||
| } | ||
|
|
||
| private CircuitBreakerConfig convert(RetrofitDegradeRule rule){ | ||
| // add degrade rule | ||
| CircuitBreakerConfig.Builder circuitBreakerBuilder = CircuitBreakerConfig.from(newInstanceByDefault()); | ||
| if (Objects.nonNull(rule.getCount())){ | ||
| circuitBreakerBuilder.failureRateThreshold(rule.getCount()); | ||
| } | ||
| if (Objects.nonNull(rule.getTimeWindow())){ | ||
| circuitBreakerBuilder.slidingWindowSize(rule.getTimeWindow()); | ||
| } | ||
| return circuitBreakerBuilder.build(); | ||
| } | ||
|
|
||
| public CircuitBreakerConfig newInstanceByDefault(){ | ||
| // 断路器配置 | ||
| return CircuitBreakerConfig.custom() | ||
| // 滑动窗口的类型为时间窗口 | ||
| .slidingWindowType(CircuitBreakerConfig.SlidingWindowType.TIME_BASED) | ||
| // 时间窗口的大小为60秒 | ||
| .slidingWindowSize(60) | ||
| // 在单位时间窗口内最少需要10次调用才能开始进行统计计算 | ||
| .minimumNumberOfCalls(10) | ||
| // 在单位时间窗口内调用失败率达到60%后会启动断路器 | ||
| .failureRateThreshold(60) | ||
| // 允许断路器自动由打开状态转换为半开状态 | ||
| .enableAutomaticTransitionFromOpenToHalfOpen() | ||
| // 在半开状态下允许进行正常调用的次数 | ||
| .permittedNumberOfCallsInHalfOpenState(5) | ||
| // 断路器打开状态转换为半开状态需要等待60秒 | ||
| .waitDurationInOpenState(Duration.ofSeconds(60)) | ||
| .build(); | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.