Hystrix源于Netflix API團(tuán)隊(duì)在2011年啟動(dòng)的彈性工程工作，而目前它在Netflix每天處理著數(shù)百億的隔離線程以及數(shù)千億的隔離信號(hào)調(diào)用。該庫(kù)旨在通過控制那些訪問遠(yuǎn)程系統(tǒng)、服務(wù)和第三方庫(kù)的節(jié)點(diǎn)，從而對(duì)延遲和故障提供更強(qiáng)大的容錯(cuò)能力。Hystrix具備擁有回退機(jī)制和斷路器功能的線程和信號(hào)隔離，請(qǐng)求緩存和請(qǐng)求打包，以及監(jiān)控和配置等功能。
目前托管在github上。

在大中型分布式系統(tǒng)中，通常系統(tǒng)很多依賴(HTTP,Dubbo等)，如果一個(gè)應(yīng)用不能對(duì)來(lái)自依賴的故障進(jìn)行有效處理，那該應(yīng)用本身就處在被拖垮的風(fēng)險(xiǎn)中。在一個(gè)高流量的網(wǎng)站中，某個(gè)單一的后端一旦發(fā)生延遲，將會(huì)在數(shù)秒內(nèi)導(dǎo)致所有應(yīng)用資源被耗盡。

例如:一個(gè)依賴30個(gè)服務(wù)的系統(tǒng),每個(gè)服務(wù)99.99%可用。   
此系統(tǒng)的失敗率為1-99.99%的30次方 ≈ 0.3%  
意味著一億次請(qǐng)求 會(huì)有 3,000,00次失敗  
隨著服務(wù)依賴數(shù)量的變多，服務(wù)不穩(wěn)定的概率會(huì)成指數(shù)性提高.

Hystrix把服務(wù)調(diào)用統(tǒng)稱為依賴調(diào)用， Hystrix通過命令模式封裝依賴調(diào)用，每一個(gè)依賴調(diào)用封裝在HystrixCommand中，每個(gè)命令在Hystrix的線程池中運(yùn)行。另外可以對(duì)其配置分組名、線程組，使得不同的依賴可以分類在不同的線程組，隔離不同模塊的依賴，也可根據(jù)負(fù)載情況，配置不同組的線程數(shù)。Hystrix還提供一種熔斷器(CircuitBreaker)的機(jī)制，Hystrix可以通過設(shè)定的條件判斷該封裝的依賴調(diào)用是否可以正確調(diào)用,如果在一定時(shí)間內(nèi)調(diào)用失敗次數(shù)過多，則會(huì)熔斷自身，使得相同的調(diào)用無(wú)法執(zhí)行，待冷卻之后重新再試。

1.pom.xml中加入依賴

  
     com.netflix.hystrix  
     hystrix-core  
     ${hystrix.version}  
  

2.繼承HystrixCommand，在run()方法中完成對(duì)依賴的調(diào)用：

public class CustomeCommand extends HystrixCommand {  
  
    protected CustomeCommand(String input) {  
    //設(shè)置HystrixCommand的屬性
        super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("CustomeGroup"))  
                .andCommandKey(HystrixCommandKey.Factory.asKey("CustomeKey"))  
                .andThreadPoolKey(HystrixThreadPoolKey.Factory.asKey("CustomeThreadPool"))  
                .andCommandPropertiesDefaults(HystrixCommandProperties.Setter()  
                        .withExecutionIsolationStrategy(HystrixCommandProperties.ExecutionIsolationStrategy.THREAD))  
                .andThreadPoolPropertiesDefaults(HystrixThreadPoolProperties.Setter()  
                        .withCoreSize(10))  
        );  
   
    }  
  
    @Override  
    protected String run() throws Exception {
    //訪問真正的服務(wù)  
        return "hello World!";  
    }    
    //服務(wù)降級(jí)
    @Override  
    protected String getFallback() {  
        return "exeucute Falled";  
    }  
    //請(qǐng)求緩存  
    @Override  
    protected String getCacheKey() {  
        //  
    }  
}  

