专栏名称: ImportNew
伯乐在线旗下账号,专注Java技术分享,包括Java基础技术、进阶技能、架构设计和Java技术领域动态等。
目录
相关文章推荐
51好读  ›  专栏  ›  ImportNew

基于 kafka,zabbix 构建应用统计数据收集展示系统

ImportNew  · 公众号  · Java  · 2017-01-15 20:08

正文

(点击 上方公众号 ,可快速关注)


源:hengyunabc,

blog.csdn.net/hengyunabc/article/details/44072285

如有好文章投稿,请点击 → 这里了解详情


想要实现的功能


  • 应用可以用少量的代码,实现统计某类数据的功能


  • 统计的数据可以很方便地展示


metrics


metrics,按字面意思是度量,指标。


举具体的例子来说,一个web服务器:


- 一分钟内请求多少次?

- 平均请求耗时多长?

- 最长请求时间?

- 某个方法的被调用次数,时长?


以缓存为例:


- 平均查询缓存时间?

- 缓存获取不命中的次数/比例?


以jvm为例:


- GC的次数?

- Old Space的大小?


在一个应用里,需要收集的metrics数据是多种多样的,需求也是各不同的。需要一个统一的metrics收集,统计,展示平台。


流行的metrics的库


https://github.com/dropwizard/metrics


Java实现,很多开源项目用到,比如Hadoop,kafka。下面称为dropwizard/metrics。


https://github.com/tumblr/colossus


Scala实现,把数据存到OpenTsdb上。


spring boot 项目里的metrics:


http://docs.spring.io/spring-boot/docs/current/reference/html/production-ready-metrics.html


spring boot里的metrics很多都是参考dropwizard/metrics的。


metrics的种类


dropwizard/metrics 里主要把metrics分为下面几大类:


https://dropwizard.github.io/metrics/3.1.0/getting-started/


Gauges


gauge用于测量一个数值。比如队列的长度:


public class QueueManager {

private final Queue queue;

public QueueManager(MetricRegistry metrics, String name) {

this.queue = new Queue();

metrics.register(MetricRegistry.name(QueueManager.class, name, "size"),

new Gauge () {

@Override

public Integer getValue() {

return queue.size();

}

});

}

}


Counters


counter是AtomicLong类型的gauge。比如可以统计阻塞在队列里的job的数量:


private final Counter pendingJobs = metrics.counter(name(QueueManager.class, "pending-jobs"));

public void addJob(Job job) {

pendingJobs.inc();

queue.offer(job);

}

public Job takeJob() {

pendingJobs.dec();

return queue.take();

}


Histograms


histogram统计数据的分布。比如最小值,最大值,中间值,还有中位数,75百分位, 90百分位, 95百分位, 98百分位, 99百分位, and 99.9百分位的值(percentiles)。


比如request的大小的分布:


private final Histogram responseSizes = metrics.histogram(name(RequestHandler.class, "response-sizes"));

public void handleRequest(Request request, Response response) {

// etc

responseSizes.update(response.getContent().length);

}


Timers


timer正如其名,统计的是某部分代码/调用的运行时间。比如统计response的耗时:


private final Timer responses = metrics.timer(name(RequestHandler.class, "responses"));

public String handleRequest(Request request, Response response) {

final Timer.Context context = responses.time();

try {

// etc;

return "OK";

} finally {

context.stop();

}

}


Health Checks


这个实际上不是统计数据。是接口让用户可以自己判断系统的健康状态。如判断数据库是否连接正常:


final HealthCheckRegistry healthChecks = new HealthCheckRegistry();

public class DatabaseHealthCheck extends HealthCheck {

private final Database database;







请到「今天看啥」查看全文