源码角度了解Skywalking之告警机制是怎么实现的
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了源码角度了解Skywalking之告警机制是怎么实现的相关的知识，希望对你有一定的参考价值。
源码角度了解Skywalking之告警机制是怎么实现的
我们在使用Skywalking的时候有没有想过它的告警机制是怎么实现的呢，本篇文章就介绍一下它的告警机制的实现机制
skywalking插件的源码部分在server-alarm-plugin 模块中
告警初始化
AlarmModuleProvider的prepare()方法进行了告警的初始化
@Override public void prepare() throws ServiceNotProvidedException, ModuleStartException
Reader applicationReader;
try
applicationReader = ResourceUtils.read("alarm-settings.yml");
catch (FileNotFoundException e)
throw new ModuleStartException("cant load alarm-settings.yml", e);
RulesReader reader = new RulesReader(applicationReader);
Rules rules = reader.readRules();
alarmRulesWatcher = new AlarmRulesWatcher(rules, this);
notifyHandler = new NotifyHandler(alarmRulesWatcher);
notifyHandler.init(new AlarmStandardPersistence());
this.registerServiceImplementation(MetricsNotify.class, notifyHandler);
- 读取alarm-settings.yml文件，这个文件中制定了告警的规则，比如我们可以设置某个服务的响应时间超过多少秒触发告警，告警信息也可以在这个配置文件中配置
- 读取的文件信息会解析保存到AlarmRule对象中
- 接下来创建NotifyHandler对象，调用init()方法进行初始化操作，具体就是将AlarmStandardPersistence对象和WebhookCallback对象加入告警信息集合中，然后调用AlarmCore的start()方法
- 注册MetricsNotify的服务实现类NotifyHandler
检查是否触发告警
AlarmCore是警报核心类，它的start()方法设置的固定线程池，每隔10s执行一次检查的线程，具体逻辑是当前时间与上次告警相差一分钟的时候调用RunningRule的check()方法进行告警检查，返回告警信息集合，如果集合不为空，就调用WebhookCallback和AlarmStandardPersistence的doAlarm()方法发送告警信息。
发送告警信息
AlarmStandardPersistence和WebhookCallback都是AlarmCallback接口的实现类
告警信息持久化
AlarmStandardPersistence将警报信息保存到数据库中持久化以供 UI 查询，它的doAlarm()方法具体逻辑是创建AlarmRecord对象，将告警信息保存到AlarmRecord中，然后通过RecordStreamProcessor进行持久化操作
发送告警信息给第三方
WebhookCallback是使用 SkyWalking 报警 webhook API 调用远程端点的类，第三方的告警地址同样是在alarm-settings.yml文件中配置，配置信息如下：
alarm-settings.yml文件：
webhooks:
- http://127.0.0.1/notify/
- http://127.0.0.1/wechat/
文件信息会解析放入到Rules类中的webhooks集合中，WebhookCallback的doAlarm()方法的具体逻辑就是构建http请求，携带告警信息发送Http请求给第三方
总结
这篇文章我们分析了skywalking的告警信息是怎么实现了，从告警的初始化过程，检查是否触发告警条件和具体发送告警信息，涉及到一个alarm-settings.yml配置文件，告警的初始化主要是加载配置文件中定义的告警规则，检查告警主要是通过定时线程池每隔10s创建线程来检测是否满足告警条件，具体是由RunningRule的check()方法来实现，告警信息可以通过AlarmStandardPersistence放入数据库中，也可以通过WebhookCallback来发送给第三方。
❤️ 感谢大家
如果你觉得这篇内容对你挺有有帮助的话：
- 欢迎关注我❤️，点赞
以上是关于源码角度了解Skywalking之告警机制是怎么实现的的主要内容，如果未能解决你的问题，请参考以下文章