预览加载中,请您耐心等待几秒...
1/10
2/10
3/10
4/10
5/10
6/10
7/10
8/10
9/10
10/10

亲,该文档总共19页,到这已经超出免费预览范围,如果喜欢就直接下载吧~

如果您无法下载资料,请参考说明:

1、部分资料下载需要金币,请确保您的账户上有足够的金币

2、已购买过的文档,再次下载不重复扣费

3、资料包下载后请先用软件解压,在使用对应软件打开

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN114125049A(43)申请公布日2022.03.01(21)申请号202111359858.3(22)申请日2021.11.17(71)申请人珠海优特电力科技股份有限公司地址519000广东省珠海市高新区金鼎工业园金鸿七路68号(72)发明人洪建兵王群飞杨家才刘灿民王岗(74)专利代理机构北京市京大律师事务所11321代理人胡安(51)Int.Cl.H04L67/55(2022.01)H04L67/12(2022.01)H04Q9/00(2006.01)权利要求书2页说明书12页附图4页(54)发明名称遥测消息处理方法、装置、设备及存储介质(57)摘要本发明涉及物联网技术领域,公开了一种遥测消息处理方法、装置、设备及存储介质,用于实现消息转换处理的松耦合,提高遥测消息处理的兼容性和消息处理操作的灵活性。所述遥测消息处理方法包括:获取目标物联终端设备上报的遥测消息,所述遥测消息包括原始消息体和产品模型标识;获取所述产品模型标识对应的设备类型标识,并根据所述产品模型标识和所述设备类型标识确定遥测属性映射关系;按照所述遥测属性映射关系将所述原始消息体转换为目标消息体;根据所述设备类型标识获取消息规则,并通过预设的消息引擎按照所述消息规则对所述目标消息体进行消息处理操作。CN114125049ACN114125049A权利要求书1/2页1.一种遥测消息处理方法,其特征在于,所述遥测消息处理方法包括:获取目标物联终端设备上报的遥测消息,所述遥测消息包括原始消息体和产品模型标识;获取所述产品模型标识对应的设备类型标识,并根据所述产品模型标识和所述设备类型标识确定遥测属性映射关系;按照所述遥测属性映射关系将所述原始消息体转换为目标消息体;根据所述设备类型标识获取消息规则,并通过预设的消息引擎按照所述消息规则对所述目标消息体进行消息处理操作。2.根据权利要求1所述的遥测消息处理方法,其特征在于,所述获取所述产品模型标识对应的设备类型标识,并根据所述产品模型标识和所述设备类型标识确定遥测属性映射关系,包括:根据所述产品模型标识从预设的设备类型映射表中读取对应的设备类型标识;根据所述设备类型标识和所述产品模型标识查询预设的遥测属性映射表,得到遥测属性映射关系。3.根据权利要求1所述的遥测消息处理方法,其特征在于,所述按照所述遥测属性映射关系将所述原始消息体转换为目标消息体,包括:对所述原始消息体进行反序列化处理,得到已处理消息体对象;根据所述遥测属性映射关系对所述已处理消息体对象对应的各产品属性名进行替换处理,得到已替换消息体对象;按照预置计算系数更新所述已替换消息体对象对应的遥测属性值,得到目标消息体,并将所述目标消息体存储至预设的消息队列中,所述目标消息体用于指示预设锁控系统识别的设备数据包。4.根据权利要求1所述的遥测消息处理方法,其特征在于,所述根据所述设备类型标识获取消息规则,并通过预设的消息引擎按照所述消息规则对所述目标消息体进行消息处理操作,包括:根据所述设备类型标识从预设的规则配置表中读取消息规则,所述消息规则包括格式化消息内容、验证逻辑、消息推送方式和延迟发送时长、重发次数和重发间隔;通过预设的消息引擎判断所述目标消息体是否符合所述验证逻辑;若所述目标消息体符合所述验证逻辑,则按照所述格式化消息内容和所述目标消息体生成待处理消息,所述待处理消息为预警类型消息、通知类型消息或命令类型消息;根据所述消息推送方式和所述延迟发送时长对所述待处理消息进行消息推送,得到推送结果;当所述推送结果为推送成功时,从预设的消息队列中删除所述待处理消息;当所述推送结果为推送失败时,按照所述重发次数和所述重发间隔对所述待处理消息进行重新发送。5.根据权利要求4所述的遥测消息处理方法,其特征在于,所述根据所述消息推送方式和所述延迟发送时长对所述待处理消息进行消息推送,得到推送结果,包括:判断所述延迟发送时长是否为预设值;若所述延迟发送时长为预设值,则调用预设的实时消息线程池将所述待处理消息推送2CN114125049A权利要求书2/2页至消息中间件中,并通过所述消息中间件按照所述消息推送方式将所述待处理消息推送至消息终端,得到推送结果;若所述延迟发送时长不为预设值,则通过预设的延时消息线程池按照所述消息推送方式将所述待处理消息推送至消息终端,得到推送结果。6.根据权利要求4所述的遥测消息处理方法,其特征在于,所述当所述推送结果为推送失败时,按照所述重发次数和所述重发间隔对所述待处理消息进行重新发送,包括:当所述推送结果为推送失败时,将所述预设的消息队列中所述待处理消息迁移至预设的待发送消息内存表中;通过所述预设的消息引擎按照所述重发次数和所述重发间隔对所述待发送消息内存表