一种分布式集群的电网监控告警消息处理方法.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113724100A(43)申请公布日2021.11.30(21)申请号202110996773.X(22)申请日2021.08.27(71)申请人广东电网有限责任公司地址510030广东省广州市越秀区东风东路757号申请人广东电网有限责任公司珠海供电局(72)发明人侯祖锋赵瑞锋李波徐春华刘谋君陈建钿黎皓彬(74)专利代理机构广州华进联合专利商标代理有限公司44224代理人王天庆(51)Int.Cl.G06Q50/06(2012.01)H04L12/24(2006.01)H04L29/08(2006.01)权利要求书2页说明书10页附图4页(54)发明名称一种分布式集群的电网监控告警消息处理方法(57)摘要本发明公开了分布式集群的电网监控告警消息处理方法，该方法通过接收远程测量设备发送的数据；根据数据生成告警消息，告警消息携带消息标识；将告警消息缓存至分布式消息队列中的目标消息队列，并生成告警消息的目标消息队列标识；在预设列表中记录告警消息的消息标识、目标消息队列标识和状态标记，状态标记为未读取；从预设列表中读取状态标记为未读取的目标消息标识，将目标消息标识对应的目标告警消息发送至客户端，并将目标消息标识的状态标记修改为已读取。基于本发明提供的方法，可以缓解电力监控系统在监控时容易出现消息堵塞和告警消息丢失的技术问题。CN113724100ACN113724100A权利要求书1/2页1.一种分布式集群的电网监控告警消息处理方法，其特征在于，所述方法包括：接收远程测量设备发送的数据；根据所述数据生成告警消息，所述告警消息携带消息标识；将所述告警消息缓存至分布式消息队列中的目标消息队列，并生成目标消息队列标识；在预设列表中记录所述告警消息的消息标识、目标消息队列标识和状态标记，所述状态标记为未读取；从所述预设列表中读取状态标记为未读取的目标消息标识和目标消息队列标识，从所述目标消息队列中将所述目标消息标识对应的目标告警消息发送至客户端，并将所述目标消息标识的状态标记修改为已读取。2.根据权利要求1所述的方法，其特征在于，所述消息标识包括唯一序列号；所述根据所述数据生成告警消息，所述告警消息携带消息标识，包括：当所述数据不在预设的正常阈值区间内时，生成告警消息，所述告警消息包括标识字段；生成唯一序列号，将所述唯一序列号写入所述标识字段中。3.根据权利要求2所述的方法，其特征在于，所述唯一序列号递增生成；所述从所述预设列表中读取状态标记为未读取的目标消息标识，包括：从所述预设列表中按照唯一序列号从小到大的顺序，读取状态标记为未读取的目标消息标识。4.根据权利要求2所述的方法，其特征在于，所述消息标识还包括等级标识符；在所述当所述数据不在预设的正常阈值区间内时，生成告警消息之后，还包括：根据所述告警消息确定故障类型；根据所述故障类型确定处理等级；将所述处理等级对应的等级标识符写入所述标识字段中。5.根据权利要求4所述的方法，其特征在于，所述预设列表包括多个列表区间，每个列表区间对应一个处理等级；所述在预设列表中记录所述告警消息的消息标识、目标消息队列标识和状态标记，包括：根据所述告警消息携带的等级标识符确定所述告警消息的目标处理等级；根据所述告警消息的目标处理等级确定所述告警消息的目标列表区间，在所述目标列表区间中记录所述告警消息的消息标识、目标消息队列标识和状态标记。6.根据权利要求1所述的方法，其特征在于，在所述从所述目标消息队列中将所述目标消息标识对应的目标告警消息发送至客户端，并将所述目标消息标识的状态标记修改为已读取之后，还包括：接收所述客户端返回的所述目标告警消息的响应消息，所述响应消息携带所述目标消息标识；将所述目标消息标识的状态标记修改为已发送。7.根据权利要求1所述的方法，其特征在于，在所述从所述目标消息队列中将所述目标消息标识对应的目标告警消息发送至客户端，并将所述目标消息标识的状态标记修改为已读取之后，还包括：2CN113724100A权利要求书2/2页接收所述客户端返回的所述目标告警消息的处理结果反馈消息，所述处理结果反馈消息携带所述目标消息标识；当所述处理结果反馈消息为告警处理成功时，将所述目标消息标识的状态标记修改为已处理成功。8.一种分布式集群的电网监控告警消息处理装置，其特征在于，包括：接收模块，用于接收远程测量设备发送的数据；告警消息生成模块，用于根据所述数据生成告警消息，所述告警消息携带消息标识；缓存模块，用于将所述告警消息缓存至分布式消息队列中的目标消息队列，并生成所述告警消息的目标消息队列标识；记录模块，用于在预设列表中记录所述告警消息的消息标识、目标消息队列标识和状态标记，所述状态标记为未读取；读取模块，用于从所述预设