项目完整名称:alarm_monitor 项目完成日期:20181108 项目功能介绍:
- 该项目作为kafka消费者,拉去消息队列的报警消息进行报警处理。
- 支持消费指定topic下的所有partition,分布式部署时数据消费不重复。
- 支持消费指定topic下的特定一个或者多个partition,分布式部署时数据消费不重复。 如服务1指定消费partition为1和2,服务2指定消费partition为3和4。
- 支持多种报警策略,但是目前仅支持钉钉机器人报警,如果需要可以基于业务需要进行 扩展,如邮件报警等。
技术/设计介绍:
- 该项目是用golang语言实现的。
- MySQL是自己写了一个简易版ORM,虽说简易但是已满足自己的需求,支持增删改查、还支 持批量插入操作等。
- 针对Redis操作,自己在调用redigo时,追加了池、操作锁、普通命令的封装等。
- 报警逻辑:报警方式、报警间隔时间和接收对象可配,报警之后,在指定的间隔时间内不会 重复报警。