(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211222313.2 (22)申请日 2022.10.08 (71)申请人 中国电信股份有限公司 地址 100033 北京市西城区金融大街31号 (72)发明人 余锦福　林晓岚　章威　向勇　 卢伟鹏　 (74)专利代理 机构 北京律智知识产权代理有限 公司 11438 专利代理师 孙宝海 (51)Int.Cl. H04L 67/565(2022.01) H04L 67/12(2022.01) H04L 67/1008(2022.01) (54)发明名称 物联网消息处理方法、 装置、 系统、 设备及存 储介质 (57)摘要 本公开提供了一种物联网消息处理方法、 装 置、 系统、 设备及存储介质， 涉及通信技术领域。 该方法应用于消息中间件， 包括： 基于MQTT协议 与物联网设备建立通信连接； 基于高级消息队列 协议AMQP与服务器建立通信连接； 接收物联网设 备发送的MQTT消息； 根据预设的消息转换规则， 将所述MQTT消息转换为AMQP消息； 根据预先存储 的绑定路由规则， 将所述AMQP消息存储至对应的 消息队列； 将所述消息队列中的消息分发至与所 述消息队列绑定的服务器， 以使所述服务器对所 述消息队列进行消费。 通过上述方法， 将物联网 设备的MQTT消息转换为AMQP消息， 便于服务器进 行负载均衡处理， 解决了MQTT消息订阅的多实例 消息重复消费的问题。 权利要求书2页 说明书11页 附图6页 CN 115550438 A 2022.12.30 CN 115550438 A 1.一种物联网消息处 理方法， 其特 征在于， 包括： 基于消息队列遥测传输 MQTT协议与物联网设备建立 通信连接； 基于高级消息队列协议AMQP与服 务器建立 通信连接； 接收物联网设备发送的MQT T消息； 根据预设的消息转换规则， 将所述MQT T消息转换为AMQP消息； 根据预先存储的绑定路由规则， 将所述AMQP消息存 储至对应的消息队列； 将所述消息队列中的消息分发至服 务器， 以使所述 服务器对所述消息队列进行消费。 2.根据权利要求1所述的物联网消息处理方法， 其特征在于， 所述MQTT消息的消息格 式 包括消息主题、 主题层 级分隔符和通配符； 所述AMQP消息的消息格式包括消息主题、 主题单 层分隔符和通配符； 所述消息转换规则配置为对所述MQTT消息的主题层级分隔符和所述 AMQP消息的主题层级分隔符进行替换。 3.根据权利要求1所述的物联网消息处理方法， 其特征在于， 根据 预先存储的绑定路由 规则， 将所述AMQP消息存 储至对应的消息队列， 包括： 通过主题 交换机获取所述AMQP消息， 所述主题交换机预先配置有与所述消息队列绑定 的绑定键； 将所述AMQP消息与所述绑定 键进行主题规则匹配， 得到匹配结果； 根据所述匹配结果将所述AMQP消息存 储至对应的消息队列。 4.根据权利要求3所述的物联网消息处理方法， 其特征在于， 所述绑定键包括主题字段 和通配符， 以使所述消息队列对所有 主题字段相同的消息进行存 储。 5.根据权利要求1所述的物联网消息处理方法， 其特征在于， 所述服务器包括与多个服 务实例， 多个所述 服务实例对所述消息队列进行消费。 6.根据权利要求5所述的物联网消息处理方法， 其特征在于， 将所述消息队列中的消息 分发至服 务器， 包括： 按照轮询机制将所述消息队列中的消息平均分发给多个服 务实例。 7.根据权利要求5所述的物联网消息处理方法， 其特征在于， 将所述消息队列中的消息 分发至服 务器， 包括： 对于所述消息队列中每 个待分发的消息， 执 行以下步骤： 接收多个所述 服务实例发送的负载情况； 根据所述负载情况确定负载最小的服 务实例， 作为目标服 务器； 将所述待分发的消息发送至所述目标服 务器。 8.根据权利要求1所述的物联网消息处 理方法， 其特 征在于， 所述方法还 包括： 接收所述 服务器发送的AMQP消息； 根据预设的消息转换规则， 将所述AMQP消息转换为MQT T主题消息； 将所述MQT T主题消息推送到订阅对应主题的物联网设备。 9.根据权利要求1所述的物联网消息处理方法， 其特征在于， 所述方法还包括： 所述服 务器接收到所述AMQP消息后， 对 所述AMQP消息进行 处理， 得到处理结果， 将所述处理结果存 储在分布式KV存 储服务器中。 10.一种物联网消息处 理装置， 其特 征在于， 包括： 第一通信模块， 用于基于 MQTT协议与物联网设备建立 通信连接； 第二通信模块， 用于基于高级消息队列协议AMQP与服 务器建立 通信连接；权　利　要　求　书 1/2 页 2 CN 115550438 A 2MQTT消息接收模块， 用于 接收物联网设备发送的MQT T消息； 消息转换模块， 用于根据预设的消息转换规则， 将所述MQT T消息转换为AMQP消息； 消息存储模块， 用于根据预先存储的绑定路由规则， 将所述AMQP消息存储至对应的消 息队列； 消息分发模块， 用于将所述消息队列中的消息分发至与所述消息队列绑定的服务器， 以使所述 服务器对所述消息队列进行消费。 11.一种物联网通信系统， 其特征在于， 包括物联网设备、 服务器以及如权利要求10所 述的物联网消息处 理装置。 12.一种电子设备， 其特 征在于， 处 理器； 以及 存储器， 用于存 储所述处 理器的可 执行指令； 其中， 所述处理器配置为经由执行所述可执行指令来执行权利要求1～9中任意一项所 述的物联网消息处 理方法。 13.一种计算机可读存储介质， 其上存储有计算机程序， 其特征在于， 所述计算机程序 被处理器执行时实现权利要求1～ 9中任意一项所述的物联网消息处 理方法。权　利　要　求　书 2/2 页 3 CN 115550438 A 3