import com.netflix.servo.monitor.Counter; //导入依赖的package包/类
public static Counter getCounter(MonitorConfig config) {
    Counter v = COUNTERS.get(config);
    if (v != null) {
        return v;
    } else {
        Counter counter = new BasicCounter(config);
        Counter prevCounter = COUNTERS.putIfAbsent(config, counter);
        if (prevCounter != null) {
            return prevCounter;
        } else {
            DefaultMonitorRegistry.getInstance().register(counter);
            return counter;
        }
    }
}
 

import com.netflix.servo.monitor.Counter; //导入依赖的package包/类
private Counter getCounter(String counterMetric) {
    Counter counter = counterMap.get(counterMetric);
    if(counter != null) return counter;

    counter = EVCacheMetricsFactory.getCounter(appName, null, serverGroup.getName(), appName + "-" + counterMetric, DataSourceType.COUNTER);
    counterMap.put(counterMetric, counter);
    return counter;
}
 

import com.netflix.servo.monitor.Counter; //导入依赖的package包/类
private RabbitMqMessageConsumer(
		final List<TransportConsumer> transportConsumers,
		final Counter deliveryCount,
		final Counter deliveryFailureCount) {
	this.transportConsumers = transportConsumers;
	this.deliveryCount = deliveryCount;
	this.deliveryFailureCount = deliveryFailureCount;
}
 

import com.netflix.servo.monitor.Counter; //导入依赖的package包/类
public CounterCacheCompositeMonitor(final String id) {
	this.id = id;

	final CacheBuilder<K, Counter> cacheBuilder = CacheBuilder.newBuilder()
			.removalListener(new MonitorRemovalListener<K, Counter>());
	this.counters = cacheBuilder.build(new CounterCacheLoader<K>());
}
 

import com.netflix.servo.monitor.Counter; //导入依赖的package包/类
protected static Counter newCounter(String name, String err) {
    return new BasicCounter(MonitorConfig.builder(name).withTag("error", err).build());
}
 

import com.netflix.servo.monitor.Counter; //导入依赖的package包/类
private final Counter createCounter() {
    return Monitors.newCounter("LoadBalancer_ChooseServer");
}
 

import com.netflix.servo.monitor.Counter; //导入依赖的package包/类
public Counter getAddCounter() {
    return addCounter;
}
 

import com.netflix.servo.monitor.Counter; //导入依赖的package包/类
public static Counter getCounter(String name) {
    return getCounter(name, DataSourceType.COUNTER);
}
 

import com.netflix.servo.monitor.Counter; //导入依赖的package包/类
public static void increment(String name) {
    final Counter counter = getCounter(name);
    counter.increment();
}
 

import com.netflix.servo.monitor.Counter; //导入依赖的package包/类
public RabbitMqTransport(
		final Connection connection,
		final Ref transportRef) throws IOException {

	this.transportRef = new RabbitMqTransportRef(transportRef);
	this.consumers = Lists.newArrayList();

	final Counter deliveryCount = new BasicCounter(
			MonitorConfig.builder("deliveryCount").withTag(
					"transport",
					getRef().toString()).build());
	final Counter deliveryFailureCount = new BasicCounter(
			MonitorConfig.builder("deliveryFailureCount").withTag(
					"transport",
					getRef().toString()).build());
	DefaultMonitorRegistry.getInstance().register(deliveryCount);
	DefaultMonitorRegistry.getInstance().register(deliveryFailureCount);
	final MonitorConfig consumersSizeMonitorConfig = MonitorConfig.builder("consumers")
			.withTag("transport", getRef().toString())
			.build();
	DefaultMonitorRegistry.getInstance().register(
			new BasicGauge<>(
					consumersSizeMonitorConfig,
					new CollectionSizeCallable(this.consumers)));

	final Channel channel = connection.createChannel();

	final AMQP.Queue.DeclareOk queueDecl = channel.queueDeclare();
	LOGGER.info("queue declared: {}", queueDecl);

	final AMQP.Exchange.DeclareOk exchangeDeclOk = channel.exchangeDeclare(
			this.transportRef.getExchange(),
			this.transportRef.getType(),
			true,
			true,
			Maps.<String, Object>newHashMap());
	LOGGER.info("exchange declared: {}", exchangeDeclOk);

	final AMQP.Queue.BindOk queueBindOk = channel.queueBind(
			queueDecl.getQueue(),
			this.transportRef.getExchange(),
			"fanout".equals(this.transportRef.getType()) ? "" : this.transportRef.getRoutingKey());
	LOGGER.info("queue binding declared: {}", queueBindOk);

	final String consumerTag = channel.basicConsume(
			queueDecl.getQueue(),
			true,
			new RabbitMqMessageConsumer(consumers, deliveryCount, deliveryFailureCount));
	LOGGER.info("Received consumer tag {}", consumerTag);
}
 

import com.netflix.servo.monitor.Counter; //导入依赖的package包/类
@Override
public Counter load(final K key) throws Exception {
	final Counter c = new BasicCounter(MonitorConfig.builder(buildId(key)).build());
	DefaultMonitorRegistry.getInstance().register(c);
	return c;
}