摘要：斷路器原理斷路器在和執(zhí)行過(guò)程中起到至關(guān)重要的作用。其中通過(guò)來(lái)定義，每一個(gè)命令都需要有一個(gè)來(lái)標(biāo)識(shí)，同時(shí)根據(jù)這個(gè)可以找到對(duì)應(yīng)的斷路器實(shí)例。一個(gè)啥都不做的斷路器，它允許所有請(qǐng)求通過(guò)，并且斷路器始終處于閉合狀態(tài)斷路器的另一個(gè)實(shí)現(xiàn)類。

斷路器在HystrixCommand和HystrixObservableCommand執(zhí)行過(guò)程中起到至關(guān)重要的作用。查看一下核心組件HystrixCircuitBreaker

package com.netflix.hystrix;

import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.atomic.AtomicReference;

import com.netflix.hystrix.HystrixCommandMetrics.HealthCounts;
import rx.Subscriber;
import rx.Subscription;

public interface HystrixCircuitBreaker {

    boolean allowRequest();
    
    boolean isOpen();

    void markSuccess();

    void markNonSuccess();

    boolean attemptExecution();

    class Factory {
        // String is HystrixCommandKey.name() (we can"t use HystrixCommandKey directly as we can"t guarantee it implements hashcode/equals correctly)
        private static ConcurrentHashMap circuitBreakersByCommand = new ConcurrentHashMap();
    }


    class HystrixCircuitBreakerImpl implements HystrixCircuitBreaker {
    }

    static class NoOpCircuitBreaker implements HystrixCircuitBreaker {
    }

}

下面先看一下該接口的抽象方法：

allowRequest(): 每個(gè)Hystrix命令的請(qǐng)求都通過(guò)它判斷是否被執(zhí)行(已經(jīng)不再使用,使用attemptExecution()方法進(jìn)行判斷)

attemptExecution(): 每個(gè)Hystrix命令的請(qǐng)求都通過(guò)它判斷是否被執(zhí)行

isOpen(): 返回當(dāng)前斷路器是否打開(kāi)

markSuccess(): 用來(lái)關(guān)閉斷路器

markNonSuccess: 用來(lái)打開(kāi)斷路器

下面看一下該接口中的類:

Factory: 維護(hù)了一個(gè)Hystrix命令和HystrixCircuitBreaker的關(guān)系的集合ConcurrentHashMap circuitBreakersByCommand。其中key通過(guò)HystrixCommandKey來(lái)定義，每一個(gè)Hystrix命令都需要有一個(gè)Key來(lái)標(biāo)識(shí)，同時(shí)根據(jù)這個(gè)Key可以找到對(duì)應(yīng)的斷路器實(shí)例。

NoOpCircuitBreaker: 一個(gè)啥都不做的斷路器，它允許所有請(qǐng)求通過(guò)，并且斷路器始終處于閉合狀態(tài)

HystrixCircuitBreakerImpl:斷路器的另一個(gè)實(shí)現(xiàn)類。

在該類中定義了斷路器的五個(gè)核心對(duì)象:

HystrixCommandProperties properties:斷路器對(duì)應(yīng)實(shí)例的屬性集合對(duì)象

HystrixCommandMetrics metrics:用來(lái)讓HystrixCommand記錄各類度量指標(biāo)的對(duì)象

AtomicReference status: 用來(lái)記錄斷路器的狀態(tài)，默認(rèn)是關(guān)閉狀態(tài)

AtomicLong circuitOpened:斷路器打開(kāi)的時(shí)間戳，默認(rèn)-1，表示斷路器未打開(kāi)

AtomicReference activeSubscription: 記錄HystrixCommand

        @Override
        public boolean isOpen() {
            if (properties.circuitBreakerForceOpen().get()) {
                return true;
            }
            if (properties.circuitBreakerForceClosed().get()) {
                return false;
            }
            return circuitOpened.get() >= 0;
        }

用來(lái)判斷斷路器是否打開(kāi)或關(guān)閉。主要步驟有：

如果斷路器強(qiáng)制打開(kāi)，返回true

如果斷路器強(qiáng)制關(guān)閉，返回false

判斷circuitOpened的值，如果大于等于0，返回true, 否則返回false

        private boolean isAfterSleepWindow() {
            final long circuitOpenTime = circuitOpened.get();
            final long currentTime = System.currentTimeMillis();
            final long sleepWindowTime = properties.circuitBreakerSleepWindowInMilliseconds().get();
            return currentTime > circuitOpenTime + sleepWindowTime;
        }

        @Override
        public boolean attemptExecution() {
            if (properties.circuitBreakerForceOpen().get()) {
                return false;
            }
            if (properties.circuitBreakerForceClosed().get()) {
                return true;
            }
            if (circuitOpened.get() == -1) {
                return true;
            } else {
                if (isAfterSleepWindow()) {
                    if (status.compareAndSet(Status.OPEN, Status.HALF_OPEN)) {
                        //only the first request after sleep window should execute
                        return true;
                    } else {
                        return false;
                    }
                } else {
                    return false;
                }
            }
        }

該方法的主要邏輯有以下幾步:

如果斷路器強(qiáng)制打開(kāi)，返回false，不允許放過(guò)請(qǐng)求

如果斷路器強(qiáng)制關(guān)閉，返回true，允許放過(guò)請(qǐng)求

如果斷路器是關(guān)閉狀態(tài)，返回true，允許放過(guò)請(qǐng)求

判斷當(dāng)前時(shí)間是否超過(guò)斷路器打開(kāi)的時(shí)間加上滑動(dòng)窗口的時(shí)間，如果沒(méi)有超過(guò)，返回false，不允許放過(guò)請(qǐng)求

如果沒(méi)有超過(guò)，如果斷路器是打開(kāi)狀態(tài)，并且設(shè)置斷路器狀態(tài)為半開(kāi)狀態(tài)成功時(shí)，返回true，允許放過(guò)請(qǐng)求

如果失敗，則返回false，不允許放過(guò)請(qǐng)求

        @Override
        public void markSuccess() {
            if (status.compareAndSet(Status.HALF_OPEN, Status.CLOSED)) {
                //This thread wins the race to close the circuit - it resets the stream to start it over from 0
                metrics.resetStream();
                Subscription previousSubscription = activeSubscription.get();
                if (previousSubscription != null) {
                    previousSubscription.unsubscribe();
                }
                Subscription newSubscription = subscribeToStream();
                activeSubscription.set(newSubscription);
                circuitOpened.set(-1L);
            }
        }

該方法主要用來(lái)關(guān)閉斷路器，主要邏輯有以下幾步：

如果斷路器狀態(tài)是半開(kāi)并且成功設(shè)置為關(guān)閉狀態(tài)時(shí)，執(zhí)行以下步驟。

重置度量指標(biāo)對(duì)象

取消之前的訂閱，發(fā)起新的訂閱

設(shè)置斷路器的打開(kāi)時(shí)間為-1

spring-cloud-example