第三十六章 metrics（4）- metrics-graphite

將metrics report給graphite（carbon-relay）

一、代碼

1、pom.xml

        <!-- metrics-graphite -->
        <dependency>
            <groupId>io.dropwizard.metrics</groupId>
            <artifactId>metrics-graphite</artifactId>
        </dependency>

依托於springboot1.3.0，版本號還是3.1.2

2、controller

package com.xxx.secondboot.web;

import java.time.LocalDateTime;
import java.util.LinkedList;
import java.util.Queue;
import java.util.concurrent.TimeUnit;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import com.codahale.metrics.Gauge;
import com.codahale.metrics.MetricFilter;
import com.codahale.metrics.MetricRegistry;
import com.codahale.metrics.graphite.Graphite;
import com.codahale.metrics.graphite.GraphiteReporter;
import com.xxx.secondboot.metrics.TestGraphiteReporter;

import io.swagger.annotations.Api;

@Api("測試metrics")
@RestController
@RequestMapping("/metrics")
public class MetricsController {
    public static Queue<String> queue = new LinkedList<>();//隊列

    @RequestMapping(value = "/test1", method = RequestMethod.GET)
    public String test1() {
        final MetricRegistry registry = new MetricRegistry();
        final Graphite graphite = new Graphite("10.0.0.1", 2013);//carbon-relay地址端口
        final GraphiteReporter reporter = GraphiteReporter.forRegistry(registry)
                                         .convertRatesTo(TimeUnit.SECONDS)
                                         .convertDurationsTo(TimeUnit.MILLISECONDS)
                                         .filter(MetricFilter.ALL)
                                         .prefixedWith("reporter.graphite")
                                         .build(graphite);
        reporter.start(1, TimeUnit.SECONDS);

        registry.register(MetricRegistry.name(TestGraphiteReporter.class, "queue", "size"), new Gauge<Integer>() {
            public Integer getValue() {
                return queue.size();
            }
        });

        while (true) {
            try {
                Thread.sleep(1000);
                queue.add("job - " + LocalDateTime.now());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

注意：

這里的carbon-relay的ip寫你真正要發給的relay，該relay的監聽接口的IP最好設置為0.0.0.0（carbon.conf），用來監聽所有連接它的服務器。這里采用了text協議（TCP協議），也可以使用pickle協議（批量發送--量是可配置的），還可以是UDP協議。

 

final PickledGraphite graphitePickle = new PickledGraphite("10.0.40.63", 2013);//pickle協議
final GraphiteUDP graphiteUDP = new GraphiteUDP("10.0.40.63", 2013);//UDP

 

 

二、測試

啟動swagger進行測試，查看relay的listen日志。

• 04/10/2016 14:21:37 :: MetricLineReceiver connection with ip:56769 established（調用controller方法的時候出現）
• 04/10/2016 14:24:38 :: MetricLineReceiver connection with ip:56769 closed cleanly（停止該方法的時候出現）

查看graphite-web中左側的metric name有沒有更新

 

參考：http://metrics.dropwizard.io/3.1.0/manual/graphite/