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

龙图腾网获悉国网江西省电力有限公司信息通信分公司申请的专利基于Kafka消息队列的调控管理方法及系统获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN120223760B 。

龙图腾网通过国家知识产权局官网在2025-08-12发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202510669151.4，技术领域涉及：H04L67/61；该发明授权基于Kafka消息队列的调控管理方法及系统是由刘小康;章文腾;李思源;鄂驰;于仕;张尚军;肖子洋;王建旭;张新宇;邓燕楠设计研发完成，并于2025-05-23向国家知识产权局提交的专利申请。

本基于Kafka消息队列的调控管理方法及系统在说明书摘要公布了：本发明涉及数据处理技术领域，具体为基于Kafka消息队列的调控管理方法及系统。该发明基于历史消息流量与事件标签构建时间特征向量，结合KafkaBroker网络拓扑，通过图神经网络预测节点负载系数；依据消息优先级和节点负载系数进行队列调度，优化消息处理顺序；根据资源使用指标对计算、存储与网络资源进行解耦管理，判断是否触发扩缩容、副本迁移或限流调整；在边缘节点部署轻量Kafka实例，结合数据活跃度实现边缘与中心的分层存储，并异步完成数据同步；通过强化学习构建恢复策略模型，实现节点异常的自动识别与调控响应。

本发明授权基于Kafka消息队列的调控管理方法及系统在权利要求书中公布了：1.基于Kafka消息队列的调控管理方法，其特征在于，包括： 基于历史消息流量数据和事件标签构建时间特征向量，并将所述时间特征向量作为预训练图神经网络的节点输入，结合KafkaBroker网络拓扑构建图结构，预测各节点的负载系数并排序； 对各节点待处理消息进行标签分类并映射至逻辑优先级队列，依据服务等级协议进行动态调度； 根据各节点的系统资源使用指标，对计算资源、存储资源与网络资源的调度控制进行逻辑解耦，判断是否触发扩缩容、副本迁移或消息限流，并执行系统资源调整； 在边缘节点部署轻量化KafkaBroker实例，结合待处理消息的访问频率和数据活跃度实现边缘与中心分层存储，通过异步机制完成数据同步； 持续监测系统异常指标，基于强化学习构建策略模型，自动决策执行恢复动作并闭环调整，实现系统自愈； 对待处理消息进行标签分类并映射至逻辑优先级队列包括： 接收每条待处理消息，并提取其业务类型、任务紧急性与数据时效性； 根据预设优先级规则将消息打上优先级标签，包括实时、准实时和批处理； 根据优先级标签构建逻辑队列，将不同优先级标签的消息绑定至对应的逻辑队列； 所述服务等级协议根据待处理消息的逻辑优先级编号与所在节点的负载系数编号之和，确定各逻辑队列的调度优先级，并优先处理编号之和最大者； 对计算资源、存储资源与网络资源的调度控制进行逻辑解耦包括： 周期性采集节点的计算资源利用率，若计算资源利用率大于计算资源设定阈值，则触发Pod的自动扩容操作；反之，则触发Pod缩容操作； 实时监测节点的存储资源使用率，若存储资源使用率大于设定存储资源设定阈值，则触发分区副本迁移； 监测节点间的网络资源状态，若网络资源状态大于网络资源设定阈值，则触发低优先级消息限流。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人国网江西省电力有限公司信息通信分公司，其通讯地址为：330000 江西省南昌市南昌高新技术产业开发区昌东大道7077号；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。