import com.netflix.hystrix.strategy.metrics.HystrixMetricsPublisherCommand; //导入依赖的package包/类
public HystrixPrometheusMetricsPublisherCommand(
        HystrixMetricsCollector collector, HystrixCommandKey commandKey, HystrixCommandGroupKey commandGroupKey,
        HystrixCommandMetrics metrics, HystrixCircuitBreaker circuitBreaker,
        HystrixCommandProperties properties, boolean exportProperties, boolean exportDeprecatedMetrics,
        HystrixMetricsPublisherCommand delegate) {

    this.labels = new TreeMap<String, String>();
    this.labels.put("command_group", (commandGroupKey != null) ? commandGroupKey.name() : "default");
    this.labels.put("command_name", commandKey.name());

    this.exportProperties = exportProperties;

    this.circuitBreaker = circuitBreaker;
    this.properties = properties;
    this.collector = collector;
    this.metrics = metrics;
    this.commandKey = commandKey;
    this.delegate = delegate;
    this.exportDeprecatedMetrics = exportDeprecatedMetrics;
}
 

import com.netflix.hystrix.strategy.metrics.HystrixMetricsPublisherCommand; //导入依赖的package包/类
@Override
public HystrixMetricsPublisherCommand getMetricsPublisherForCommand(
        HystrixCommandKey commandKey,
        HystrixCommandGroupKey commandGroupKey,
        HystrixCommandMetrics metrics,
        HystrixCircuitBreaker circuitBreaker,
        HystrixCommandProperties properties) {
    log.debug("Notify {} listeners for command {} and group {}", listeners.size(),
            safe(commandKey, HystrixKey::name, "null"),
            safe(commandGroupKey, HystrixKey::name, "null"));
    return () -> listeners.forEach(listener -> listener.initialize(metrics));
}
 

import com.netflix.hystrix.strategy.metrics.HystrixMetricsPublisherCommand; //导入依赖的package包/类
@Override
public HystrixMetricsPublisherCommand getMetricsPublisherForCommand(HystrixCommandKey commandKey, HystrixCommandGroupKey commandGroupKey, HystrixCommandMetrics metrics, HystrixCircuitBreaker circuitBreaker, HystrixCommandProperties properties) {
    Stream<HystrixMetricsPublisherCommand> stream = publishers.stream().map(p ->
            p.getMetricsPublisherForCommand(commandKey, commandGroupKey, metrics, circuitBreaker, properties));
    log.trace("getMetricsPublisherForCommand {}", commandKey.name());
    return () -> stream.forEach(HystrixMetricsPublisherCommand::initialize);
}
 

import com.netflix.hystrix.strategy.metrics.HystrixMetricsPublisherCommand; //导入依赖的package包/类
@Override
public HystrixMetricsPublisherCommand getMetricsPublisherForCommand(
        HystrixCommandKey commandKey, HystrixCommandGroupKey commandGroupKey,
        HystrixCommandMetrics metrics, HystrixCircuitBreaker circuitBreaker,
        HystrixCommandProperties properties) {
    HystrixMetricsPublisherCommand delegate = metricsPublisherDelegate.getMetricsPublisherForCommand(commandKey,
            commandGroupKey, metrics, circuitBreaker, properties);

    return new HystrixPrometheusMetricsPublisherCommand(
            collector, commandKey, commandGroupKey, metrics, circuitBreaker, properties, exportProperties,
            exportDeprecatedMetrics, delegate);
}
 

import com.netflix.hystrix.strategy.metrics.HystrixMetricsPublisherCommand; //导入依赖的package包/类
@Override
public HystrixMetricsPublisherCommand getMetricsPublisherForCommand(HystrixCommandKey commandKey,
                                                                    HystrixCommandGroupKey commandGroupKey,
                                                                    HystrixCommandMetrics metrics,
                                                                    HystrixCircuitBreaker circuitBreaker,
                                                                    HystrixCommandProperties properties) {
  return new HystrixAppmon4jMetricsPublisherCommand(commandKey, commandGroupKey, metrics, circuitBreaker, properties,
    corePlugin);
}
 

import com.netflix.hystrix.strategy.metrics.HystrixMetricsPublisherCommand; //导入依赖的package包/类
@Override
public HystrixMetricsPublisherCommand getMetricsPublisherForCommand(HystrixCommandKey commandKey,
                                                                    HystrixCommandGroupKey commandGroupKey,
                                                                    HystrixCommandMetrics metrics,
                                                                    HystrixCircuitBreaker circuitBreaker,
                                                                    HystrixCommandProperties properties) {
  return new HystrixCodahaleMetricsPublisherCommand(commandKey, commandGroupKey, metrics, circuitBreaker, properties,
    metricRegistry);
}
 

import com.netflix.hystrix.strategy.metrics.HystrixMetricsPublisherCommand; //导入依赖的package包/类
@Override
public HystrixMetricsPublisherCommand getMetricsPublisherForCommand(HystrixCommandKey commandKey, HystrixCommandGroupKey commandGroupKey, HystrixCommandMetrics metrics, HystrixCircuitBreaker circuitBreaker, HystrixCommandProperties properties) {
    return new MicrometerMetricsPublisherCommand(registry, commandKey, commandGroupKey, metrics, circuitBreaker, properties);
}
 

import com.netflix.hystrix.strategy.metrics.HystrixMetricsPublisherCommand; //导入依赖的package包/类
@Override
public HystrixMetricsPublisherCommand getMetricsPublisherForCommand(HystrixCommandKey commandKey, HystrixCommandGroupKey commandGroupKey, HystrixCommandMetrics metrics, HystrixCircuitBreaker circuitBreaker, HystrixCommandProperties properties) {
    return new YammerMetricsPublisherCommand(commandKey, commandGroupKey, metrics, circuitBreaker, properties, metricRegistry);
}