架構師入門：Spring Cloud系列，Hystrix與Eureka的整合

Eureka Hystrix · 發表 2018-10-30 07:24:00

摘要：和Ribbon等元件一樣，在專案中，Hystrix一般不會單獨出現，而是會和Eureka等元件配套出現。在Hystrix和Eureka整合後的框架裡，一般會用到Hystrix的斷路器以及合併請求等特性，而在Web框架裡，大多會有專門的快取元件，所以不怎麼會用到Hystrix的快取特性。 1...

和Ribbon等元件一樣，在專案中，Hystrix一般不會單獨出現，而是會和Eureka等元件配套出現。在Hystrix和Eureka整合後的框架裡，一般會用到Hystrix的斷路器以及合併請求等特性，而在Web框架裡，大多會有專門的快取元件，所以不怎麼會用到Hystrix的快取特性。

1 準備Eureka伺服器專案

HystrixEurekaServer專案承擔著Eureka伺服器的作用，這部分的程式碼關鍵點如下。

第一，在pom.xml裡，通過如下關鍵程式碼引入Eureka伺服器元件的依賴包。

1<dependency>
2<groupId>org.springframework.cloud</groupId>
3<artifactId>spring-cloud-starter-eureka-server</artifactId>
4</dependency>

第二，在application.yml裡，指定了本專案的主機名和埠號，並指定了對外提供eureka服務的Url路徑，程式碼如下。

1server:
2port: 8888
3eureka:
4instance:
5hostname: localhost
6client:
7register-with-eureka: false
8fetch-registry: false 
9serviceUrl:
10defaultZone: http://localhost:8888/eureka/

第三，在ServerStarter.java裡，編寫啟動Eureka服務的程式碼，這裡請注意，在第2和第3行裡，通過註解聲明瞭本類是Eureka伺服器的啟動類。

1//省略必要的package和import的程式碼
2@EnableEurekaServer
3@SpringBootApplication
4public class ServerStarter 
5{
6public static void main( String[] args )
7{SpringApplication.run(ServerStarter.class, args);}
}

2 服務提供者的程式碼結構

HystrixEurekaserviceProvider專案承擔著Eureka服務提供者的角色。在pom.xml裡，我們除了指定Eureka的依賴包以外，還了指定了Hystrix的依賴包，關鍵程式碼如下。其中，前4行指定的是Eureka的依賴包，後4行指定的是Hystrix的依賴包。

1<dependency>
2<groupId>org.springframework.cloud</groupId>
3<artifactId>spring-cloud-starter-eureka</artifactId>
4</dependency>
5<dependency>
6<groupId>org.springframework.cloud</groupId>
7<artifactId>spring-cloud-starter-hystrix</artifactId>
8</dependency>

而在application.yml裡，指定了本專案的服務埠是1111，對外提供的專案名是hystrixEureka，以及是向第一部分指定的Eureka伺服器註冊，程式碼如下。

1server:
2port: 1111
3spring:
4application:
5name: hystrixEureka
6eureka:
7client:
8serviceUrl:
9defaultZone: http://localhost:8888/eureka/

3 在服務提供者專案裡引入斷路器機制

在服務提供者的啟動類ServiceProviderApp.java裡，我們是通過加入@EnableCircuitBreaker註解來啟動斷路器，程式碼如下。

1//省略必要的package和import程式碼
2@SpringBootApplication
3@EnableEurekaClient
4@EnableCircuitBreaker
5@ServletComponentScan
6public class ServiceProviderApp 
7{
8public static void main( String[] args )
9{SpringApplication.run(ServiceProviderApp.class, args);}
10}

在Controller.java這個控制器類裡，我們是在第9行裡，通過呼叫service類提供的方法來返回具體的OrderDetail資訊，程式碼如下。

1//省略必要的package和import程式碼
2@RestController
3public class Controller {
4@Autowired
5private OrderDetailService service;
6//對外提供服務的getOrderDetailById方法 
7@RequestMapping(value = "/getOrderDetailById/{orderId}", method = RequestMethod.GET)
8public OrderDetail getOrderDetailById(@PathVariable("orderId")String orderId) throws Exception {
9return service.getOrderDetailByID(orderId);
10}
11}

在OrderDetailService.java裡，我們用HashMap這個資料結構來模擬資料庫，以此來模擬從資料庫讀OrderDetail的方式，提供了“根據ID找相應物件的服務”，程式碼如下。

1//省略必要的package和import程式碼
2@Service
3public class OrderDetailService {
4static HashMap<String,String> orderDB = new HashMap<String,String> ();
5static //通過static程式碼，模擬資料庫中儲存的OrderDetail資訊
6{
7orderDB.put("1","Peter");
8orderDB.put("2","Tom");
9orderDB.put("3","Mike");
10}
11//在方法之前，通過註解引入Hystrix，並指定回退方法
12@HystrixCommand(fallbackMethod = "getFallback")
13public OrderDetail getOrderDetailByID(String id) throws Exception
14{
15OrderDetail orderDetail = new OrderDetail();
16if("error".equals(id) ) //如果輸入是error，則故意丟擲異常
17{throw new Exception(); }
18//模擬地從資料庫裡得到資訊並返回
19orderDetail.setOrderId(id);
20orderDetail.setOrderOwner(orderDB.get(id));
21return orderDetail;
22}
23//定義Hystrix的回退方法
24public OrderDetail getFallback(String orderId) {
25OrderDetail orderDetail = new OrderDetail();
26orderDetail.setOrderId("error");
27orderDetail.setOrderOwner("error");
28System.out.println("In fallbackForOrderDetail function");
29return orderDetail;
30}
31}

在第13行的getOrderDetailByID方法之前，我們在第12行通過fallbackMethod定義了回退方法，在這個方法的第16行裡，我們定義瞭如果輸入是error，那麼則將丟擲異常，以此觸發回退方法getFallback。而在第24行定義的回退方法裡，我們將返回一個ID和Owner都是error的OrderDetail物件。本類用到的OrderDetail模型類定義如下。

1public class OrderDetail{
2private String orderId;//訂單id
3private String orderOwner; //訂單所有人 
4//省略必要的get和set方法
5}

至此我們完成了開發工作，啟動HystrixEurekaServer和HystrixEurekaserviceProvider後，如果在瀏覽器中輸入ofollow,noindex" target="_blank">http://localhost:1111/getOrderDetailById/1 ，能看到如下的輸出，這說明走的是正常的流程。

{"orderId":"1","orderOwner":"Peter"}

但如果輸入的是http://localhost:1111/getOrderDetailById/error ，那麼會在OrderDetailService類的getOrderDetailByID方法裡丟擲異常，從而走Hystrix的回退流程，由此會輸入如下的語句。

{"orderId":"error","orderOwner":"error"}

在這個案例中，我們是在“提供者服務”的模組引入hytrix斷路器，而不是在“服務呼叫”模組，這和專案中的常規做法相符，因為啟動斷路器的場景一般是“提供服務模組的流量超載”。

本人之前寫的和本文有關的Spring Cloud其它相關文章。

JavaArchitect/p/9557991.html" rel="nofollow,noindex" target="_blank">Hystrix針對不可用服務的保護機制以及引入快取

通過案例瞭解Hystrix的各種基本使用方式

Ribbon整合Eureka元件，以實現負載均衡

Spring Clould負載均衡重要元件：Ribbon中重要類的用法

架構師入門：搭建雙註冊中心的高可用Eureka架構（基於專案實戰）

架構師入門：搭建基本的Eureka架構（從專案裡抽取）

藉助Maven入手Spring Boot第一個程式