SpringCloud2.0 Hystrix Ribbon 基於Ribbon實現斷路器 基礎教程(六)

1、啟動【服務中心】集群，工程名：springcloud-eureka-server

參考 SpringCloud2.0 Eureka Server 服務中心 基礎教程(二)

2、啟動【服務提供者】集群，工程名：springcloud-eureka-client

參考 SpringCloud2.0 Eureka Client 服務注冊 基礎教程(三)

3、啟動【服務消費者】，工程名：springcloud-eureka-ribbon

參考 SpringCloud2.0 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"
     * @return
     */
    @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 = "網絡繁忙，請稍后再試-_-。PS：服務消費者自己提供的信息";
        return message;
    }

}

6、加入熔斷機制后，【服務提供者】出現問題，對【服務消費者】的影響

6.1、重啟【服務提供者】集群，重啟【服務消費者】

6.2、停掉【服務提供者】集群中的其中一個服務。本例：停掉端口為 52602 這個服務。

6.3、開瀏覽器窗口，訪問 http://localhost:52610/ribbonInfo，多次刷新該地址

調用 52601、52603 服務是正常的，調用52602服務的時候，沒有出現阻塞等待，而是返回了【服務消費者】自己提供的返回信息

【服務消費者】加入熔斷機制結束