买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网获悉深圳华龙讯达信息技术股份有限公司申请的专利一种MQTT数据传输中的异常识别方法及系统获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN121619365B 。

龙图腾网通过国家知识产权局官网在2026-04-21发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202610141460.9，技术领域涉及：H04L67/55；该发明授权一种MQTT数据传输中的异常识别方法及系统是由胡丽华;龙小昂;宋阳;朱丹设计研发完成，并于2026-02-02向国家知识产权局提交的专利申请。

本一种MQTT数据传输中的异常识别方法及系统在说明书摘要公布了：本发明涉及数据传输技术领域，公开了一种MQTT数据传输中的异常识别方法及系统，该方法包括：接收客户端发送的MQTT发布报文，解析得到服务质量等级字段和主题名称字段；若服务质量等级字段为第一服务质量等级或第二服务质量等级，则将发布选项对象推送至发布队列；根据主题名称字段匹配订阅客户端集合并获取每个订阅客户端的网络信道对象，通过网络信道对象构造MQTT推送报文并发送至对应订阅客户端，本发明能够并行处理同一消息事件，避免了传统队列的锁竞争开销，使单个发布队列即可支撑每秒百万级的消息吞吐量，消息推送延迟可控制在微秒级，满足工业互联网实时数据传输的性能要求，进而保障了数据传输的稳定性和可用性。

本发明授权一种MQTT数据传输中的异常识别方法及系统在权利要求书中公布了：1.一种MQTT数据传输中的异常识别方法，其特征在于，包括： 接收客户端发送的MQTT发布报文，解析得到服务质量等级字段和主题名称字段；具体包括：接收客户端发送的MQTT发布报文；通过前置事件拦截器链中的格式检查拦截器对所述MQTT发布报文中的主题名称字段进行长度和规范性验证，在长度和规范性验证通过之后，将所述MQTT发布报文传递至发布处理器；从所述MQTT发布报文中依次提取服务质量等级字段和主题名称字段； 若所述服务质量等级字段为第一服务质量等级或第二服务质量等级，则将发布选项对象推送至发布队列；具体包括：将所述服务质量等级字段和所述主题名称字段封装为发布选项对象；通过后置事件拦截器链中的消息统计拦截器获取所述发布选项对象；若所述服务质量等级字段为第一服务质量等级或第二服务质量等级，则将所述发布选项对象推送至发布队列； 从所述发布队列中获取所述发布选项对象并分发至消息推送执行消费者，所述消息推送执行消费者从所述发布选项对象中提取主题名称字段；具体包括：获取所述发布队列中发布选项对象的事件槽位；将所述发布选项对象的各字段数据拷贝至所述事件槽位中完成事件发布；所述消息推送执行消费者从所述事件槽位中读取所述发布选项对象，提取所述发布选项对象中的主题名称字段和客户端标识；在将所述发布选项对象的各字段数据拷贝至所述事件槽位中完成事件发布之后，还包括：客户端发送监控消费者从所述事件槽位中读取所述发布选项对象，提取所述客户端标识和负载数据，查询客户端存储器获取所述客户端标识对应的客户端信息对象，将所述客户端信息对象中的发送计数字段递增并将发送字节数字段累加所述负载数据的字节长度；消息频率监控消费者从所述事件槽位中读取所述发布选项对象，通过并发哈希映射表以所述客户端标识为键值递增消息计数并在统计周期结束时，将所述消息计数记录至消息客户端存储器； 根据所述主题名称字段匹配订阅客户端集合并获取每个订阅客户端的网络信道对象，通过所述网络信道对象构造MQTT推送报文并发送至对应订阅客户端；具体包括：从主题客户端映射表中获取所有订阅主题，将所述主题名称字段和各订阅主题进行匹配，将匹配成功的订阅客户端添加至订阅客户端集合；遍历所述订阅客户端集合提取每个订阅客户端的客户端标识，以所述客户端标识为键值从客户端信道映射表中查询网络信道对象；判断所述网络信道对象的连接状态是否有效，若有效，则将所述订阅客户端的客户端标识和所述网络信道对象添加至待推送列表；遍历所述待推送列表，根据所述发布选项对象中的主题名称字段、负载数据和服务质量等级字段构造MQTT推送报文；通过所述网络信道对象的发送接口将所述MQTT推送报文发送至对应订阅客户端，将所述MQTT推送报文的消息标识添加至未确认消息集合；还包括：若所述服务质量等级字段为第二服务质量等级，则创建延迟任务对象，调用延迟任务队列的优先队列添加接口将所述延迟任务对象加入队列；延迟消费者线程从所述延迟任务队列中阻塞获取延迟时间到期的所述延迟任务对象，提取所述延迟任务对象的消息标识并查询所述未确认消息集合是否存在；若存在，则从所述延迟任务对象中读取当前重试次数与最大重试次数，当所述当前重试次数小于所述最大重试次数时，将所述MQTT推送报文的重复标识字段设置为真并通过所述网络信道对象重新发送，同时对所述延迟任务对象的当前重试次数执行递增操作并重新添加至所述延迟任务队列。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人深圳华龙讯达信息技术股份有限公司，其通讯地址为：518033 广东省深圳市福田区福田街道福山社区金田路2030号卓越世纪中心、皇岗商务中心4号楼2501；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

以上内容由龙图腾AI智能生成。