Cat源码分析（三）：10种分析器

分析器的共同特点

一、消息分析器接口定义了如下方法，通过这些方法，我们可以知道分析器他要做哪些事

涉及到重要的功能方法：分析（analyze）、存储(doCheckpoint) 、销毁（destroy）

二、我们再来看看消息分析器的抽象实现类AbstractMessageAnalyzer做了什么

定义了两个重要的抽象方法：
a) doCheckpoint：存储
b) process：处理
c) loadReports：得到某一周期的reports
对analyze有明确的实现，对队列中的MessageTree进行消费，消费过程调用了process方法

三、具体分析器（为什么每一个分析器都要注入xxxDelegate,没有被调用到？？）
1．注入ReportManager 进行report的生成和持久化
2．具体实现了process的方法，不同类型进行不同的处理
3．。。。

四、 DefaultReportManager（委托模式：聚合代替继承，对类进行功能扩展）

注入ReportBucketManager：用于持久化到本地文件
注入ReportDelegate：帮助manager存储、生成report的工具类
注入dao：用于持久化到数据库

总结：不同的分析器首先对消息进行处理，之后通过reportManager生成报表，存于Report对象中，并持久化到本地文件或数据库

HeartBeatAnalyzer

每隔一分钟，client端会收集一次心跳状态，收集数据的线程在cat初始化过程中启动

process

获得message
获得report(HeartbeatReport类型的),根据不同项目类型，获得不同项目的report
将tree中的ip加入到report的m_ips中（这是一个set集合）
processTransaction(report, tree, (Transaction) message);
(1) 获得message的children
(2) 循环遍历message
- 如果是transaction类型的，则递归调用自己
- 如果是Heartbeat,则processHeartbeat
  a.从message中得到ip，根据ip从report中得到machine
  b.buildHeartBeatInfo(Machine machine, Heartbeat heartbeat, long timestamp)
  c.将period加入到machine的periods中

EventAnalyzer

TransactionAnalyzer

第二步调用m_reportManager.getHourlyReport，这个方法是根据开始时间得到对应的report,如果是新的周期还没有report,则调用m_reportDelegate.makeReport方法创建一个report,放到reports中，返回report

疑问：

为什么sum=duration*duration?
m_allDuration和m_durations有什么区别？粒度不同？但是展现只展现了m_durations，不知道m_allDuations用在什么场景？
checkForTruncatedMessage方法不明白什么意思
4.95、99如何计算？

MetricAnalyzer

初始化

业务分析有一个产品线的概念，层级关系如下，一个company可以有多个产品线，一个产品线可以包含多个domain，三者之间的映射关系配置在配置文件metricProductLine中

当cat启动的时候，会解析配置文件为具体的配置类，持久化到数据库中，当用到某个配置的时候会先从库中读取（config表），如果该表中没有相应的配置，则会读取xml文件，然后持久化到数据库。

当研究metric的时候，我自己搭了一套springmvc的项目做测试，发现在cat的页面中，出不来指标的图像，就是因为我没有将项目（domain）加到生产线下，所以我就更改了上述配置，但是还是不生效，因为每次读取该配置都是从库中读取，不会读取我修改后的xml文件，所以需要把库中的数据删除，才会读取修改后的xml文件，然后在往数据库存一份

循环一个company下的所有生产线，循环生产线下的domain，给生产线中的Map赋值, map<domainID,produceID>，因为processMetric的第一步就是通过这个map找到对应的生产线
Eg:

分析流程：

写在后边

这一篇总结了分析器的共性和4个重要分析器的工作原理，下一篇将介绍另外几种分析器的分析过程