import com.netflix.servo.publish.MonitorRegistryMetricPoller; //导入依赖的package包/类
private static void initMetricsPublishing() throws Exception {
  final List<MetricObserver> observers = new ArrayList<>();

  if (Config.isFileObserverEnabled()) {
    final File dir = Config.getFileObserverDirectory();
    LOGGER.info("file observer enabled, logging to: " + dir);
    observers.add(createFileObserver(dir));
  }

  if (Config.isAtlasObserverEnabled()) {
    final String uri = Config.getAtlasObserverUri();
    LOGGER.info("atlas observer enabled, uri: " + uri);
    observers.add(createAtlasObserver());
  }

  PollScheduler.getInstance().start();
  schedule(new MonitorRegistryMetricPoller(), observers);
}
 

import com.netflix.servo.publish.MonitorRegistryMetricPoller; //导入依赖的package包/类
/**
 * Start the plugin.
 */
public void start() {
    if (!config.isEnabled()) {
        LOGGER.info("Atlas Plugin is disabled.");
        return;
    }

    final List<MetricPoller> pollers = Lists.newArrayList();
    final MonitorRegistry registry = DefaultMonitorRegistry.getInstance();
    final MetricPoller poller = new MonitorRegistryMetricPoller(registry);
    pollers.add(poller);

    final MetricPoller jvmPoller = new JvmMetricPoller();
    pollers.add(jvmPoller);

    thePoller = new CompositePoller(pollers);
    final long delayForMainPoller = delaySecondsFor(Pollers.getPollingIntervals().get(0));
    addPoller(thePoller, delayForMainPoller, TimeUnit.SECONDS);
    registry.register(Monitors.newObjectMonitor(observer));

    LOGGER.info("Starting to keep track of the cpu usage for threads in the jvm.");
    ThreadCpuStats.getInstance().start();
    LOGGER.info("Atlas Plugin started.");
}
 

import com.netflix.servo.publish.MonitorRegistryMetricPoller; //导入依赖的package包/类
public void init() {
  PollScheduler scheduler = PollScheduler.getInstance();
  if (!scheduler.isStarted()) {
    scheduler.start();
  }

  if (isRollingFileEnabled()) {
    MetricObserver fileObserver = new FileOutputMetricObserver(fileOutput, convertor, formatter);
    MetricObserver fileTransform = new CounterToRateMetricTransform(fileObserver, metricPoll, TimeUnit.SECONDS);
    PollRunnable fileTask = new PollRunnable(new MonitorRegistryMetricPoller(), BasicMetricFilter.MATCH_ALL,
        fileTransform);
    scheduler.addPoller(fileTask, metricPoll, TimeUnit.SECONDS);
  }
}
 

import com.netflix.servo.publish.MonitorRegistryMetricPoller; //导入依赖的package包/类
public static final void initialize() {
    // register hystrix servo metrics publisher
    HystrixPlugins.getInstance().registerMetricsPublisher(HystrixServoMetricsPublisher.getInstance());

    // try to get name from openshift.  assume it's scaleable app.
    // format: <app name>.  <namespace>.<gear dns>
    String prefix = System.getenv("HOSTNAME"); // default

    if (System.getenv("OPENSHIFT_APP_NAME") != null) {
        prefix = String.format(
                "%s.%s.%s",
                System.getenv("OPENSHIFT_APP_NAME"),
                System.getenv("OPENSHIFT_NAMESPACE"),
                System.getenv("OPENSHIFT_GEAR_DNS")
        );
    }

    String host = System.getenv("GRAPHITE_HOSTNAME");
    String port = System.getenv("GRAPHITE_PORT");

    String addr = host + ":" + port;
    LOGGER.info("ServoConfig: prefix={}, address={}", prefix, addr);
    MetricObserver observer = new GraphiteMetricObserver(prefix, addr);

    // start poll scheduler
    PollScheduler.getInstance().start();

    // create registry on observer                                                                                                          
    PollRunnable registeryTask = new PollRunnable(new MonitorRegistryMetricPoller(), BasicMetricFilter.MATCH_ALL, observer);
    PollScheduler.getInstance().addPoller(registeryTask, 5, TimeUnit.SECONDS);
    
    // create jvm poller
    PollRunnable jvmTask = new PollRunnable(new JvmMetricPoller(), BasicMetricFilter.MATCH_ALL, observer);
    PollScheduler.getInstance().addPoller(jvmTask, 5, TimeUnit.SECONDS);
}
 

import com.netflix.servo.publish.MonitorRegistryMetricPoller; //导入依赖的package包/类
@Bean
@ConditionalOnMissingBean(MetricPoller.class)
MetricPoller metricPoller() {
	return new MonitorRegistryMetricPoller();
}
 

import com.netflix.servo.publish.MonitorRegistryMetricPoller; //导入依赖的package包/类
private static synchronized void doInitialize(final Type... types) {
    if (initialized) {
        return;
    }

    // Fix Java 7 problem that initialized Hystrix/Servo before the it has been even called
    Hystrix.reset();
    HystrixPlugins.reset();

    // register hystrix servo metrics publisher, required for collecting hystrix metrics
    HystrixPlugins.getInstance().registerMetricsPublisher(HystrixServoMetricsPublisher.getInstance());
    // if IllegalStateException is thrown it means there is a hytrix command being used prior to this setup.
    // SEE: https://github.com/lightblue-platform/lightblue-rest/issues/58
    //      https://github.com/Netflix/Hystrix/issues/150

    List<MetricObserver> observers = new ArrayList<>();

    for (Type type : types) {
        switch (type) {
            case GRAPHITE:
                registerGraphiteMetricObserver(observers, findVariable(ENV_GRAPHITE_PREFIX),
                        findVariable(ENV_GRAPHITE_HOSTNAME), findVariable(ENV_GRAPHITE_PORT));
                break;
            case STATSD:
                registerStatsdMetricObserver(observers, findVariable(ENV_STATSD_PREFIX),
                        findVariable(ENV_STATSD_HOSTNAME), findVariable(ENV_STATSD_PORT));
                break;
            default:
                throw new RuntimeException("Unsupported Type: " + type);
        }
    }

    // start poll scheduler
    PollScheduler.getInstance().start();

    // create and register registery poller
    PollRunnable registeryTask = new PollRunnable(new MonitorRegistryMetricPoller(), BasicMetricFilter.MATCH_ALL, observers);
    PollScheduler.getInstance().addPoller(registeryTask, 5, TimeUnit.SECONDS);

    // create and register jvm poller
    PollRunnable jvmTask = new PollRunnable(new JvmMetricPoller(), BasicMetricFilter.MATCH_ALL, observers);
    PollScheduler.getInstance().addPoller(jvmTask, 5, TimeUnit.SECONDS);

    initialized = true;
    LOGGER.debug("doInitialize() completed, initialized = " + initialized);
}