摘要：斷路器原理斷路器在和執(zhí)行過程中起到至關重要的作用。其中通過來定義，每一個命令都需要有一個來標識，同時根據這個可以找到對應的斷路器實例。一個啥都不做的斷路器，它允許所有請求通過，并且斷路器始終處于閉合狀態(tài)斷路器的另一個實現類。

斷路器在HystrixCommand和HystrixObservableCommand執(zhí)行過程中起到至關重要的作用。查看一下核心組件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(): 每個Hystrix命令的請求都通過它判斷是否被執(zhí)行(已經不再使用,使用attemptExecution()方法進行判斷)

attemptExecution(): 每個Hystrix命令的請求都通過它判斷是否被執(zhí)行

isOpen(): 返回當前斷路器是否打開

markSuccess(): 用來關閉斷路器

markNonSuccess: 用來打開斷路器

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

Factory: 維護了一個Hystrix命令和HystrixCircuitBreaker的關系的集合ConcurrentHashMap circuitBreakersByCommand。其中key通過HystrixCommandKey來定義，每一個Hystrix命令都需要有一個Key來標識，同時根據這個Key可以找到對應的斷路器實例。

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

HystrixCircuitBreakerImpl:斷路器的另一個實現類。

在該類中定義了斷路器的五個核心對象:

HystrixCommandProperties properties:斷路器對應實例的屬性集合對象

HystrixCommandMetrics metrics:用來讓HystrixCommand記錄各類度量指標的對象

AtomicReference status: 用來記錄斷路器的狀態(tài)，默認是關閉狀態(tài)

AtomicLong circuitOpened:斷路器打開的時間戳，默認-1，表示斷路器未打開

AtomicReference activeSubscription: 記錄HystrixCommand

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

用來判斷斷路器是否打開或關閉。主要步驟有：

如果斷路器強制打開，返回true

如果斷路器強制關閉，返回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;
                }
            }
        }

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

如果斷路器強制打開，返回false，不允許放過請求

如果斷路器強制關閉，返回true，允許放過請求

如果斷路器是關閉狀態(tài)，返回true，允許放過請求

判斷當前時間是否超過斷路器打開的時間加上滑動窗口的時間，如果沒有超過，返回false，不允許放過請求

如果沒有超過，如果斷路器是打開狀態(tài)，并且設置斷路器狀態(tài)為半開狀態(tài)成功時，返回true，允許放過請求

如果失敗，則返回false，不允許放過請求

        @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);
            }
        }

該方法主要用來關閉斷路器，主要邏輯有以下幾步：

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

重置度量指標對象

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

設置斷路器的打開時間為-1

spring-cloud-example