在這里插入圖片描述

??各位小伙伴們大家好，歡迎來到這個小扎扎的spring cloud專欄，在這個系列專欄中我對B站尚硅谷陽哥的spring cloud教程進行一個總結，鑒于 看到就是學到、學到就是賺到 精神，這波依然是血賺 ┗|｀O′|┛

💡服務調用知識點速覽
🍹 Hystrix
🍸 初識Hystrix
🍷 Hystrix是什么？
🍹 Hystrix三大概念
🍸 服務降級(fallback)
🍷 fallback是什么？
🍷 服務提供方實現服務降級
🍷 服務調用方實現服務降級
🍷 服務降級優化
🍸 服務熔斷(break)
🍷 break是什么？
🍷 服務提供方實現服務熔斷
🍸 服務限流(flowlimit)
🍷 flowlimit是什么？
🍹 Hystrix圖形化監控

🍹 Hystrix

🍸 初識Hystrix

🍷 Hystrix是什么？

??Java應用程序講求“高內聚低耦合”，而spring cloud是一種微服務架構理念，將原來的一個應用程序拆分成許多微服務來調用，這樣的話就可以滿足“低耦合”的要求，但是隨之而來的就是“服務雪崩”問題。

??所謂的服務雪崩就是指，由于服務提供者不可用導致服務調用者不可用，并且在生產過程中，這種不可用逐漸擴大的現象。想要解決“服務雪崩”問題就需要用到Hystrix(豪豬)

??Hystrix是一個用于處理分布式系統的延遲和容錯的開源庫，在分布式系統里，許多依賴不可避免的會調用失敗，比如超時、異常等，Hystrix能夠保證在一個依賴出問題的情況下，不會導致整體服務失敗，避免級聯故障，以提高分布式系統的彈性。

??"斷路器”本身是一種開關裝置，當某個服務單元發生故障之后，通過斷路器的故障監控（類似熔斷保險絲)，向調用方返回一個符合預期的、可處理的備選響應（FallBack)，而不是長時間的等待或者拋出調用方無法處理的異常，這樣就保證了服務調用方的線程不會被長時間、不必要地占用，從而避免了故障在分布式系統中的蔓延，乃至雪崩。

🍹 Hystrix三大概念

🍸 服務降級(fallback)

🍷 fallback是什么？

??所謂的服務降級就是當服務出現程序運行異常、超時、服務熔斷觸發服務降級、線程池/信號量打滿等情況，此時應該返回一個符合預期的、可處理的備選響應(fallback)，以提高用戶的使用體驗而不是長時間的等待請求或者返回一個超時異常頁面。總而言之，當出現以上問題時，要有一個兜底方案來提高用戶的使用體驗

??服務降級的解決方案可以分為服務提供方和服務調用方，兩面都可以實現服務降級

🍷 服務提供方實現服務降級

??第一步： 對服務提供方的service接口方法進行加強，主要就是針對可能出現超時等異常情況的接口，新建方法對其進行兜底，如果原接口出現問題則使用兜底方案進行反饋
??使用@HystrixCommand注解的fallbackMethod屬性指定兜底方法名，使用commandProperties屬性的@HystrixProperty注解指定異常類型(超時異常和超時時間)

/*** 超時訪問，設置自身調用超時的峰值，峰值內正常運行，超過了峰值需要服務降級 自動調用fallbackMethod 指定的方法* 超時異常或者運行異常 都會進行服務降級* @param id* @return*/
@HystrixCommand(fallbackMethod = "paymentInfo_TimeOutHandler", commandProperties = {@HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "3000")
})
public String paymentInfoTimeOut(Integer id) {int second = 5;try {TimeUnit.SECONDS.sleep(second);} catch (InterruptedException e) {e.printStackTrace();}return "線程池:  " + Thread.currentThread().getName() + " paymentInfoTimeOut,id:  " + id + "\t"+ "O(∩_∩)O哈哈~" + "  耗時(秒): " + second;
}public String paymentInfo_TimeOutHandler(Integer id) {return "超時異常兜底方案！線程池:  " + Thread.currentThread().getName() + " paymentInfo_TimeOutHandler,id:  " + id + "\t";
}

