SpringCloud 基礎教程(五) 服務熔斷機制(Eureka + Ribbon + Hystrix)
阿新 • • 發佈：2018-11-16
1、啟動【服務中心】叢集，即 Eureka Server
參考 SpringCloud 基礎教程(一) 服務中心及叢集(Eureka Server)
2、啟動【服務提供者】叢集，即 Eureka Client
參考 SpringCloud 基礎教程(二) 服務註冊及叢集(Eureka Client)
3、啟動【服務消費者】，即 Eureka Discovery Client
參考 SpringCloud 基礎教程(三) 服務發現及負載均衡(Eureka Discovery Client + Ribbon)
4、未加入熔斷機制，【服務提供者】出現問題，對【服務消費者】的影響
4.1、停掉【服務提供者】叢集中的其中一個服務。本例：停掉埠為 52602 這個服務。
4.2、開瀏覽器視窗，訪問 http://localhost:52610/ribbonInfo，多次重新整理該地址
呼叫 52601、52603 服務是正常的，但是呼叫52602服務的時候，出現了阻塞等待，並最終返回了紅框內的錯誤資訊。
假如這是正式的生產環境，訪問量很大的情況下，那麼就會有很多請求阻塞。這會造成【服務消費者】伺服器記憶體消耗陡增，導致應用崩潰。如果有其他應用需要【服務消費者】返回資源資訊，那麼呼叫【服務消費者】的應用也會出現阻塞。這就導致了連鎖反應，也就是所謂的雪崩。
所以，為了避免這種悲劇發生。順應而生的出現了熔斷保護機制。即：訪問不通時，要及時作出響應，而不是等待至超時。
5、修改【服務消費者】，加入熔斷機制
5.1、開啟工程：springcloud-eureka-ribbon
5.2、工程pom.xml檔案新增如下依賴：
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-hystrix</artifactId> </dependency>
5.3、修改工程啟動類中，添加註解 @EnableHystrix
package com.miniooc.eurekaribbon;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
/**
* EurekaRibbonApplication
* 應用程式啟動類，程式入口
*
* @author 宋陸
* @version 1.0.0
*/
@EnableHystrix // 啟用 hystrix 熔斷機制相關配置
@EnableDiscoveryClient // 啟用 Eureka 服務發現 相關配置
@SpringBootApplication
public class EurekaRibbonApplication {
public static void main(String[] args) {
SpringApplication.run(EurekaRibbonApplication.class, args);
}
}
5.4、修改服務消費者 Service 類, EurekaRibbonService
package com.miniooc.eurekaribbon.service;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
/**
* EurekaRibbonService
* 服務消費者服務類，呼叫服務提供者提供的服務，實現業務
*
* @author 宋陸
* @version 1.0.0
*/
@Service
public class EurekaRibbonService {
@Autowired
RestTemplate restTemplate;
@HystrixCommand(fallbackMethod = "getInfoFailure")
public String getInfo() {
String message;
try {
System.out.println("呼叫 服務 EUREKA-CLIENT/info");
message = restTemplate.getForObject("http://EUREKA-CLIENT/info", String.class);
System.out.println("服務 EUREKA-CLIENT/info 返回資訊 : " + message);
System.out.println("呼叫 服務 EUREKA-CLIENT/info 成功！");
} catch (Exception ex) {
message = ex.getMessage();
}
return message;
}
/**
* 服務 EUREKA-PROVIDER/hello 呼叫失敗的回撥方法
*
* @return
*/
public String getInfoFailure() {
String message = "呼叫 服務 EUREKA-PROVIDER/hello 失敗！";
return message;
}
}