Hystrix說明與入門例項
阿新 • • 發佈：2019-02-10
一、Hystrix說明1.服務雪崩效應：是一種因 服務提供者 的不可用導致 服務呼叫者 的不可用,並將不可用 逐漸放大 的過程。1) A為服務提供者, B為A的服務呼叫者, C和D是B的服務呼叫者. 當A的不可用,引起B的不可用,並將不可用逐漸放大C和D時, 服務雪崩就形成了2.雪崩原因：1) 服務提供者不可用a.硬體故障a1.硬體損壞造成的伺服器主機宕機a2.網路硬體故障造成的服務提供者的不可訪問b.程式Bugc.快取擊穿：快取應用重啟, 所有快取被清空時,以及短時間內大量快取失效時. 大量的快取不命中, 使請求直擊後端,造成服務提供者超負荷執行,引起服務不可用d.使用者大量請求：在秒殺和大促開始前,如果準備不充分,使用者發起大量請求造成服務提供者的不可用
6)service impl層：建立回撥類
2)controller層：
# Hystrix配置：Feign中已經依賴了Hystrix，所以在maven配置上不用做任何改動 feign: hystrix: enabled: true3)**Appliaction.java啟動類：@EnableFeignClients //開啟feigin註解@EnableCircuitBreaker //開啟Hystrix@EnableDiscoveryClient //開啟註冊中心@SpringBootApplication //spring-boot啟動注：還可用@SpringCloudApplication代替，@SpringCloudApplication包括以下註解： @Target({ElementType.TYPE}@Retention(RetentionPolicy.RUNTIME)@Documented@Inherited@SpringBootApplication@EnableDiscoveryClient@EnableCircuitBreaker
@Bean @LoadBalanced public RestTemplate restTemplate() { //用於呼叫"提供者"的方法 return new RestTemplate(); }4)controller層：
@GetMapping("/order/{userId}/{orderNo}") public String findOrder(@PathVariable Long userId, @PathVariable String orderNo) throws InterruptedException { return userConsumerService.findOrder(userId,orderNo); }5)service層：新增fallback屬性
String findOrder(Long userId,String orderNo) throws InterruptedException;
6)service impl層：建立回撥類
@HystrixCommand(fallbackMethod = "findOrderFallback", commandProperties = { //timeoutInMilliseconds 使用執行緒隔離時，呼叫超時時間 @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "1000") }) public String findOrder(Long userId,String orderNo) throws InterruptedException { Random random = new Random(); sleepRandom = random.nextInt(2000); System.out.println("sleepRandom="+sleepRandom); Thread.sleep(sleepRandom); ConsumerBeehiveUser user = findById(userId); if (user != null) { return user.getUsername() + " 的訂單" + orderNo + " 找到啦！sleepRandom="+sleepRandom; } return "使用者不存在！sleepRandom="+sleepRandom; } public String findOrderFallback(Long userId, String orderNo) { return "訂單查詢失敗！sleepRandom="+sleepRandom; }7)檢視hystrix狀態：a.檢視hystrix基本情況：http://localhost:8002/healthb.檢視hystrix詳情：http://localhost:8002/hystrix.stream8)引數說明：a.快照時間窗:斷路器確定是否開啟需要統計一些請求和錯誤資料，而統計的時間範圍就是快照時間窗，預設為最近的10秒。b.請求總數下限：在快照時間窗內，必須滿足請求總數下限才有資格根據熔斷。預設為20，意味著在10秒內，如果該hystrix命令的呼叫此時不足20次，即使所有的請求都超時或其他原因失敗，斷路器都不會開啟。c.錯誤百分比下限：當請求總數在快照時間窗內超過了下限，比如發生了30次呼叫，如果在這30次呼叫中，有16次發生了超時異常，也就是超過50%的錯誤百分比，在預設設定50%下限情況下，這時候就會將斷路器開啟。注：fallback是降級處理2.隔離：1)*Application：
@SpringBootApplication @EnableDiscoveryClient //開啟eureka服務 @EnableFeignClients //開啟feigin註解 @EnableCircuitBreaker //開啟Hystrix @EnableCircuitBreaker或@EnableHystrix @EnableHystrixDashboard //開啟dashboard圖形監控 public class ConsumerBeehiveApplication { @Bean @LoadBalanced public RestTemplate restTemplate() { //用於呼叫"提供者"的方法 return new RestTemplate(); } public static void main(String[] args) { SpringApplication.run(ConsumerBeehiveApplication.class, args); } }
2)controller層：
@GetMapping("/testCircuitBreaker/{id}") public String testCircuitBreaker(@PathVariable int id) { StringBuilder sb = new StringBuilder(); for(int i = 0; i < 50; i++) { String result = userConsumerService.testCircuitBreaker(i); System.out.println("testCircuitBreaker controller："+result); sb.append(result).append("\n"); } return sb.toString(); }3)service層：
String testCircuitBreaker(int id);4)service impl層：
@HystrixCommand(fallbackMethod = "testCircuitBreakerFallback", commandProperties = { //errorThresholdPercentage 斷路器錯誤請求百分比 @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "50") }) public String testCircuitBreaker(int id) { if(id % 2 == 0 && id < 10) { // 直接返回 return "consumer testCircuitBreaker "+id; } else { // 無限迴圈模擬超時 int j = 0; while (true) { j++; } } } public String testCircuitBreakerFallback(int id) { String template = restTemplate.getForObject("http://provider-user/user/testCircuitBreaker/"+id, String.class); return "fallback："+template; }