GroupKey：該命令屬于哪一個(gè)組，可以幫助我們更好的組織命令。
CommandKey：該命令的名稱
ThreadPoolKey：該命令所屬線程池的名稱，同樣配置的命令會(huì)共享同一線程池，若不配置，會(huì)默認(rèn)使用GroupKey作為線程池名稱。
CommandProperties：該命令的一些設(shè)置，包括斷路器的配置，隔離策略，降級(jí)設(shè)置，以及一些監(jiān)控指標(biāo)等。
ThreadPoolProerties：關(guān)于線程池的配置，包括線程池大小，排隊(duì)隊(duì)列的大小等。

3.調(diào)用HystrixCommand

        CustomeCommand command = new CustomeCommand();  
        String result = command.execute();  

同步執(zhí)行：即一旦開始執(zhí)行該命令，當(dāng)前線程就得阻塞著直到該命令返回結(jié)果，然后才能繼續(xù)執(zhí)行下面的邏輯。當(dāng)調(diào)用命令的execute()方法即為同步執(zhí)行(內(nèi)部使用queue().get() )。
異步執(zhí)行：命令開始執(zhí)行會(huì)返回一個(gè)Future的對(duì)象，不阻塞后面的邏輯，開發(fā)者自己根據(jù)需要去獲取結(jié)果。當(dāng)調(diào)用HystrixCommand的queue()方法即為異步執(zhí)行。

        CustomeCommand command = new CustomeCommand();  
        Future result = command.queue();  
        while (!result.isDone()){  
            System.out.println("Do other things ..."); 
            } 

響應(yīng)式執(zhí)行：命令開始執(zhí)行會(huì)返回一個(gè)Observable 對(duì)象，開發(fā)者可以給給Obeservable對(duì)象注冊(cè)上Observer或者Action1對(duì)象，響應(yīng)式地處理命令執(zhí)行過程中的不同階段。當(dāng)調(diào)用HystrixCommand的observe()方法，或使用Observable的工廠方法（just(),from()）即為響應(yīng)式執(zhí)行，這個(gè)功能的實(shí)現(xiàn)是基于Netflix的另一個(gè)開源項(xiàng)目RxJava

        CustomeCommand command = new CustomeCommand();  
        Observable result = command.observe();
        result.subscribe(new Action1() {
            @Override
            public void call(String str) {
                logger.info("Command called. Result is:{}", str);
            }
        });

或

        CustomeCommand command = new CustomeCommand();
        Observable result = command.observe();
        result.subscribe(new Observer() {
            @Override
            public void onCompleted() {
                logger.info("Command Completed");
            }

            @Override
            public void onError(Throwable e) {
                logger.error("Command failed", e);
            }

            @Override
            public void onNext(String args) {
                logger.info("Command finish,result is {}", args);
            }
        });
    }

Hystrix還提供給我們一個(gè)監(jiān)控功能Hystrix-dashboard，可以直接使用其開源項(xiàng)目進(jìn)行配置，就能實(shí)時(shí)的觀察我們的服務(wù)調(diào)用情況。

1.構(gòu)建dashboard項(xiàng)目
Shell代碼 收藏代碼
$ git clone https://github.com/Netflix/Hy...
$ cd Hystrix/hystrix-dashboard
$ ../gradlew jettyRun

打開路徑：http://localhost:7979/hystrix...

2.配置服務(wù)狀態(tài)上報(bào)

    
  HystrixMetricsStreamServlet    
  HystrixMetricsStreamServlet    
  com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet  
  
      
  HystrixMetricsStreamServlet    
  /hystrix.stream  
  

3.添加stream
在hystrix-dashboard中按照說(shuō)明添加自己的 http://hystrix-app:port/hystr... ，然后監(jiān)視
4.如果是集群，通過turbine進(jìn)行監(jiān)視

https://github.com/Netflix/Hy...
http://ningandjiao.iteye.com/...
http://fobject.iteye.com/blog...