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

時間 2019-11-06

標籤 springcloud2.0 springcloud hystrix feign 基於實現斷路器基礎教程简体版

原文原文鏈接

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

4.一、停掉【服務提供者】集羣中的其中一個服務。本例：停掉端口爲 52602 這個服務。

4.二、打開瀏覽器，訪問 http://localhost:52620/feignInfo，屢次刷新該地址

調用 5260一、52603 服務是正常的，可是調用52602服務的時候，出現了阻塞等待，並最終返回了紅框內的錯誤信息。spring

假如這是正式的生產環境，訪問量很大的狀況下，那麼就會有不少請求阻塞。這會形成【服務消費者】服務器內存消耗陡增，致使應用崩潰。若是有其餘應用須要【服務消費者】返回資源信息，那麼調用【服務消費者】的應用也會出現阻塞。這就致使了連鎖反應，也就是所謂的雪崩。瀏覽器

因此，爲了不這種悲劇發生。順應而生的出現了熔斷保護機制。即：訪問不通時，要及時做出響應，而不是等待至超時。服務器

五、修改【服務消費者】，加入熔斷機制

5.一、打開工程：springcloud-eureka-feign

5.二、修改工程 pom.xml 文件，追加 Hystrix 依賴，添加以下內容：

<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>

5.三、修改工程啓動類，添加註解 @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.四、修改【服務消費者】服務類, 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.五、新增【服務消費者】服務調用失敗，回調處理類，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;
    }

}