國網江西省電力有限公司信息通信分公司劉小康獲國家專利權
買專利賣專利找龍圖騰,真高效! 查專利查商標用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或微信搜索“龍圖騰網”。
1、本報告根據公開、合法渠道獲得相關數據和信息,力求客觀、公正,但并不保證數據的最終完整性和準確性。
2、報告中的分析和結論僅反映本公司于發布本報告當日的職業理解,僅供參考使用,不能作為本公司承擔任何法律責任的依據或者憑證。