136 日志监控告警系统案例（代码实现）

整体结构

LogMonitorTopologyMain驱动类

KafkaSpout获取数据源

FilterBolt用来过滤日志信息

主要是过滤格式和校验appId是否合法。

PrepareRecordBolt发送邮件告警和短信告警

SaveMessage2MySq保存到数据库

核心类 MonitorHandler 所有流程处理的核心代码

7、运行结果

短信发送

邮件发送