一种基于消息队列的区域告警消息推送方法及系统.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN112702190A(43)申请公布日2021.04.23(21)申请号202011453397.1(22)申请日2020.12.11(71)申请人广东电力通信科技有限公司地址510080广东省广州市越秀区东风东路836号1座3201-3206室(72)发明人郭立玮温景新江映燕尹震超潘城李海涛吴振田连柯(74)专利代理机构南京禹为知识产权代理事务所(特殊普通合伙)32272代理人王晓东(51)Int.Cl.H04L12/24(2006.01)H04L12/26(2006.01)H04L12/863(2013.01)H04L29/08(2006.01)权利要求书2页说明书7页附图4页(54)发明名称一种基于消息队列的区域告警消息推送方法及系统(57)摘要本发明公开了一种基于消息队列的区域告警消息推送方法及系统，包括监听不同区域的告警信息并进行预处理；将处理后的告警信息通过发送组件发送信息；所述发送组件根据消息地区属性，将信息发送至对应的消息队列；用户客户端与所述对应消息列队相连接，获取对应区域的告警消息。采用消息队列的方式，通过部署告警消息监听程序集群，快速捕获不同区域的告警消息，使得信息处理有序、快速；消息发送组件根据消息的不同区域属性，把消息发送到相应的区域队列之中，并根据消息的获取情况，决定其保留时间，提高了信息传输速度和信息数据的完整性；用户只获取自身权限对应的区域信息，有效减低消息获取的压力，也清晰的区分消息获取的权限范围。CN112702190ACN112702190A权利要求书1/2页1.一种基于消息队列的区域告警消息推送方法，其特征在于：包括，监听不同区域的告警信息并进行预处理；将处理后的告警信息通过发送组件发送信息；所述发送组件根据消息地区属性，将信息发送至对应的消息队列；用户客户端与所述对应消息列队相连接，获取对应区域的告警消息。2.如权利要求1所述的基于消息队列的区域告警消息推送方法，其特征在于：所述监听不同区域的告警信息包括，在程序集中搭建多个监听程序，每个监听程序负责监听一个或多个地区的告警状态，捕获并处理告警信息，所述监听程序在监听区域中采集到的数量达到告警规则阈值时，触发告警信息。3.如权利要求2所述的基于消息队列的区域告警消息推送方法，其特征在于：所述通过发送组件发送信息包括，所述发送组件根据告警信息的不同区域进行批量打包，并进行多线程的信息发送，以便同时处理、批量发送大量告警信息。4.如权利要求1～3任一所述的基于消息队列的区域告警消息推送方法，其特征在于：所述将信息发送至对应的消息队列包括，将监听区域进行分组，不同地区设置不同的区域代码，以地级市作为地区级别划分标准，形成不同的地级市消息队列，并且各个地级市队列独立存储市内的告警信息，并且根据所述不同地区对应的不同区域代码建立地理数据库。5.如权利要求4所述的基于消息队列的区域告警消息推送方法，其特征在于：所述用户客户端获取对应区域的告警消息包括，用户在登录客户端时，首先对用户的权限配置进行检验，将所述用户账号自身的地区属性输入所述地理数据库中，根据所述地区属性与对应的区域代码进行匹配，将相同区域代码的所述用户账号和地级市消息队列建立连接，搭建消息获取通道，在进行连接后所述客户端实现信息监听，同时获取所述消息队列的信息。6.如权利要求5所述的基于消息队列的区域告警消息推送方法，其特征在于：所述消息通道包括，所述消息通道是单个用户跟所述地级市消息队列建立的通道，同个地区内的不同用户建立的通道互不影响，不同用户获取消息也互不干扰，所述地级市消息队列会判断是否所有用户通道都已经成功获取消息，当全部消息被通道信息获取后，消息会从队列中清除，保障后续的信息处理。7.如权利要求1或6所述的基于消息队列的区域告警消息推送方法，其特征在于：所述预处理包括，按区域对所述告警信息进行信息分析、信息过滤、信息加工以及类型分拣等处理，消除重复、无用的信息。8.一种基于消息队列的区域告警消息推送系统，其特征在于：包括，告警信息采集模块(100)用于采集各个区域的告警信息，并且对所述采集到的告警信息进行预处理，由程序集群构成，在所述程序集群中包含多个监听程序，监听一个或多个区域的告警状态；2CN112702190A权利要求书2/2页信息发送组件(200)与所述告警信息采集模块(100)相连接，将所述预处理后的告警信息，进行批量打包并多线程发送；消息队列(300)与所述信息发送组件(200)相连接，将不同地区按照不同区域代码进行分组，构建地级市消息队列，将打包的不同区域的信息存放至对应的所述地级市消息队列；用户信息匹配模块(400)连接于所述消息队列(300)，用于检验用户在登录客户端时所使用的账