Java metrics 学习

YinKe-Lin · Dec 2, 2021 · 2ccf5f7 · 2ccf5f7
1 parent ea9f6c7
commit 2ccf5f7
Show file tree

Hide file tree

Showing 16 changed files with 130 additions and 16 deletions.
diff --git a/.../fast/cloud/nacos/metrics/CacheGauge.java → ...loud/nacos/metrics/metric/CacheGauge.java b/.../fast/cloud/nacos/metrics/CacheGauge.java → ...loud/nacos/metrics/metric/CacheGauge.java
@@ -1,4 +1,4 @@
-package fast.cloud.nacos.metrics;
+package fast.cloud.nacos.metrics.metric;
 
 import com.codahale.metrics.CachedGauge;
 import com.codahale.metrics.ConsoleReporter;

diff --git a/...t/cloud/nacos/metrics/CounterExample.java → .../nacos/metrics/metric/CounterExample.java b/...t/cloud/nacos/metrics/CounterExample.java → .../nacos/metrics/metric/CounterExample.java
@@ -1,4 +1,4 @@
-package fast.cloud.nacos.metrics;
+package fast.cloud.nacos.metrics.metric;
 
 import com.codahale.metrics.ConsoleReporter;
 import com.codahale.metrics.Counter;

diff --git a/...llyDecayingReservoirHistogramExample.java → ...llyDecayingReservoirHistogramExample.java b/...llyDecayingReservoirHistogramExample.java → ...llyDecayingReservoirHistogramExample.java
@@ -1,4 +1,4 @@
-package fast.cloud.nacos.metrics;
+package fast.cloud.nacos.metrics.metric;
 
 import com.codahale.metrics.*;
 

diff --git a/...cloud/nacos/metrics/HistogramExample.java → ...acos/metrics/metric/HistogramExample.java b/...cloud/nacos/metrics/HistogramExample.java → ...acos/metrics/metric/HistogramExample.java
@@ -1,4 +1,4 @@
-package fast.cloud.nacos.metrics;
+package fast.cloud.nacos.metrics.metric;
 
 import com.codahale.metrics.ConsoleReporter;
 import com.codahale.metrics.Histogram;

diff --git a/...cos/metrics/JmxAttributeGaugeExample.java → ...rics/metric/JmxAttributeGaugeExample.java b/...cos/metrics/JmxAttributeGaugeExample.java → ...rics/metric/JmxAttributeGaugeExample.java
@@ -1,4 +1,4 @@
-package fast.cloud.nacos.metrics;
+package fast.cloud.nacos.metrics.metric;
 
 import com.codahale.metrics.ConsoleReporter;
 import com.codahale.metrics.JmxAttributeGauge;

diff --git a/...ast/cloud/nacos/metrics/MeterExample.java → ...ud/nacos/metrics/metric/MeterExample.java b/...ast/cloud/nacos/metrics/MeterExample.java → ...ud/nacos/metrics/metric/MeterExample.java
@@ -1,4 +1,4 @@
-package fast.cloud.nacos.metrics;
+package fast.cloud.nacos.metrics.metric;
 
 import com.codahale.metrics.ConsoleReporter;
 import com.codahale.metrics.Meter;
@@ -38,7 +38,4 @@ private static void upload(byte[] bytes) {
         requestMeter.mark();
         sizeMeter.mark(bytes.length);
     }
-
-
-
 }
diff --git a/.../fast/cloud/nacos/metrics/RadioGauge.java → ...loud/nacos/metrics/metric/RadioGauge.java b/.../fast/cloud/nacos/metrics/RadioGauge.java → ...loud/nacos/metrics/metric/RadioGauge.java
@@ -1,4 +1,4 @@
-package fast.cloud.nacos.metrics;
+package fast.cloud.nacos.metrics.metric;
 
 import com.codahale.metrics.ConsoleReporter;
 import com.codahale.metrics.Meter;

diff --git a/...oud/nacos/metrics/SimpleGaugeExample.java → ...os/metrics/metric/SimpleGaugeExample.java b/...oud/nacos/metrics/SimpleGaugeExample.java → ...os/metrics/metric/SimpleGaugeExample.java
@@ -1,4 +1,4 @@
-package fast.cloud.nacos.metrics;
+package fast.cloud.nacos.metrics.metric;
 
 import com.codahale.metrics.ConsoleReporter;
 import com.codahale.metrics.Gauge;

diff --git a/...TimeWindowReservoirsHistogramExample.java → ...TimeWindowReservoirsHistogramExample.java b/...TimeWindowReservoirsHistogramExample.java → ...TimeWindowReservoirsHistogramExample.java
@@ -1,4 +1,4 @@
-package fast.cloud.nacos.metrics;
+package fast.cloud.nacos.metrics.metric;
 
 import com.codahale.metrics.*;
 

diff --git a/...dingWindowReservoirsHistogramExample.java → ...dingWindowReservoirsHistogramExample.java b/...dingWindowReservoirsHistogramExample.java → ...dingWindowReservoirsHistogramExample.java
@@ -1,4 +1,4 @@
-package fast.cloud.nacos.metrics;
+package fast.cloud.nacos.metrics.metric;
 
 import com.codahale.metrics.*;
 