??第二步： 服務提供方的主啟動類上使用@EnableCircuitBreaker注解開啟“熔斷器”，這樣的話前面的配置才能生效

@SpringBootApplication
@EnableEurekaClient
@EnableCircuitBreaker
public class HystrixPaymentMain8001 {public static void main(String[] args) {SpringApplication.run(HystrixPaymentMain8001.class, args);}
}

??除了上述可以自定義超時時間的異常，出現其他運行時異常也會調用兜底方案返回
在這里插入圖片描述

🍷 服務調用方實現服務降級

??第一步： 使用配置文件開啟hystrix

feign:hystrix:enabled: true

??第二步： 服務調用方的controller加強，新建方法對其進行兜底，使用方式與服務提供方一樣，主要就是服務調用方和服務提供方兩套方案，可以實現兩邊定制化。

@GetMapping("/payment/hystrix/timeout/{id}")
@HystrixCommand(fallbackMethod = "paymentTimeOutFallbackMethod", commandProperties = {@HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "1500")
})
public String paymentInfoTimeOut(@PathVariable("id") Integer id) {String result = paymentHystrixService.paymentInfoTimeOut(id);return result;
}public String paymentTimeOutFallbackMethod(@PathVariable("id") Integer id) {return "服務調用方兜底方案！我是消費者80,對方支付系統繁忙請10秒鐘后再試或者自己運行出錯請檢查自己,o(╥﹏╥)o";
}

??第三步： 服務調用方的主程序類上使用@EnableHystrix注解開啟hystrix

🍷 服務降級優化

解決冗余問題

??前面的每一個方法都對應一個兜底方案，這樣的話會顯得代碼十分臃腫，實際上很多的接口都可以使用一個兜底方案，于是我們就可以配置默認的兜底方案，在沒有使用@HystrixCommand注解指定的時候，類中的所有接口都會走默認兜底方案

??@DefaultProperties注解的defaultFallback屬性指定默認兜底方法，如果類中存在@HystrixCommand注解中不使用屬性指定特定兜底方案的情況，就說明這個接口使用是默認兜底方案

@RestController
@RequestMapping("consumer")
@Slf4j
@DefaultProperties(defaultFallback = "payment_Global_FallbackMethod")
public class OrderHystrixController {@Resourceprivate PaymentHystrixService paymentHystrixService;@HystrixCommand@GetMapping("/payment/hystrix/ex/{id}")public String paymentInfoException(@PathVariable("id") Integer id) {int age = 10/0;String result = paymentHystrixService.paymentInfoException(id);return result;}/*** hystrix 全局fallback方法* @return*/public String payment_Global_FallbackMethod() {return "Global異常處理信息，請稍后再試，/(ㄒoㄒ)/~~";}
}

解決耦合問題

??上述操作中，原方案和兜底方案都在controller中定義，想要解決這個耦合問題可以使用一個類實現service接口，然后重寫所有的接口方法，然后使用service接口上@FeignClient注解的fallback屬性指定接口的實現類為兜底類

@Component
@FeignClient(value = "CLOUD-PROVIDER-HYSTRIX-PAYMENT", fallback = PaymentFallbackService.class)
public interface PaymentHystrixService {@GetMapping("/payment/hystrix/ok/{id}")String paymentInfoOK(@PathVariable("id") Integer id);@GetMapping("/payment/hystrix/timeout/{id}")String paymentInfoTimeOut(@PathVariable("id") Integer id);@GetMapping("/payment/hystrix/ex/{id}")String paymentInfoException(Integer id);
}

@Component
public class PaymentFallbackService implements PaymentHystrixService {@Overridepublic String paymentInfoOK(Integer id) {return "-----PaymentFallbackService fall back-paymentInfo_OK ,o(╥﹏╥)o";}@Overridepublic String paymentInfoTimeOut(Integer id) {return "-----PaymentFallbackService fall back-paymentInfo_TimeOut ,o(╥﹏╥)o";}@Overridepublic String paymentInfoException(Integer id) {return "-----PaymentFallbackService fall back-paymentInfoException ,o(╥﹏╥)o";}}

