import com.readytalk.metrics.StatsDReporter; //导入依赖的package包/类
/**
 * Configures and builds a {@link ScheduledReporter} instance for the given registry.
 *
 * @param registry the metrics registry to report metrics from.
 * @return a reporter configured for the given metrics registry.
 */
@Override
public ScheduledReporter build(MetricRegistry registry) {

    StatsDReporter.Builder builder
            = StatsDReporter.forRegistry(registry)
                            .convertDurationsTo(getDurationUnit())
                            .convertRatesTo(getRateUnit())
                            .filter(getFilter());

    LOG.info("StatsDReporterFactory built with host: {}, port: {}", getHost(), getPort());

    return builder.build(getHost(), getPort());
}
 

import com.readytalk.metrics.StatsDReporter; //导入依赖的package包/类
/**
 * Starts logging the metrics for cassandra into statsd. 
 */
public static void apply(ActorSystem system) {
    MetricRegistry registry = CassandraMetricsRegistry.get(system).getRegistry();
    
    String statsdhost = system.settings().config().getString("codahale.statsd.hostname");
    int statsdport = system.settings().config().getInt("codahale.statsd.port");
    long interval = system.settings().config().getDuration("codahale.statsd.tick-interval", TimeUnit.MILLISECONDS);
    String prefix = system.settings().config().getString("codahale.statsd.prefix");
    StatsDReporter.forRegistry(registry)
        .prefixedWith(prefix)
        .build(statsdhost, statsdport)           
        .start(interval, TimeUnit.MILLISECONDS);
}
 

import com.readytalk.metrics.StatsDReporter; //导入依赖的package包/类
@Bean
public StatsDReporter statsDReporter() {
    // @formatter:off
    return StatsDReporter
            .forRegistry(metricRegistry)
            .prefixedWith(String.format("%s.%s", statsdSettings.getApplicationName(), statsdSettings.getApplicationHostname()))
            .convertDurationsTo(TimeUnit.MILLISECONDS)
            .convertRatesTo(TimeUnit.SECONDS)
            .filter(MetricFilter.ALL)
            .build(statsdSettings.getHostname(), statsdSettings.getPort());
    // @formatter:on
}
 

import com.readytalk.metrics.StatsDReporter; //导入依赖的package包/类
/**
 * Create a reporter to send metrics to Graphite.
 * @param registry the metric registry
 * @param host the host of the metrics server
 * @param port the port of the metrics server
 * @param prefix the prefix for the metrics
 * @param reportingTime the amount of time between polls
 */
@SuppressWarnings("checkstyle:designforextension")
public void createAndStartStatsDReporter(
        final MetricRegistry registry,
        final String host,
        final int port,
        final String prefix,
        final int reportingTime) {
    StatsDReporter.forRegistry(registry)
            .prefixedWith(prefix)
            .build(host, port)
            .start(reportingTime, TimeUnit.SECONDS);
}
 

import com.readytalk.metrics.StatsDReporter; //导入依赖的package包/类
private StatsDReporter createStatsDReporter(URI uri) {
    StatsDReporter statsDReporter = StatsDReporter.forRegistry(registry)
            .prefixedWith(configuration.getString(CK_PREFIX))
            .convertRatesTo(TimeUnit.SECONDS)
            .convertDurationsTo(TimeUnit.MILLISECONDS)
            .filter(MetricFilter.ALL)
            .build(uri.getHost(), uri.getPort());
    statsDReporter.start(configuration.getInt(CK_RUN_RATE), TimeUnit.SECONDS);
    return statsDReporter;
}
 

import com.readytalk.metrics.StatsDReporter; //导入依赖的package包/类
/**
 * Configures the metrics service to emit StatsD-formatted metrics to the configured UDP host/port with the
 * specified interval.
 */
public static void configureStatsd(SchedulerConfig schedulerConfig) {
    StatsDReporter.forRegistry(metrics)
            .build(schedulerConfig.getStatsdHost(), schedulerConfig.getStatsdPort())
            .start(schedulerConfig.getStatsDPollIntervalS(), TimeUnit.SECONDS);
}
 

import com.readytalk.metrics.StatsDReporter; //导入依赖的package包/类
@Synchronized
@Override
public void start() {
    init();

    if (conf.isEnableCSVReporter()) {
        // NOTE:  metrics output files are exclusive to a given process
        File outdir;
        if (!Strings.isNullOrEmpty(conf.getMetricsPrefix())) {
            outdir = new File(conf.getCsvEndpoint(), conf.getMetricsPrefix());
        } else {
            outdir = new File(conf.getCsvEndpoint());
        }
        outdir.mkdirs();
        log.info("Configuring stats with csv output to directory [{}]", outdir.getAbsolutePath());
        reporters.add(CsvReporter.forRegistry(getMetrics())
                      .convertRatesTo(TimeUnit.SECONDS)
                      .convertDurationsTo(TimeUnit.MILLISECONDS)
                      .build(outdir));
    }
    if (conf.isEnableStatsdReporter()) {
        log.info("Configuring stats with statsD at {}:{}", conf.getStatsDHost(), conf.getStatsDPort());
        reporters.add(StatsDReporter.forRegistry(getMetrics())
                      .build(conf.getStatsDHost(), conf.getStatsDPort()));
    }
    if (conf.isEnableGraphiteReporter()) {
        log.info("Configuring stats with graphite at {}:{}", conf.getGraphiteHost(), conf.getGraphitePort());
        final Graphite graphite = new Graphite(new InetSocketAddress(conf.getGraphiteHost(), conf.getGraphitePort()));
        reporters.add(GraphiteReporter.forRegistry(getMetrics())
            .prefixedWith(conf.getMetricsPrefix())
            .convertRatesTo(TimeUnit.SECONDS)
            .convertDurationsTo(TimeUnit.MILLISECONDS)
            .filter(MetricFilter.ALL)
            .build(graphite));
    }
    if (conf.isEnableJMXReporter()) {
        log.info("Configuring stats with jmx {}", conf.getJmxDomain());
        final JmxReporter jmx = JmxReporter.forRegistry(getMetrics())
            .inDomain(conf.getJmxDomain())
            .convertRatesTo(TimeUnit.SECONDS)
            .convertDurationsTo(TimeUnit.MILLISECONDS)
            .build();
        jmx.start();
    }
    if (conf.isEnableGangliaReporter()) {
        try {
            log.info("Configuring stats with ganglia at {}:{}", conf.getGangliaHost(), conf.getGangliaPort());
            final GMetric ganglia = new GMetric(conf.getGangliaHost(), conf.getGangliaPort(), GMetric.UDPAddressingMode.MULTICAST, 1);
            reporters.add(GangliaReporter.forRegistry(getMetrics())
                .prefixedWith(conf.getMetricsPrefix())
                .convertRatesTo(TimeUnit.SECONDS)
                .convertDurationsTo(TimeUnit.MILLISECONDS)
                .build(ganglia));
        } catch (IOException e) {
            log.warn("ganglia create failure: {}", e);
        }
    }
    if (conf.isEnableConsoleReporter()) {
        log.info("Configuring console reporter");
        reporters.add(ConsoleReporter.forRegistry(getMetrics())
            .convertRatesTo(TimeUnit.SECONDS)
            .convertDurationsTo(TimeUnit.MILLISECONDS)
            .build());
    }
    for (ScheduledReporter r : reporters) {
        r.start(conf.getStatsOutputFrequencySeconds(), TimeUnit.SECONDS);
    }
}