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

1         <!-- metrics-graphite -->
2         <dependency>
3             <groupId>io.dropwizard.metrics</groupId>
4             <artifactId>metrics-graphite</artifactId>
5         </dependency>

 1 package com.xxx.secondboot.web;
 2 
 3 import java.time.LocalDateTime;
 4 import java.util.LinkedList;
 5 import java.util.Queue;
 6 import java.util.concurrent.TimeUnit;
 7 
 8 import org.springframework.web.bind.annotation.RequestMapping;
 9 import org.springframework.web.bind.annotation.RequestMethod;
10 import org.springframework.web.bind.annotation.RestController;
11 
12 import com.codahale.metrics.Gauge;
13 import com.codahale.metrics.MetricFilter;
14 import com.codahale.metrics.MetricRegistry;
15 import com.codahale.metrics.graphite.Graphite;
16 import com.codahale.metrics.graphite.GraphiteReporter;
17 import com.xxx.secondboot.metrics.TestGraphiteReporter;
18 
19 import io.swagger.annotations.Api;
20 
21 @Api("测试metrics")
22 @RestController
23 @RequestMapping("/metrics")
24 public class MetricsController {
25     public static Queue<String> queue = new LinkedList<>();//队列
26 
27     @RequestMapping(value = "/test1", method = RequestMethod.GET)
28     public String test1() {
29         final MetricRegistry registry = new MetricRegistry();
30         final Graphite graphite = new Graphite("10.0.0.1", 2013);//carbon-relay地址端口
31         final GraphiteReporter reporter = GraphiteReporter.forRegistry(registry)
32                                          .convertRatesTo(TimeUnit.SECONDS)
33                                          .convertDurationsTo(TimeUnit.MILLISECONDS)
34                                          .filter(MetricFilter.ALL)
35                                          .prefixedWith("reporter.graphite")
36                                          .build(graphite);
37         reporter.start(1, TimeUnit.SECONDS);
38 
39         registry.register(MetricRegistry.name(TestGraphiteReporter.class, "queue", "size"), new Gauge<Integer>() {
40             public Integer getValue() {
41                 return queue.size();
42             }
43         });
44 
45         while (true) {
46             try {
47                 Thread.sleep(1000);
48                 queue.add("job - " + LocalDateTime.now());
49             } catch (InterruptedException e) {
50                 e.printStackTrace();
51             }
52         }
53     }
54 }

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