SpringCloud2.0 Hystrix Feign 基於Feign實現斷路器 基礎教程(七)
阿新 • • 發佈:2018-11-22
1、啟動【服務中心】叢集,工程名:springcloud-eureka-server
參考 SpringCloud2.0 Eureka Server 服務中心 基礎教程(二)
2、啟動【服務提供者】叢集,工程名:springcloud-eureka-client
參考 SpringCloud2.0 Eureka Client 服務註冊 基礎教程(三)
3、啟動【服務消費者】,工程名:springcloud-eureka-feign
參考 SpringCloud2.0 Feign 服務發現 基礎教程(五)
4、未加入熔斷機制,【服務提供者】出現問題,對【服務消費者】的影響
4.1、停掉【服務提供者】叢集中的其中一個服務。本例:停掉埠為 52602 這個服務。
4.2、開啟瀏覽器,訪問 http://localhost:52620/feignInfo,多次重新整理該地址
呼叫 52601、52603 服務是正常的,但是呼叫52602服務的時候,出現了阻塞等待,並最終返回了紅框內的錯誤資訊。
假如這是正式的生產環境,訪問量很大的情況下,那麼就會有很多請求阻塞。這會造成【服務消費者】伺服器記憶體消耗陡增,導致應用崩潰。如果有其他應用需要【服務消費者】返回資源資訊,那麼呼叫【服務消費者】的應用也會出現阻塞。這就導致了連鎖反應,也就是所謂的雪崩。
所以,為了避免這種悲劇發生。順應而生的出現了熔斷保護機制。即:訪問不通時,要及時作出響應,而不是等待至超時。
5、修改【服務消費者】,加入熔斷機制
5.1、開啟工程:springcloud-eureka-feign
5.2、修改工程 pom.xml 檔案,追加 Hystrix 依賴,新增如下內容:
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-hystrix</artifactId> </dependency>
5.3、修改工程啟動類,添加註解 @EnableHystrix
package com.miniooc.eurekafeign; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.cloud.netflix.hystrix.EnableHystrix; import org.springframework.cloud.openfeign.EnableFeignClients; /** * EurekaFeignApplication * 應用程式啟動類,程式入口 * * @author 宋陸 * @version 1.0.0 */ @EnableHystrix // Feign預設是開啟,這個註解可以不加的 @EnableDiscoveryClient // 啟用 Eureka 服務發現 @EnableFeignClients // 啟用 Feign @SpringBootApplication public class EurekaFeignApplication { public static void main(String[] args) { SpringApplication.run(EurekaFeignApplication.class, args); } }
5.4、修改【服務消費者】服務類, EurekaFeignService,追加 fallback 配置
package com.miniooc.eurekafeign.service; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.stereotype.Service; import org.springframework.web.bind.annotation.RequestMapping; /** * EurekaFeignService * 服務消費者,呼叫服務提供者提供的服務,實現業務 * * @author 宋陸 * @version 1.0.0 */ @FeignClient(value = "EUREKA-CLIENT", fallback = EurekaFeignServiceFailure.class) // 呼叫的服務的名稱 public interface EurekaFeignService { @RequestMapping(value = "/info") String getInfo(); }
5.5、新增【服務消費者】服務呼叫失敗,回撥處理類,EurekaFeignServiceFailure
package com.miniooc.eurekafeign.service; import org.springframework.stereotype.Service; /** * EurekaFeignServiceFailure * 服務消費者,呼叫服務提供者提供的服務失敗,回撥處理類 * * @author 宋陸 * @version 1.0.0 */ @Service public class EurekaFeignServiceFailure implements EurekaFeignService { @Override public String getInfo() { String message = "網路繁忙,請稍後再試-_-。PS:服務消費者自己提供的資訊"; return message; } }
5.6、修改工程配置檔案 application.yml, 開啟 hystrix,追加如下配置
feign: hystrix: enabled: true
6、加入熔斷機制後,【服務提供者】出現問題,對【服務消費者】的影響
6.1、重啟【服務提供者】叢集,重啟【服務消費者】
6.2、停掉【服務提供者】叢集中的其中一個服務。本例:停掉埠為 52602 這個服務。
6.3、開啟瀏覽器,訪問 http://localhost:52620/feignInfo,多次重新整理該地址
呼叫 52601、52603 服務是正常的,呼叫52602服務的時候,沒有出現阻塞等待,而是返回了【服務消費者】自己提供的返回資訊
【服務消費者】加入熔斷機制結束