SpringCloud中使用Hystrix

1.  引言

---

一般而言，一個服務都是部署了多台機器的，那么在這種情況下，當其中一個服務掛了以后Hystrix是怎么處理的呢？

為了驗證這個問題，我們准備兩個服務：user-api 和 app-gateway，再加一個Eureka Server

2.  服務搭建

---

2.1.  注冊中心

關於這一部分，參見《SpringCloud學習筆記(1)——Eureka》

2.2.  服務提供方

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.cjs.example</groupId>
    <artifactId>user-api</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>user-api</name>
    <description></description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.5.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
        <spring-cloud.version>Finchley.SR1</spring-cloud.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

server:
  port: 8081
spring:
  application:
    name: user-api

eureka:
  instance:
    instance-id: 192.168.1.1:${server.port}
    hostname: 192.168.1.1
  client:
    service-url:
      defaultZone: http://192.168.1.1:8761/eureka/

package com.cjs.example;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@SpringBootApplication
public class UserApiApplication {

    public static void main(String[] args) {
        SpringApplication.run(UserApiApplication.class, args);
    }

    @RequestMapping("/sayHello")
    public String sayHello() {
        System.out.println("lalala");
        return "hello";
    }
}

這里通過控制打印日志來觀察調用的是哪個機器上的該服務

2.3.  服務消費方

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.cjs.example</groupId>
    <artifactId>app-gatewate</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>app-gatewate</name>
    <description></description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.5.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
        <spring-cloud.version>Finchley.SR1</spring-cloud.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

application.yml

server:
  port: 8080
spring:
  application:
    name: app-gateway
eureka:
  instance:
    instance-id: 192.168.1.1:${server.port}
    hostname: 192.168.1.1
  client:
    service-url:
      defaultZone: http://192.168.1.1:8761/eureka/
feign:
  hystrix:
    enabled: true

AppGatewayApplication.java

package com.cjs.example;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.openfeign.EnableFeignClients;

@EnableCircuitBreaker
@EnableFeignClients
@SpringBootApplication
public class AppGatewayApplication {

    public static void main(String[] args) {
        SpringApplication.run(AppGatewayApplication.class, args);
    }
}

FeignClient

package com.cjs.example.service;

import com.cjs.example.fallback.UserClientFallback;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;

@FeignClient(value = "user-api", fallback = UserClientFallback.class)
public interface UserClient {

    @RequestMapping("/sayHello")
    String sayHello();

}

Hystrix

package com.cjs.example.fallback;

import com.cjs.example.service.UserClient;
import org.springframework.stereotype.Component;

@Component
public class UserClientFallback implements UserClient {
    @Override
    public String sayHello() {
        return "Oh! Error!!!";
    }
}

UserController.java

package com.cjs.example.controller;

import com.cjs.example.service.UserClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/user")
public class UserController {

    @Autowired
    private UserClient userClient;

    @RequestMapping("/hello")
    public String hello() {
        return userClient.sayHello();
    }

}

目錄結構

3.  演示

---

1、依次啟動各服務：eureka-demo-server，user-api（兩台），app-gateway

2、瀏覽器查看 http://192.168.1.1:8761/

3、通過請求 http://localhost:8080/user/hello 令app-gateway調用user-api服務（使用FeignClient調用，並集成Hystrix）

4、觀察控制打印“lalala”，同時頁面輸出“hello”

5、停掉其中一台user-api，發現在短時間內會執行回退操作（即頁面返回“Oh! Error!!!”），隨后恢復正常（因為請求打到另一台機器上了）

 

由此，可以看出

首先，一般Hystrix 和 Ribbon一起使用的，而且必要有注冊中心，在這種情況下，如果調用某個服務失敗（或者拒絕、超時等），會嘗試調用其它機器上的該服務，但這種切換需要一定的時間，並不是無縫切換的（也就是說，並不是在服務調用失敗或拒絕的時候理解換到另一台機器，在所有機器都嘗試過以后都失敗的情況下才執行回退邏輯，不是這樣的，可以想象一下，單純依靠Hystrix的能力是不能做到這一點的，況且，Hystrix本身設計就不是用來做這個事情的，它設計是用來阻止級聯失敗，用快速失敗來代替請求排隊的，但是有了客戶端負載均衡器以后，當其中一台機器掛了以后，請求會轉發到其它機器上。因此，切換是負載均衡器做的，跟斷路器沒有關系）

 

4.  小結

---

Ribbon是一個客戶端的負載均衡器，它決定選擇哪一台機器來調用

Hystrix是一個斷路器，它將服務調用進行隔離，用快速失敗來代替排隊，阻止級聯調用失敗。它的目的是不讓服務掛掉。

二者之間沒有關系，因為設計它們的目的不一樣，解決的問題也不一樣

再回到開頭提到的問題，即使沒有Hystrix，一台機器掛掉以后，后續的請求也會轉到其它機器上。只是有了Hystrix以后，遇到這種失敗的時候會執行回退操作。

5.  其它

---

《Feign Hystrix Fallbacks》

《Hystrix介紹》

《Hystrix是如何工作的》

《Spring Boot 集成 Hystrix》

《SpringCloud學習筆記(3)——Hystrix》

《SpringCloud學習筆記(2)——Ribbon》

《SpringCloud學習筆記(1)——Eureka》