Resilience4j.Circuitbreaker源码分析

Resilience4j.Circuitbreaker

源码分析

Resilience4j的CircuitBreaker主要由6个部分组成：

• 管理断路器实例的注册容器(CircuitBreakerRegistry)
• 断路器的相关配置(CircuitBreakerConfig)
• 断路器的各种状态(CircuitBreakerState)
• 触发断路器状态变化的指标(CircuitBreakerMetrics)
• 断路器行为变化产生的事件(CircuitBreakerEvent)
• 断路器本身(CircuitBreaker)

他们之间的调用关系如下图：

接下来将会详细介绍下各部分内容及他们之间的关系

CircuitBreakerRegistry 断路器容器

源码如下：

public interface CircuitBrakerRegistry extends Registry<CircuitBreaker, CircuitBreakerConfig> {
    // 根据自定义配置创建CircuitBreakerRegistry实例
    static CircuitBreakerRegistry of(CircuitBreakerConfig circuitBreakerConfig) {
        return new InMemoryCircuitBreakerRegistry(circuitBreakerConfig);
    }
    // ...
    // 使用默认的配置 创建CircuitBreakerRegistry实例
    static CircuitBreakerRegistry ofDefaults() {
        return new InMemoryCircuitBreakerRegistry();
    }
    // ...
    // 根据name获取CircuitBreaker
    CircuitBreaker circuitBreaker(String name, CircuitBreakerConfig config);
    // ...
}
public final class InMemoryCircuitBreakerRegistry extends
    AbstractRegistry<CircuitBreaker, CircuitBreakerConfig> implements CircuitBreakerRegistry {
        public InMemoryCircuitBreakerRegistry(CircuitBreakerConfig defaultConfig) {
        super(defaultConfig);
    }
    // ... 
}

public class AbstractRegistry<E, C> implements Registry<E, C> {
    // CircuitBreaker 实例
    protected final RegistryStore<E> entryMap;
    // CircuitBreakerConfig
    protected final ConcurrentMap<String, C> configurations;
    // tags
    protected final Map<String, String> registryTags;
    private final RegistryEventProcessor eventProcessor;
}

// RegistryStore 默认实现为 InMemoryRegistryStore
// 主要作用就是利用ConcurrentHashMap来存储CircuitBreaker实例
public class InMemoryRegistryStore<E> implements RegistryStore<E> {
    private final ConcurrentMap<String, E> entryMap;
    public InMemoryRegistryStore() {
        this.entryMap = new ConcurrentHashMap<>();
    }
}

CircuitBreakerConfig 断路器的相关配置

• Predicate recordExceptionPredicate=throwable -> true; 判断是否是需要记录的异常，默认所有异常都是可记录的(会拿来计算失败率)
• Predicate ignoreExceptionPredicate = throwable -> false; 判断是否需要忽略异常，默认都不忽略
• Predicate