🍸 服務熔斷(break)

🍷 break是什么？

??微服務鏈路中某個微服務的請求達到最大訪問之后，直接拒絕訪問，然后調用服務降級的方法返回友好的提示；當檢測到該節點微服務調用響應正常之后，還可以恢復鏈路的正常調用。hystrix會默認在服務5秒內調用失敗20次后觸發熔斷機制，但是也可以使用配置對其進行修改。

🍷 服務提供方實現服務熔斷

??首先service層使用注解配置服務熔斷的相關值和熔斷時的備選方案，就以下代碼為例：在10S的時間窗口期中，10次請求中失敗率達到60%就會觸發熔斷啟動備選方案。

??如果在10S的時間窗口期中，請求次數不足10次，那么根本就不可能觸發熔斷器。當熔斷器開啟后所有的請求都不會被轉發，一段時間窗口期之后(默認5秒，可以自定義配置)斷路器切換為半開狀態，此時會讓其中一個請求進行轉發，成功則關閉斷路器，反之繼續開啟

@HystrixCommand(fallbackMethod = "paymentCircuitBreakerFallback", commandProperties = {@HystrixProperty(name = "circuitBreaker.enabled", value = "true"),/* 是否開啟斷路器*/@HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "10"),// 請求次數@HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value = "10000"), // 時間窗口期@HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "60"),// 失敗率達到多少后跳閘
})
public String paymentCircuitBreaker(Integer id) {if (id < 0) {throw new RuntimeException("******id 不能負數");}String serialNumber = IdUtil.simpleUUID();return Thread.currentThread().getName() + "\t" + "調用成功，流水號: " + serialNumber;
}public String paymentCircuitBreakerFallback(Integer id) {return Thread.currentThread().getName() + "\t" + "id 不能負數或超時或自身錯誤，請稍后再試，/(ㄒoㄒ)/~~   id: " + id;
}

??controller中調用service方法

@GetMapping("/circuit/{id}")
public String paymentCircuitBreaker(@PathVariable("id") Integer id) {String result = paymentService.paymentCircuitBreaker(id);log.info("****result: " + result);return result;
}

🍸 服務限流(flowlimit)

🍷 flowlimit是什么？

??在秒殺等高并發的操作下，為了防止大量請求一塊發送過來，采用排隊的方式，把請求按照順序排隊發送過來。由于hystrix已經停止更新，而且Alibaba的sentinel在進行服務限流的處理時比hystrix更加優秀，所以說這一部分知識可以放在后面進行學習。

🍹 Hystrix圖形化監控

??第一步： 新建一個模塊用于監控，導入相關依賴

<dependencies><!--最主要的依賴，用于引入圖形化dashboard--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId></dependency><!-- 引入自己定義的api通用包 --><dependency><groupId>com.xiaochen</groupId><artifactId>cloud-api-commons</artifactId><version>${project.version}</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency>
</dependencies>

??第一步： 配置文件配置端口號

server:port: 9001

??第三步： 主啟動類開啟HystrixDashboard，

@SpringBootApplication
@EnableHystrixDashboard
public class HystrixDashboardMain9001 {public static void main(String[] args) {SpringApplication.run(HystrixDashboardMain9001.class, args);}
}

??此外，所有的服務提供方也就是被監控的服務都要引入spring-boot-starter-actuator依賴，表示自己可以受監控。然后就是在服務的主啟動類上要使用以下代碼中的addUrlMappings配置受監控的路徑

/*** 注意：新版本Hystrix需要在主啟動類中指定監控路徑* 此配置是為了服務監控而配置，與服務容錯本身無關，spring cloud升級后的坑* ServletRegistrationBean因為springboot的默認路徑不是"/hystrix.stream"，* 只要在自己的項目里配置上下面的servlet就可以了** @return ServletRegistrationBean*/
@Bean
public ServletRegistrationBean getServlet() {HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet);// 一啟動就加載registrationBean.setLoadOnStartup(1);// 添加urlregistrationBean.addUrlMappings("/hystrix.stream");// 設置名稱registrationBean.setName("HystrixMetricsStreamServlet");return registrationBean;
}