CircuitBreaker

CircuitBreaker主要分为以下几个模块：熔断器配置，熔断器注册，熔断事件消费者注册，熔断器状态机，熔断器状态及指标，熔断器事件，熔断器事件处理器，熔断器事件消费者。

各模块间关系

• CircuitBreakerRegistry通过其实现类InMemoryCircuitBreakerRegistry根据CircuitBreakerConfig创建CircuitBreaker实例。
• EventConsumerRegistry通过其实现类DefaultEventConsumerRegistry创建EventConsumer事件消费者。
• CircuitBreaker通过其实现类CircuitBreakerStateMachine处理熔断状态，并发布CircuitBreakerEvent从而被注册到EventProcessor事件处理器的EventConsumer事件消费者消费。

State

熔断状态，其数字表示序号，boolean类型表示是否允许发布CircuitBreakerEvent

/** 熔断器不工作，没有状态变化、事件，允许所有请求通过.*/
        DISABLED(3, false),
        /** 熔断器工作，但不熔断，允许所有请求通过.*/
        CLOSED(0, true),
        /** 熔断器工作，开启熔断，不允许所有请求通过.*/
        OPEN(1, true),
        /*强制开启熔断，没有状态变化、事件，不允许任意请求通过. */
        FORCED_OPEN(4, false),
        /** 熔断器开启之后，超过等待周期，进入半开，运行部分请求通过*/
        HALF_OPEN(2, true);

StateTransition

熔断器状态转换的所有情况枚举

CLOSED_TO_OPEN(State.CLOSED, State.OPEN),
        CLOSED_TO_DISABLED(State.CLOSED, State.DISABLED),
        CLOSED_TO_FORCED_OPEN(State.CLOSED, State.FORCED_OPEN),
        HALF_OPEN_TO_CLOSED(State.HALF_OPEN, State.CLOSED),
        HALF_OPEN_TO_OPEN(State.HALF_OPEN, State.OPEN),
        HALF_OPEN_TO_DISABLED(State.HALF_OPEN, State.DISABLED),
        HALF_OPEN_TO_FORCED_OPEN(State.HALF_OPEN, State.FORCED_OPEN),
        OPEN_TO_CLOSED(State.OPEN, State.CLOSED),
        OPEN_TO_HALF_OPEN(State.OPEN, State.HALF_OPEN),
        OPEN_TO_DISABLED(State.OPEN, State.DISABLED),
        OPEN_TO_FORCED_OPEN(State.OPEN, State.FORCED_OPEN),
        FORCED_OPEN_TO_CLOSED(State.FORCED_OPEN, State.CLOSED),
        FORCED_OPEN_TO_OPEN(State.FORCED_OPEN, State.OPEN),
        FORCED_OPEN_TO_DISABLED(State.FORCED_OPEN, State.DISABLED),
        FORCED_OPEN_TO_HALF_OPEN(State.FORCED_OPEN, State.HALF_OPEN),
        DISABLED_TO_CLOSED(State.DISABLED, State.CLOSED),
        DISABLED_TO_OPEN(State.DISABLED, State.OPEN),
        DISABLED_TO_FORCED_OPEN(State.DISABLED, State.FORCED_OPEN),
        DISABLED_TO_HALF_OPEN(State.DISABLED, State.HALF_OPEN);

CircuitBreaker.EventPublisher

通过CircuitBreaker.EventPublisher可以注册事件消费策略，且可根据不同事件类型注册不同的处理策略，onEvent默认所有事件触发。

//请求成功时触发的事件消费策略
        EventPublisher onSuccess(EventConsumer<CircuitBreakerOnSuccessEvent> eventConsumer);
		//请求失败时触发的事件消费策略
        EventPublisher onError(EventConsumer<CircuitBreakerOnErrorEvent> eventConsumer);
		//熔断状态发生变化时触发的事件消费策略
        EventPublisher onStateTransition(EventConsumer<CircuitBreakerOnStateTransitionEvent> eventConsumer);
		//熔断状态被重置触发的事件消费策略
        EventPublisher onReset(EventConsumer<CircuitBreakerOnResetEvent> eventConsumer);
		//请求出现异常，但是是可忽略的异常时触发的事件消费策略
        EventPublisher onIgnoredError(EventConsumer<CircuitBreakerOnIgnoredErrorEvent> eventConsumer);
		//熔断开启请求不运行通过的事件消费策略
        EventPublisher onCallNotPermitted(EventConsumer<CircuitBreakerOnCallNotPermittedEvent> eventConsumer);

Metrics

熔断器监控指标

/**
         * 失败请求比率，当失败次数未达到压力值，返回-1
         */
        float getFailureRate();

        /**
         * 当前所有请求总数
         */
        int getNumberOfBufferedCalls();

        /**
         * 当前所有失败请求总数
         */
        int getNumberOfFailedCalls();

        /**
         * 当熔断器状态处于OPEN时，返回被禁止调用的请求总数，当处于CLOSED or HALF_OPEN时，返回0
         */
        long getNumberOfNotPermittedCalls();

        /**
         * 返回环形缓存区最大请求总数
         */
        int getMaxNumberOfBufferedCalls();

        /**
         * 返回当前成功请求总数
        int getNumberOfSuccessfulCalls();

从下面截图可以看出熔断器核心接口CircuitBreaker提供的核心功能可分为以下几类：

• 请求鉴权
• 熔断处理
• 状态转换
• 装饰多种请求
• 返回熔断信息（如状态、监控指标、配置等）