同步操作将从 孙成成/xcollector 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
此项目主要用基于skywalking开源框架扩展collector接收器和改造agent探针组件,采用RocketMQ的方式进行消息采集以及消息预警等功能。尽可能去保留原功能,并且采取约定优于配置的方式进行接管监控。
新增我们消费端服务:skywalking-xcollector,项目进行操作开发接受,从我们mq的broker端进行接受消息和功能开发操作。
系统数据源入口,用于MQ消费端的消费入口,消费数据后,我们采用异步方式(内置pc)去处理,当然为了方便实现可以采用线程池功能进行线程获取数据之后,进行传入我们的数据源解析接口。完成相关反序列化后进行构建生产我们的product端与consumer端共有数据对象。(MessageSegment)。
根据数据源的接受阶段后,进行数据源的解析,我们采用三个维度存储数据:
思路借鉴与sk的思路方式
用于配置我们的相关规则预警以及预警阈值
错误预警发送情况数据 WARNING_Message 每次我们预警之后都会用于我们的存储记录,用于触发记录的操作 记录预警信息发送成功或者失败的记录。以及重试发送记录的信息汇总和 记录查看。
处理错误数据接口: 两个方面:1.处理存储我们相关的缓存记录,用于处理相关的记录错误出现的数据记录,为了提供预警功能提供了条件数据的基础。我们可以低耦合起来去处理数据。
触发器接口: 抽象的方案可以采用粗粒度方案抽象接口: 具体实现按照rule规则进行处理,默认出口为阈值触发方案。 可以控制开关:进行启动某种触发功能。 次数阈值触发:同一个应用下,超过阈值次数错误,便会启动触发器开关。发送异步信息请求到预警接口进行发送预警信息。 时间阈值触发:如果指定字段超过时间+次数阈值,则会进行触发。例如执行sql语句时间超过时间阈值。 自定义触发:可以自定义触发条件,开发者自行定义触发操作实现类。 预警接口: 调用预警接口:实现类,进行相应的预警操作,并且存储相应的实现类方法功能。
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。