03、核心模块CircuitBreaker源码之CircuitBreaker、State、StateTransition、EventPublisher、Metrics

文章目录

  • CircuitBreaker
    • 各模块间关系
  • State
  • StateTransition
  • CircuitBreaker.EventPublisher
  • Metrics

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提供的核心功能可分为以下几类:

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