hystrix源码小贴士之Servo Publisher

Posted 2020-10-19 zwh1988

HystrixServoMetricsPublisher

　　继承HystrixMetricsPublisher，创建HystrixServoMetricsPublisherCommand、HystrixServoMetricsPublisherThreadPool、HystrixServoMetricsPublisherCollapser。

    @Override
    public HystrixMetricsPublisherCommand getMetricsPublisherForCommand(HystrixCommandKey commandKey, HystrixCommandGroupKey commandGroupKey, HystrixCommandMetrics metrics, HystrixCircuitBreaker circuitBreaker, HystrixCommandProperties properties) {
        return new HystrixServoMetricsPublisherCommand(commandKey, commandGroupKey, metrics, circuitBreaker, properties);
    }

    @Override
    public HystrixMetricsPublisherThreadPool getMetricsPublisherForThreadPool(HystrixThreadPoolKey threadPoolKey, HystrixThreadPoolMetrics metrics, HystrixThreadPoolProperties properties) {
        return new HystrixServoMetricsPublisherThreadPool(threadPoolKey, metrics, properties);
    }

    @Override
    public HystrixMetricsPublisherCollapser getMetricsPublisherForCollapser(HystrixCollapserKey collapserKey, HystrixCollapserMetrics metrics, HystrixCollapserProperties properties) {
        return new HystrixServoMetricsPublisherCollapser(collapserKey, metrics, properties);
    }

HystrixServoMetricsPublisherCommand

　　从HystrixCommandMetrics获取数据，然后设置到DefaultMonitorRegistry中。

HystrixServoMetricsPublisherThreadPool

 　　从HystrixThreadPoolMetrics获取数据，然后设置到DefaultMonitorRegistry中。

HystrixServoMetricsPublisherCollapser

　　从HystrixCollapserMetrics获取数据，然后设置到DefaultMonitorRegistry中。