diff --git a/...e-code-analysis/code-metrics/src/main/java/fast/cloud/nacos/metrics/metric/TimerTest.java b/...e-code-analysis/code-metrics/src/main/java/fast/cloud/nacos/metrics/metric/TimerTest.java
@@ -0,0 +1,31 @@
+package fast.cloud.nacos.metrics.metric;
+
+import com.codahale.metrics.ConsoleReporter;
+import com.codahale.metrics.MetricRegistry;
+import com.codahale.metrics.Timer;
+
+import java.util.Random;
+import java.util.concurrent.TimeUnit;
+
+public class TimerTest {
+
+    public static Random random = new Random();
+
+    public static void main(String[] args) throws InterruptedException {
+        MetricRegistry registry = new MetricRegistry();
+        ConsoleReporter reporter = ConsoleReporter.forRegistry(registry).build();
+        reporter.start(1, TimeUnit.SECONDS);
+
+        Timer timer = registry.timer(MetricRegistry.name(TimerTest.class,"get-latency"));
+
+        Timer.Context ctx;
+
+        while(true){
+            ctx = timer.time();
+            Thread.sleep(random.nextInt(1000));
+            ctx.stop();
+        }
+
+    }
+
+}
diff --git a/...ics/UniformReservoirHistogramExample.java → ...ric/UniformReservoirHistogramExample.java b/...ics/UniformReservoirHistogramExample.java → ...ric/UniformReservoirHistogramExample.java
@@ -1,4 +1,4 @@
-package fast.cloud.nacos.metrics;
+package fast.cloud.nacos.metrics.metric;
 
 import com.codahale.metrics.ConsoleReporter;
 import com.codahale.metrics.Histogram;

diff --git a/.../code-metrics/src/main/java/fast/cloud/nacos/metrics/reporter/ConsoleReporterExample.java b/.../code-metrics/src/main/java/fast/cloud/nacos/metrics/reporter/ConsoleReporterExample.java
@@ -0,0 +1,42 @@
+package fast.cloud.nacos.metrics.reporter;
+
+import com.codahale.metrics.ConsoleReporter;
+import com.codahale.metrics.Histogram;
+import com.codahale.metrics.MetricRegistry;
+
+import java.util.concurrent.TimeUnit;
+
+import static java.util.concurrent.ThreadLocalRandom.current;
+
+public class ConsoleReporterExample {
+    private static final MetricRegistry registry = new MetricRegistry();
+
+    private static final ConsoleReporter reporter = ConsoleReporter.forRegistry(registry)
+            .convertRatesTo(TimeUnit.SECONDS)
+            .convertDurationsTo(TimeUnit.SECONDS).build();
+
+    private static final Histogram histogram = registry.histogram("search-result");
+
+    public static void main(String[] args) {
+        reporter.start(10,TimeUnit.SECONDS);
+
+        while (true) {
+            doSearch();
+            randomSleep();
+        }
+    }
+
+    private static void doSearch() {
+        histogram.update(current().nextInt(10));
+    }
+
+
+    private static void randomSleep() {
+        try {
+            TimeUnit.SECONDS.sleep(current().nextInt(500));
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+    }
+
+}
diff --git a/...oud/nacos/metrics/CsvReporterExample.java → .../metrics/reporter/CsvReporterExample.java b/...oud/nacos/metrics/CsvReporterExample.java → .../metrics/reporter/CsvReporterExample.java
@@ -1,4 +1,4 @@
-package fast.cloud.nacos.metrics;
+package fast.cloud.nacos.metrics.reporter;
 
 import com.codahale.metrics.CsvReporter;
 import com.codahale.metrics.Histogram;

diff --git a/...oud/nacos/metrics/JmxReporterExample.java → .../metrics/reporter/JmxReporterExample.java b/...oud/nacos/metrics/JmxReporterExample.java → .../metrics/reporter/JmxReporterExample.java
@@ -1,4 +1,4 @@
-package fast.cloud.nacos.metrics;
+package fast.cloud.nacos.metrics.reporter;
 
 import com.codahale.metrics.Histogram;
 import com.codahale.metrics.JmxReporter;

diff --git a/...is/code-metrics/src/main/java/fast/cloud/nacos/metrics/reporter/SLF4jReporterExample.java b/...is/code-metrics/src/main/java/fast/cloud/nacos/metrics/reporter/SLF4jReporterExample.java
@@ -0,0 +1,44 @@
+package fast.cloud.nacos.metrics.reporter;
+
+import com.codahale.metrics.Histogram;
+import com.codahale.metrics.MetricRegistry;
+import com.codahale.metrics.Slf4jReporter;
+import org.slf4j.LoggerFactory;
+
+import java.util.concurrent.TimeUnit;
+
+import static java.util.concurrent.ThreadLocalRandom.current;
+
+public class SLF4jReporterExample {
+    private static final MetricRegistry registry = new MetricRegistry();
+
+    private static final Slf4jReporter reporter = Slf4jReporter.forRegistry(registry)
+            .outputTo(LoggerFactory.getLogger(SLF4jReporterExample.class))
+            .convertRatesTo(TimeUnit.SECONDS)
+            .convertDurationsTo(TimeUnit.SECONDS).build();
+
+    private static final Histogram histogram = registry.histogram("search-result");
+
+    public static void main(String[] args) {
+        reporter.start(10,TimeUnit.SECONDS);
+
+        while (true) {
+            doSearch();
+            randomSleep();
+        }
+    }
+
+    private static void doSearch() {
+        histogram.update(current().nextInt(10));
+    }
+
+
+    private static void randomSleep() {
+        try {
+            TimeUnit.SECONDS.sleep(current().nextInt(500));
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+    }
+
+}