import com.timgroup.statsd.NoOpStatsDClient; //导入依赖的package包/类
private StatsDClient createClient(String statsdHost, int port) {
    StatsDClientErrorHandler errorHandler = new StatsDClientErrorHandler() {
        @Override
        public void handle(Exception exception) {
            log.error("Error sending to statsd: " + ExceptionToString.format(exception));
        }
    };
    if (statsdHost == null) {
        log.fatal("Error, statsd host not set. It needs to be set in RaptureMETRICS.cfg");
        return new NoOpStatsDClient();
    } else {
        try {
            InetAddress address = InetAddress.getByName(statsdHost);
            String ip = address.getHostAddress();
            log.info(String.format("statsd host=%s, ip=%s", statsdHost, ip));
            return createClient(ip, port, errorHandler);
        } catch (UnknownHostException e) {
            log.error(String.format("Error resolving statsd host ip. hostname=%s - %s", statsdHost, ExceptionToString.format(e)));
            return createClient(statsdHost, port, errorHandler);
        }
    }
}
 

import com.timgroup.statsd.NoOpStatsDClient; //导入依赖的package包/类
/**
 * Returns an initialized instance of the StatsDClient If StatsD is enabled
 * this is a NonBlockingStatsDClient which guarantees not to block the thread or 
 * throw exceptions.   If StatsD is not enabled it creates a NoOpStatsDClient which 
 * contains all empty methods
 *
 * @return initialized StatsDClient
 */
protected StatsDClient createStatsDClient() {

    if (kafkaProducerConfiguration.getStatsDConfiguration() != null) {
        final String prefix = kafkaProducerConfiguration.getStatsDConfiguration().getPrefix();
        final String host = kafkaProducerConfiguration.getStatsDConfiguration().getHost();
        final int port = kafkaProducerConfiguration.getStatsDConfiguration().getPort();
        return new NonBlockingStatsDClient(prefix, host, port);
    } else {
        return new NoOpStatsDClient();
    }
}
 

import com.timgroup.statsd.NoOpStatsDClient; //导入依赖的package包/类
/**
    * Returns an initialized instance of the StatsDClient If StatsD is enabled
    * this is a NonBlockingStatsDClient which guarantees not to block the thread or 
    * throw exceptions.   If StatsD is not enabled it creates a NoOpStatsDClient which 
    * contains all empty methods
    * 
    * @return initialized StatsDClient
    */
   protected StatsDClient createStatsDClient() {
   	
   	final boolean enabled = getOptionalBooleanConfig(STATSD_ENABLED, DEFAULT_STATSD_ENABLED);
   	
   	if (enabled) {
		final String prefix = getOptionalStringConfig(STATSD_PREFIX, DEFAULT_STATSD_PREFIX);
    	final String host = getOptionalStringConfig(STATSD_HOST, DEFAULT_STATSD_HOST);
    	final int port = getOptionalIntConfig(STATSD_PORT, DEFAULT_STATSD_PORT);
		return new NonBlockingStatsDClient(prefix, host, port);
	}
	else {
		return new NoOpStatsDClient();
	}
}
 

import com.timgroup.statsd.NoOpStatsDClient; //导入依赖的package包/类
@Provides
StatsDClient statsDClient(DataDogConfig config) {
    return config.enabled()
           ? new NonBlockingStatsDClient(null, config.host(), config.port())
           : new NoOpStatsDClient();
}
 

import com.timgroup.statsd.NoOpStatsDClient; //导入依赖的package包/类
@Test
public void capabilities() {
    reporter = new StatsdReporter(new NoOpStatsDClient());

    assertEquals(CapableOf.REPORTING, reporter.capabilities());
}
 

import com.timgroup.statsd.NoOpStatsDClient; //导入依赖的package包/类
@Test
public void buildingWithStatsDClientProvidedIsOkay() {
    config.setLivenessMetric("whatever");
    assertNotNull(config.build(new NoOpStatsDClient()));
}