<!--resilience4j-circuitbreaker-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-circuitbreaker-resilience4j</artifactId>
</dependency>
<!-- 由于斷路保護(hù)等需要AOP實(shí)現(xiàn)，所以必須導(dǎo)入AOP包 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-aop</artifactId>
</dependency>

spring:
  application:
    name: cloud-consumer-openfeign-order
  ####Spring Cloud Consul for Service Discovery
  cloud:
    consul:
      host: localhost
      port: 8500
      discovery:
        prefer-ip-address: true #優(yōu)先使用服務(wù)ip進(jìn)行注冊(cè)
        service-name: ${spring.application.name}
    openfeign:
      # 開啟circuitbreaker和分組激活 spring.cloud.openfeign.circuitbreaker.enabled
      circuitbreaker:
        enabled: true
        group:
          enabled: true #沒開分組永遠(yuǎn)不用分組的配置。精確優(yōu)先、分組次之(開了分組)、默認(rèn)最后
# Resilience4j CircuitBreaker 按照次數(shù)：COUNT_BASED 的例子
#  6次訪問中當(dāng)執(zhí)行方法的失敗率達(dá)到50%時(shí)CircuitBreaker將進(jìn)入開啟OPEN狀態(tài)(保險(xiǎn)絲跳閘斷電)拒絕所有請(qǐng)求。
#  等待5秒后，CircuitBreaker 將自動(dòng)從開啟OPEN狀態(tài)過渡到半開HALF_OPEN狀態(tài)，允許一些請(qǐng)求通過以測試服務(wù)是否恢復(fù)正常。
#  如還是異常CircuitBreaker 將重新進(jìn)入開啟OPEN狀態(tài)；如正常將進(jìn)入關(guān)閉CLOSE閉合狀態(tài)恢復(fù)正常處理請(qǐng)求。
resilience4j:
  circuitbreaker:
    configs:
      default:
        failureRateThreshold: 50 #設(shè)置50%的調(diào)用失敗時(shí)打開斷路器，超過失敗請(qǐng)求百分?CircuitBreaker變?yōu)镺PEN狀態(tài)。
		slidingWindowType: COUNT_BASED # 滑動(dòng)窗口的類型
		slidingWindowSize: 6 #滑動(dòng)窗?的??配置COUNT_BASED表示6個(gè)請(qǐng)求，配置TIME_BASED表示6秒
		minimumNumberOfCalls: 6 #斷路器計(jì)算失敗率或慢調(diào)用率之前所需的最小樣本(每個(gè)滑動(dòng)窗口周期)。如果minimumNumberOfCalls為10，則必須最少記錄10個(gè)樣本，然后才能計(jì)算失敗率。如果只記錄了9次調(diào)用，即使所有9次調(diào)用都失敗，斷路器也不會(huì)開啟。
		automaticTransitionFromOpenToHalfOpenEnabled: true # 是否啟用自動(dòng)從開啟狀態(tài)過渡到半開狀態(tài)，默認(rèn)值為true。如果啟用，CircuitBreaker將自動(dòng)從開啟狀態(tài)過渡到半開狀態(tài)，并允許一些請(qǐng)求通過以測試服務(wù)是否恢復(fù)正常
		waitDurationInOpenState: 5s #從OPEN到HALF_OPEN狀態(tài)需要等待的時(shí)間
		permittedNumberOfCallsInHalfOpenState: 2 #半開狀態(tài)允許的最大請(qǐng)求數(shù)，默認(rèn)值為10。在半開狀態(tài)下，CircuitBreaker將允許最多permittedNumberOfCallsInHalfOpenState個(gè)請(qǐng)求通過，如果其中有任何一個(gè)請(qǐng)求失敗，CircuitBreaker將重新進(jìn)入開啟狀態(tài)。
		recordExceptions:
          - java.lang.Exception
    instances:
      cloud-payment-service:
        baseConfig: default

@RestController
public class OrderCircuitController{
    @Resource
    private PayFeignApi payFeignApi;
    @GetMapping(value = "/feign/pay/circuit/{id}")
    @CircuitBreaker(name = "cloud-payment-service", fallbackMethod = "myCircuitFallback")
    public String myCircuitBreaker(@PathVariable("id") Integer id){
        return payFeignApi.myCircuit(id);
    }
    //myCircuitFallback就是服務(wù)降級(jí)后的兜底處理方法
    public String myCircuitFallback(Integer id,Throwable t) {
        // 這里是容錯(cuò)處理邏輯，返回備用結(jié)果
        return "myCircuitFallback，系統(tǒng)繁忙，請(qǐng)稍后再試-----/(ㄒoㄒ)/~~";
    }
}

spring:
  application:
    name: cloud-consumer-openfeign-order
  ####Spring Cloud Consul for Service Discovery
  cloud:
    consul:
      host: localhost
      port: 8500
      discovery:
        prefer-ip-address: true #優(yōu)先使用服務(wù)ip進(jìn)行注冊(cè)
        service-name: ${spring.application.name}
    openfeign:
      # 開啟circuitbreaker和分組激活 spring.cloud.openfeign.circuitbreaker.enabled
      circuitbreaker:
        enabled: true
        group:
          enabled: true #沒開分組永遠(yuǎn)不用分組的配置。精確優(yōu)先、分組次之(開了分組)、默認(rèn)最后
