Java Metrics系統(tǒng)性能監(jiān)控工具的使用詳解
前言
Metrics是一個(gè)Java庫,可以對(duì)系統(tǒng)進(jìn)行監(jiān)控,統(tǒng)計(jì)一些系統(tǒng)的性能指標(biāo)。
比如一個(gè)系統(tǒng)后臺(tái)服務(wù),我們可能需要了解一下下面的一些情況:
1、每秒鐘的請(qǐng)求數(shù)是多少(TPS)?
2、平均每個(gè)請(qǐng)求處理的時(shí)間?
3、請(qǐng)求處理的最長耗時(shí)?
4、等待處理的請(qǐng)求隊(duì)列長度?
5、又或者一個(gè)緩存服務(wù):緩存的命中率?平均查詢緩存的時(shí)間?
基本上每一個(gè)服務(wù)、應(yīng)用都需要做一個(gè)監(jiān)控系統(tǒng),這需要盡量以少量的代碼,實(shí)現(xiàn)統(tǒng)計(jì)某類數(shù)據(jù)的功能。
Metric Registries
MetricRegistry類是Metrics的核心,它是存放應(yīng)用中所有metrics的容器,也是我們使用 Metrics 庫的起點(diǎn)。
MetricRegistry registry = new MetricRegistry();
Metrics 數(shù)據(jù)展示
Metrics 提供了 Report 接口,用于展示 metrics 獲取到的統(tǒng)計(jì)數(shù)據(jù)。metrics-core中主要實(shí)現(xiàn)了四種 reporter: JMX ,console, SLF4J, 和 CSV。 在的例子中,我們使用 ConsoleReporter 。
Metrics的五種類型
Gauges
比較簡(jiǎn)單的度量指標(biāo),只有一個(gè)簡(jiǎn)單的返回值,例如,我們想衡量一個(gè)待處理隊(duì)列中任務(wù)的個(gè)數(shù),代碼如下:
package com.zyh.maven.metricsdemo;
import com.codahale.metrics.ConsoleReporter;
import com.codahale.metrics.Gauge;
import com.codahale.metrics.MetricRegistry;
import java.util.LinkedList;
import java.util.Queue;
import java.util.concurrent.TimeUnit;
public class GaugeTest {
public static Queue<String> q = new LinkedList<String>();
public static void main(String[] args) throws InterruptedException {
MetricRegistry metricRegistry = new MetricRegistry();
ConsoleReporter reporter = ConsoleReporter.forRegistry(metricRegistry).build();
reporter.start(1, TimeUnit.SECONDS);
metricRegistry.register(MetricRegistry.name(GaugeTest.class, "queue", "size"),
new Gauge<Integer>(){
@Override
public Integer getValue() {
return q.size();
}
});
while (true)
{
Thread.sleep(1000);
q.add("lfwhvip");
}
}
}
運(yùn)行結(jié)果 :
22-11-3 14:36:28 ================================================================
-- Gauges ----------------------------------------------------------------------
com.zyh.maven.metricsdemo.GaugeTest.queue.size
value = 1
22-11-3 14:36:29 ================================================================
-- Gauges ----------------------------------------------------------------------
com.zyh.maven.metricsdemo.GaugeTest.queue.size
value = 1
Counters
Counter 就是計(jì)數(shù)器,Counter 只是用 Gauge 封裝了 AtomicLong ,我們可以使用如下的方法獲得隊(duì)列大小,代碼如下:
package com.zyh.maven.metricsdemo;
import com.codahale.metrics.ConsoleReporter;
import com.codahale.metrics.Counter;
import com.codahale.metrics.MetricRegistry;
import java.util.Queue;
import java.util.Random;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.TimeUnit;
public class CounterTest {
public static Queue<String> q = new LinkedBlockingDeque<String>();
public static Counter pendingJobs;
public static Random random = new Random();
public static void addJob(String job)
{
pendingJobs.inc();
q.offer(job);
}
public static String takeJob()
{
pendingJobs.dec();
return q.poll();
}
public static void main(String[] args) throws InterruptedException {
MetricRegistry registry = new MetricRegistry();
ConsoleReporter reporter = ConsoleReporter.forRegistry(registry).build();
reporter.start(1, TimeUnit.SECONDS);
pendingJobs = registry.counter(MetricRegistry.name(Queue.class, "pending-jobs", "size"));
int num = 1;
while(true)
{
Thread.sleep(200);
if(random.nextDouble() > 0.7)
{
String job = takeJob();
System.out.println("take job :" + job);
}else{
String job = "Job-" + num;
addJob(job);
System.out.println("add Job :" + job);
}
num++;
}
}
}
運(yùn)行結(jié)果
take job :Job-14
add Job :Job-26
add Job :Job-27
add Job :Job-28
add Job :Job-29
22-11-3 14:39:58 ================================================================
-- Counters --------------------------------------------------------------------
java.util.Queue.pending-jobs.size
count = 11
take job :Job-16
add Job :Job-31
add Job :Job-32
take job :Job-17
take job :Job-18
22-11-3 14:39:59 ================================================================
-- Counters --------------------------------------------------------------------
java.util.Queue.pending-jobs.size
count = 10
Meters
Meter度量一系列事件發(fā)生的速率(rate),例如TPS。Meters會(huì)統(tǒng)計(jì)最近1分鐘,5分鐘,15分鐘,還有全部時(shí)間的速率。
package com.zyh.maven.metricsdemo;
import com.codahale.metrics.ConsoleReporter;
import com.codahale.metrics.Meter;
import com.codahale.metrics.MetricRegistry;
import java.util.Random;
import java.util.concurrent.TimeUnit;
public class MeterTest {
public static Random random = new Random();
public static void request(Meter meter)
{
System.out.println("request");
meter.mark();
}
public static void request(Meter meter, int n)
{
while(n > 0)
{
request(meter);
n--;
}
}
public static void main(String[] args) throws InterruptedException {
MetricRegistry registry = new MetricRegistry();
ConsoleReporter reporter = ConsoleReporter.forRegistry(registry).build();
reporter.start(1, TimeUnit.SECONDS);
Meter meterTps = registry.meter(MetricRegistry.name(MeterTest.class, "request", "tps"));
while(true)
{
request(meterTps, random.nextInt(5));
Thread.sleep(1000);
}
}
}運(yùn)行結(jié)果
22-11-7 16:18:38 ===============================================================
-- Meters ----------------------------------------------------------------------
com.example.jkytest.modules.MeterTest.request.tps
count = 8
mean rate = 1.60 events/second
1-minute rate = 1.60 events/second
5-minute rate = 1.60 events/second
15-minute rate = 1.60 events/second
request
request
request
request
22-11-7 16:18:39 ===============================================================
-- Meters ----------------------------------------------------------------------
com.example.jkytest.modules.MeterTest.request.tps
count = 12
mean rate = 2.00 events/second
1-minute rate = 1.60 events/second
5-minute rate = 1.60 events/second
15-minute rate = 1.60 events/second
Histograms
Histogram統(tǒng)計(jì)數(shù)據(jù)的分布情況。比如最小值,最大值,中間值,還有中位數(shù),75百分位,90百分位,95百分位,98百分位,99百分位,和 99.9百分位的值(percentiles)。
package com.example.jkytest.modules;
import com.codahale.metrics.ConsoleReporter;
import com.codahale.metrics.ExponentiallyDecayingReservoir;
import com.codahale.metrics.Histogram;
import com.codahale.metrics.MetricRegistry;
import java.util.Random;
import java.util.concurrent.TimeUnit;
public class HistogramsTest {
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);
Histogram histogram = new Histogram(new ExponentiallyDecayingReservoir());
registry.register(MetricRegistry.name(HistogramsTest.class, "request", "histogram"), histogram);
while (true)
{
Thread.sleep(1000);
histogram.update(random.nextInt(100000));
}
}
}
運(yùn)行結(jié)果
-- Histograms ------------------------------------------------------------------
com.example.jkytest.modules.HistogramsTest.request.histogram
count = 1
min = 33246
max = 33246
mean = 33246.00
stddev = 0.00
median = 33246.00
75% <= 33246.00
95% <= 33246.00
98% <= 33246.00
99% <= 33246.00
99.9% <= 33246.00
22-11-7 16:26:34 ===============================================================
-- Histograms ------------------------------------------------------------------
com.example.jkytest.modules.HistogramsTest.request.histogram
count = 2
min = 33246
max = 68864
mean = 51188.56
stddev = 17808.50
median = 68864.00
75% <= 68864.00
95% <= 68864.00
98% <= 68864.00
99% <= 68864.00
99.9% <= 68864.00
Timers
Timer其實(shí)是 Histogram 和 Meter 的結(jié)合, histogram 某部分代碼/調(diào)用的耗時(shí), meter統(tǒng)計(jì)TPS。
package com.example.jkytest.modules;
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();
}
}
}
運(yùn)行結(jié)果
-- Timers ----------------------------------------------------------------------
com.example.jkytest.modules.TimerTest.get-latency
count = 1
mean rate = 1.00 calls/second
1-minute rate = 0.00 calls/second
5-minute rate = 0.00 calls/second
15-minute rate = 0.00 calls/second
min = 560.21 milliseconds
max = 560.21 milliseconds
mean = 560.21 milliseconds
stddev = 0.00 milliseconds
median = 560.21 milliseconds
75% <= 560.21 milliseconds
95% <= 560.21 milliseconds
98% <= 560.21 milliseconds
99% <= 560.21 milliseconds
99.9% <= 560.21 milliseconds
到此這篇關(guān)于Java Metrics系統(tǒng)性能監(jiān)控工具的使用詳解的文章就介紹到這了,更多相關(guān)Java Metrics系統(tǒng)性能監(jiān)控內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
java開發(fā)web前端cookie session及token會(huì)話機(jī)制詳解
如果把人體比作一個(gè)web系統(tǒng)的話,cookie、session和token就好像人體的經(jīng)絡(luò)和血管一樣,而web系統(tǒng)中的數(shù)據(jù),就好像人體的血液一樣。血液依靠著血管在人體內(nèi)流動(dòng),就如數(shù)據(jù)根據(jù)cookie和session機(jī)制在web系統(tǒng)中流動(dòng)一樣2021-10-10
Springboot 使用maven release插件執(zhí)行版本管理及打包操作
maven-release-plugin 可用于構(gòu)建release版本項(xiàng)目,實(shí)現(xiàn)自動(dòng)打tag、遞增版本號(hào)、分發(fā)release版本jar包至倉庫,接下來通過本文給大家介紹Springboot 使用maven release插件執(zhí)行版本管理及打包操作,需要的朋友可以參考下2022-03-03
MyBatis-Plus數(shù)據(jù)權(quán)限插件的簡(jiǎn)單使用
在MyBatis-Plus中,通過DataPermissionInterceptor插件實(shí)現(xiàn)數(shù)據(jù)權(quán)限控制,首先需要?jiǎng)?chuàng)建自定義注解和處理類,利用JSQLParser庫動(dòng)態(tài)修改SQL,實(shí)現(xiàn)按角色權(quán)限過濾數(shù)據(jù),配置類中注冊(cè)攔截器,確保只有授權(quán)用戶能訪問指定數(shù)據(jù),感興趣的可以了解一下2024-10-10
Java進(jìn)階教程之運(yùn)行時(shí)類型識(shí)別RTTI機(jī)制
這篇文章主要介紹了Java進(jìn)階教程之運(yùn)行時(shí)類型識(shí)別RTTI機(jī)制,在Java運(yùn)行時(shí),RTTI維護(hù)類的相關(guān)信息,比如多態(tài)(polymorphism)就是基于RTTI實(shí)現(xiàn)的,需要的朋友可以參考下2014-09-09
SpringBoot應(yīng)用程序啟動(dòng)監(jiān)聽功能的常見方法
應(yīng)用啟動(dòng)監(jiān)聽在?Spring?Boot?和其他框架中扮演著重要的角色,它們的主要作用是在應(yīng)用啟動(dòng)或關(guān)閉時(shí)觸發(fā)特定的操作或任務(wù),本文給大家介紹了SpringBoot應(yīng)用程序啟動(dòng)監(jiān)聽功能的常見方法,需要的朋友可以參考下2024-05-05
Struts2學(xué)習(xí)教程之自定義類型轉(zhuǎn)換器的方法
類型轉(zhuǎn)換器的作用是將請(qǐng)求中的字符串或字符串?dāng)?shù)組參數(shù)與action中的對(duì)象進(jìn)行相互轉(zhuǎn)換。下面這篇文章主要給大家介紹了關(guān)于Struts2學(xué)習(xí)教程之自定義類型轉(zhuǎn)換器的相關(guān)資料,文中通過示例代碼介紹的非常詳細(xì),需要的朋友可以參考下2018-05-05
SpringBoot集成selenium實(shí)現(xiàn)自動(dòng)化測(cè)試的代碼工程
Selenium?是支持web?瀏覽器自動(dòng)化的一系列工具和[庫]?它提供了擴(kuò)展來模擬用戶與瀏覽器的交互,用于擴(kuò)展瀏覽器分配的分發(fā),本文給大家介紹了SpringBoot集成selenium實(shí)現(xiàn)自動(dòng)化測(cè)試的代碼工程,需要的朋友可以參考下2024-08-08

