在服務端 cloud-provider-hystrix-payment8001 進行演示。 <br/> **1. 在需要熔斷的方法上標注注解`@HystrixCommand`** ```java /** * @DefaultProperties注解可以為當前類提供一個通用的異常處理方法 * 當注解 @HystrixCommand(fallbackMethod ="..")沒有指定具體的 fallbackMethod 時 * 發生異常時就會調用 defaultFallback 指定的方法進行后續處理。 */ @DefaultProperties(defaultFallback = "paymentGlobalFallback") @Service public class PaymentServiceImpl implements PaymentService { @Override @HystrixCommand( //當調用方法paymentCircuitBreaker失敗，則會調用方法paymentCircuitBreakerFallback進行后續處理 fallbackMethod = "paymentCircuitBreakerFallback" , commandProperties = { //true：開啟斷路器 @HystrixProperty(name = "circuitBreaker.enabled", value = "true"), //當請求次數超過10次時才進行熔斷 @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "10"), //時間窗口期為10000ms @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value = "10000"), //失敗率達到%60后跳閘 @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "60"), }) public String paymentCircuitBreaker(Integer id) { if (id < 0) { throw new RuntimeException("id不能為負數！"); } String simpleUUID = IdUtil.simpleUUID(); return Thread.currentThread().getName() + "，" + "成功調用，流水號是：" + simpleUUID; } /** * 該方法的參數列表要與方法paymentCircuitBreaker一模一樣。 */ public String paymentCircuitBreakerFallback(Integer id) { return "id不能為負數，請稍后再試...，id=" + id; } public String paymentGlobalFallback() { return "payment server exception!"; } } ``` **2. 測試效果** 每次調用失敗就會執行方法`paymentCircuitBreakerFallback`，而不是執行業務方法`paymentCircuitBreaker`。如果在10000ms的時間內，調用方法`paymentCircuitBreaker`有超過60%比例調用失敗，那么在5s的時間窗口內，即使訪問正確也不會調用業務方法`paymentCircuitBreaker`，只有超過5s的時間窗口并且也是正確訪問時才會被正確調用。 <br/> **斷路器開啟或關閉的條件如下：** * 開啟的條件：當滿足下面兩個條件之一斷路器就會開啟。 * （1）當達到一定的閾值的時候(默認10秒鐘超過20個請求次數)。 * （2）當失敗率達到一定的時候(默認10秒內超過50%的請求次數)。 * 關閉條件：斷路器開啟之后(默認5秒)，這個時候斷路器是半開狀態，會讓其他一個請求進行轉發，如果成功，斷路器會關閉；若失敗，繼續開啟。