# Resilience4j CircuitBreaker 按照時(shí)間：TIME_BASED 的例子
resilience4j:
  timelimiter:
    configs:
      default:
        timeout-duration: 10s #神坑的位置，timelimiter 默認(rèn)限制遠(yuǎn)程1s，超于1s就超時(shí)異常，配置了降級(jí)，就走降級(jí)邏輯
  circuitbreaker:
    configs:
      default:
        failureRateThreshold: 50 #設(shè)置50%的調(diào)用失敗時(shí)打開斷路器，超過失敗請(qǐng)求百分?CircuitBreaker變?yōu)镺PEN狀態(tài)。
        slowCallDurationThreshold: 2s #慢調(diào)用時(shí)間閾值，高于這個(gè)閾值的視為慢調(diào)用并增加慢調(diào)用比例。
        slowCallRateThreshold: 30 #慢調(diào)用百分比峰值，斷路器把調(diào)用時(shí)間?于slowCallDurationThreshold，視為慢調(diào)用，當(dāng)慢調(diào)用比例高于閾值，斷路器打開，并開啟服務(wù)降級(jí)
        slidingWindowType: TIME_BASED # 滑動(dòng)窗口的類型
        slidingWindowSize: 2 #滑動(dòng)窗口的大小配置，配置TIME_BASED表示2秒
        minimumNumberOfCalls: 2 #斷路器計(jì)算失敗率或慢調(diào)用率之前所需的最小樣本(每個(gè)滑動(dòng)窗口周期)。
        permittedNumberOfCallsInHalfOpenState: 2 #半開狀態(tài)允許的最大請(qǐng)求數(shù)，默認(rèn)值為10。
        waitDurationInOpenState: 5s #從OPEN到HALF_OPEN狀態(tài)需要等待的時(shí)間
        recordExceptions:
          - java.lang.Exception
    instances:
      cloud-payment-service:
        baseConfig: default

<!--resilience4j-bulkhead-->
<dependency>
    <groupId>io.github.resilience4j</groupId>
    <artifactId>resilience4j-bulkhead</artifactId>
</dependency>

####resilience4j bulkhead 的例子
resilience4j:
  bulkhead:
    configs:
      default:
        maxConcurrentCalls: 2 # 隔離允許并發(fā)線程執(zhí)行的最大數(shù)量
        maxWaitDuration: 1s # 當(dāng)達(dá)到并發(fā)調(diào)用數(shù)量時(shí)，新的線程的阻塞時(shí)間，我只愿意等待1秒，過時(shí)不候進(jìn)艙壁兜底fallback
    instances:
      cloud-payment-service:
        baseConfig: default
  timelimiter:
    configs:
      default:
        timeout-duration: 20s

@GetMapping(value = "/feign/pay/bulkhead/{id}")
@Bulkhead(name = "cloud-payment-service",fallbackMethod = "myBulkheadFallback",type = Bulkhead.Type.SEMAPHORE)
public String myBulkhead(@PathVariable("id") Integer id){
    return payFeignApi.myBulkhead(id);
}
public String myBulkheadFallback(Throwable t){
    return "myBulkheadFallback，隔板超出最大數(shù)量限制，系統(tǒng)繁忙，請(qǐng)稍后再試-----/(ㄒoㄒ)/~~";
}

####resilience4j bulkhead -THREADPOOL的例子
resilience4j:
  timelimiter:
    configs:
      default:
        timeout-duration: 10s #timelimiter默認(rèn)限制遠(yuǎn)程1s，超過報(bào)錯(cuò)不好演示效果所以加上10秒
  thread-pool-bulkhead:
    configs:
      default:
        core-thread-pool-size: 1
        max-thread-pool-size: 1
        queue-capacity: 1
    instances:
      cloud-payment-service:
        baseConfig: default
# spring.cloud.openfeign.circuitbreaker.group.enabled 請(qǐng)?jiān)O(shè)置為false 新啟線程和原來主線程脫離

@GetMapping(value = "/feign/pay/bulkhead/{id}")
@Bulkhead(name = "cloud-payment-service",fallbackMethod = "myBulkheadPoolFallback",type = Bulkhead.Type.THREADPOOL)
public CompletableFuture<String> myBulkheadTHREADPOOL(@PathVariable("id") Integer id){
    System.out.println(Thread.currentThread().getName()+"\t"+"enter the method!!!");
    try { TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) { e.printStackTrace(); }
    System.out.println(Thread.currentThread().getName()+"\t"+"exist the method!!!");
    return CompletableFuture.supplyAsync(() -> payFeignApi.myBulkhead(id) + "\t" + " Bulkhead.Type.THREADPOOL");
}
public CompletableFuture<String> myBulkheadPoolFallback(Integer id,Throwable t){
    return CompletableFuture.supplyAsync(() -> "Bulkhead.Type.THREADPOOL，系統(tǒng)繁忙，請(qǐng)稍后再試-----/(ㄒoㄒ)/~~");
}

<!--resilience4j-ratelimiter-->
<dependency>
    <groupId>io.github.resilience4j</groupId>
    <artifactId>resilience4j-ratelimiter</artifactId>
</dependency>

####resilience4j ratelimiter 限流的例子
resilience4j:
  ratelimiter:
    configs:
      default:
        limitForPeriod: 2 #在一次刷新周期內(nèi)，允許執(zhí)行的最大請(qǐng)求數(shù)
        limitRefreshPeriod: 1s # 限流器每隔limitRefreshPeriod刷新一次，將允許處理的最大請(qǐng)求數(shù)量重置為limitForPeriod
        timeout-duration: 1 # 線程等待權(quán)限的默認(rèn)等待時(shí)間
    instances:
      cloud-payment-service:
        baseConfig: default

@GetMapping(value = "/feign/pay/ratelimit/{id}")
@RateLimiter(name = "cloud-payment-service",fallbackMethod = "myRatelimitFallback")
public String myBulkhead(@PathVariable("id") Integer id){
    return payFeignApi.myRatelimit(id);
}
public String myRatelimitFallback(Integer id,Throwable t){
    return "你被限流了，禁止訪問/(ㄒoㄒ)/~~";
}