概述

原來的計劃是寫一篇大而全的文章，用來介紹spring cloud Hystrix，但是想了想，這樣的做法其實也並不是特別好，所以
打算把原來的文章拆分，這樣能夠看起來比較清晰。

服務降級

繼承HystrixCommand來實現

fallback是Hystrix命令執行失敗時使用的後備方法,用來實現服務的降級處理邏輯。在HystrixCommand中可以通過過載
getFallback ()方法來實現服務降級邏輯, Hystrix會在run ()執行過程中出現錯誤、超時、執行緒池拒絕、斷路器熔斷等情況時,執
行getFallback ()方法內的邏輯,比如我們可以用如下方式實現服務降級邏輯:
 

package com.bobo.eurekacomsumer.command;

import com.netflix.hystrix.HystrixCommand;
import org.springframework.web.client.RestTemplate;

/**
 * @author [email protected]
 * @create 2018-10-23 18:47
 **/
public class HelloCommend extends HystrixCommand<String>{

    private RestTemplate restTemplate;
 


    public HelloCommend(Setter setter, RestTemplate restTemplate) {
        super(setter);
        this.restTemplate = restTemplate;
    }
    @Override
    protected String run() throws Exception {
        String forObject = restTemplate.getForObject("http://EUREKA-CLIENT/hello", String.class);
        return
 
 forObject;
    }

    @Override
    protected String getFallback() {
        return "error";
    }
}

在HystrixObservableCommand實現的Hystrix命令中,我們可以通過過載resumeWithFallback方法來實現服務降級邏輯。該方
法會返回一個Observable物件,當命令執行失敗的時候, Hystrix會將Observable中的結果通知給所有的訂閱者。

使用註解實現

package com.bobo.eurekacomsumer.service;

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.client.RestTemplate;

/**
 * @author [email protected]
 * @create 2018-10-21 10:59
 **/
@Service
public class HelloService {

    @Autowired
    @Qualifier(value = "restTemplate")
    private RestTemplate restTemplate;

    @HystrixCommand(fallbackMethod = "helloFeedback")
    public String helloConsumer () {
        return restTemplate.getForEntity("http://EUREKA-CLIENT/hello",
                String.class).getBody();
    }

    public String helloFeedback() {
        return "error";
    }
}

在使用註解來定義服務降級邏輯時,我們需要將具體的Hystrix命令與fallback實現函式定義在同一個類中,並且fallbackMethod
的值必須與實現fallback方法的名字相同。由於必須定義在一個類中,所以對於fallback的訪問修飾符沒有特定的要求,定義為
private. protected. public均可。
在上面的例子中, defaultUser方法將在getUserById執行時發生錯誤的情況下被執行。若defaultUser方法實現的並不是一個穩
定邏輯,它依然可能會發生異常,那麼我們也可以為它新增@HystrixCommand註解以生成Hystrix命令,同時使用fallbackMethod
來指定服務降級 。
服務降級的程式碼:

package com.bobo.eurekacomsumer.service;/**
 * Created by wuxiaobo on 2018/10/21.
 */

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.client.RestTemplate;

/**
 * @author [email protected]
 * @create 2018-10-21 10:59
 **/
@Service
public class HelloService2 {

    @Autowired
    @Qualifier(value = "restTemplate")
    private RestTemplate restTemplate;

    @HystrixCommand(fallbackMethod = "helloFeedback1")
    public String helloConsumer () {
        return restTemplate.getForEntity("http://EUREKA-CLIENT/hello",
                String.class).getBody();
    }

    @HystrixCommand(fallbackMethod = "helloFeedback")
    public String helloFeedback1() {
        return "Hello World";
    }

    
    public String helloFeedback() {
        return "error";
    }
}

異常處理

	當Hystrix命令因為異常(除了HystrixBadRequestException的異常)進入服務降級邏輯之後,往往需要對不同異常做針對性的處
理,那麼我們如何來獲取當前丟擲的異常呢?
	在以傳統繼承方式實現的Hystrix命令中,我們可以用getFallback ()方法通過Throwable getExecutionException ()方法來獲取具
體的異常,通過判斷來進入不同的處理邏輯。
	除了傳統的實現方式之外,註解配置方式也同樣可以實現異常的獲取。它的實現也非,常簡單,只需要在fallback實現方法的參
數中增加Throwable e物件的定義,這樣在方法內部就可以獲取觸發服務降級的具體異常內容了,比如:

@HystrixCommand (fallbackMethod = "fallbacki")
User getUserById (String id) {
	throw new RuntimeException ("getUserById command failed");
}
User fallback1 (String id, Throwable e) {
	assert "getUserById command failed".equals (e.getMessage ());
}