graphite

定时向Graphite中写入指标项数据，指标项模拟个数3000个

使用的类库

 

        
     
      io.dropwizard.metrics
         
     
      metrics-core
         
     
      ${dropwizard.metrics.version}
     
    
        
     
      io.dropwizard.metrics
         
     
      metrics-graphite
         
     
      ${dropwizard.metrics.version}
     
    

核心代码详解

配置Graphite地址

指定Graphite的host和port，默认时，Graphite中的carbon使用2003端口接收数据；

Graphite graphite = new Graphite(new InetSocketAddress("10.144.202.150", 2003));

模拟3000个指标项

每个指标项都有一个uuid，3000个uuid代表3000个不同的指标项

final List
    
      uuids = Lists.newArrayList();{    for (int i = 1000; i < 4000; i++) {        String uuid = "aaa" + i + "";        uuids.add(uuid);    }}
    

定义Gauge指标

dropwizard.metrics支持5种指标类型，分别为：

1. Gauge
2. Counter
3. Meter
4. Histograms
5. Timers

我们这里定义Gauge指标，需要实现Gauge接口；

使用metricValue(uuid)方法模拟每个指标项的当前值

/** * Gauge指标 */class GaugeImp implements Gauge
    
      {    String uuid;    public GaugeImp(String uuid) {        this.uuid = uuid;    }    @Override    public Float getValue() {        return metricValue(uuid);    }} /** * 用于模拟指标值 * * @param uuid * @return */private float metricValue(String uuid) {    Random random = new Random();    float value = random.nextFloat();    return value;}
    

向Graphite中写入指标项

1. 注册一个MetricRegistry：所有的指标项metrics都存在在MetricRegistry中；
2. 注册所有需要写入的指标项：这里写入3000个Gauge指标；
3. 使用GraphiteReporter实现向Graphite写入数据：A reporter which publishes metric values to a Graphite server.
4. 开始定时任务，每隔5s中向Graphite中写入一次数据；

MetricRegistry registry = new MetricRegistry();// 注册 gauge 指标for (String uuid : uuids) {    String name = "resource." + uuid + ".size";    registry.register(name, new GaugeImp(uuid));}//A reporter which publishes metric values to a Graphite server.GraphiteReporter reporter = GraphiteReporter.forRegistry(registry)        .prefixedWith("openmetric")        .convertRatesTo(TimeUnit.SECONDS)        .convertDurationsTo(TimeUnit.MILLISECONDS)        .filter(MetricFilter.ALL)        .build(graphite);// 设置每隔5秒钟，向Graphite中发送一次指标值reporter.start(5, TimeUnit.SECONDS);

写入结果截图

完整程序