[發(fā)明專利]基于KAFKA的網(wǎng)絡(luò)拓撲同步方法、設(shè)備、服務(wù)器及存儲介質(zhì)在審
| 申請?zhí)枺?/td> | 202310072471.2 | 申請日： | 2023-01-16 |
| 公開（公告）號： | CN116094938A | 公開（公告）日： | 2023-05-09 |
| 發(fā)明（設(shè)計）人： | 楊志鵬 | 申請（專利權(quán)）人： | 紫光云技術(shù)有限公司 |
| 主分類號： | H04L41/12 | 分類號： | H04L41/12;H04L45/02;H04L67/1095;H04L49/90;H04L43/103 |
| 代理公司： | 天津企興智財知識產(chǎn)權(quán)代理有限公司 12226 | 代理人： | 劉東 |
| 地址： | 300459 天津市濱海新區(qū)*** | 國省代碼： | 天津;12 |
| 權(quán)利要求書： | 查看更多 | 說明書： | 查看更多 |
| 摘要： | |||
| 搜索關(guān)鍵詞： | 基于 kafka 網(wǎng)絡(luò) 拓撲 同步 方法 設(shè)備 服務(wù)器 存儲 介質(zhì) | ||
1.基于KAFKA的網(wǎng)絡(luò)拓撲同步方法，其特征在于，所述方法包括：
服務(wù)啟動，獲取KAFKA集群信息，并建立與KAFKA集群的連接關(guān)系；
注冊推送虛機上線網(wǎng)卡信息算法；
獲取虛機上線網(wǎng)卡信息，拼接與所述虛機網(wǎng)卡信息相關(guān)的JSON報文數(shù)據(jù)，將所述JSON報文數(shù)據(jù)推送至KAFKA服務(wù)端，并注冊回調(diào)監(jiān)聽，其中，所述虛機上線網(wǎng)卡信息至少包括虛機所屬VPC_L3vni、虛機所屬CVK信息；
判斷是否回調(diào)成功，響應(yīng)于回調(diào)成功，CVK-AGENT進程對接收到KAFKA服務(wù)端中推送的所述JSON報文數(shù)據(jù)進行數(shù)據(jù)解析，并判斷當(dāng)前CVK中是否存在目標虛機所屬VPC_L3vni；
響應(yīng)于所述當(dāng)前CVK中存在所述目標虛機所屬VPC_L3vni，則構(gòu)建同步拓撲，進行VPC配置下發(fā)。
2.根據(jù)權(quán)利要求1所述的基于KAFKA的網(wǎng)絡(luò)拓撲同步方法，其特征在于：
所述虛機上線網(wǎng)卡信息還包括虛機網(wǎng)卡MAC地址和子網(wǎng)L2vni。
3.根據(jù)權(quán)利要求1所述的基于KAFKA的網(wǎng)絡(luò)拓撲同步方法，其特征在于，所述判斷是否回調(diào)成功，還包括：
響應(yīng)于回調(diào)失敗，記錄VPC配置下發(fā)操作日志，回滾Mysql中的相關(guān)數(shù)據(jù)，標記為不可用，并發(fā)送告警郵件。
4.根據(jù)權(quán)利要求1所述的基于KAFKA的網(wǎng)絡(luò)拓撲同步方法，其特征在于，所述響應(yīng)于回調(diào)成功之后，還包括：
存儲所述虛機上線網(wǎng)卡信息至Redis中，并將VPC加入至審計資源池中；
審計定時任務(wù)根據(jù)待審計的資源池數(shù)據(jù)，定時比對資源池中VPC的配置，完成數(shù)據(jù)檢測比對。
5.根據(jù)權(quán)利要求1所述的基于KAFKA的網(wǎng)絡(luò)拓撲同步方法，其特征在于，判斷所述當(dāng)前CVK中是否存在目標虛機所屬VPC_L3vni，還包括：
響應(yīng)于所述當(dāng)前CVK中不存在所述目標虛機所屬VPC_L3vni，則判斷所述JSON報文數(shù)據(jù)中的CVK信息是否為所述當(dāng)前CVK；
響應(yīng)于所述JSON報文數(shù)據(jù)中的CVK信息為所述當(dāng)前CVK，則從控制層拉取當(dāng)前對應(yīng)VPC的全量拓撲，完成配置下發(fā)。
6.根據(jù)權(quán)利要求5所述的基于KAFKA的網(wǎng)絡(luò)拓撲同步方法，其特征在于，所述判斷所述JSON報文數(shù)據(jù)中的CVK信息是否為所述當(dāng)前CVK，還包括：
響應(yīng)于所述JSON報文數(shù)據(jù)中的CVK信息不為所述當(dāng)前CVK,則丟棄消息，忽略相關(guān)配置下發(fā)。
7.一種電子設(shè)備，包括處理器，以及與處理器通信連接，且用于存儲所述處理器可執(zhí)行指令的存儲器，其特征在于：所述處理器執(zhí)行所述指令時實現(xiàn)權(quán)利要求1至6任一所述的基于KAFKA的網(wǎng)絡(luò)拓撲同步方法的步驟。
8.一種服務(wù)器，包括至少一個處理器，以及與所述處理器通信連接的存儲器，所述存儲器存儲有可被所述至少一個處理器執(zhí)行的指令，其特征在于：所述指令被所述處理器執(zhí)行，以使所述至少一個處理器執(zhí)行如權(quán)利要求1至6任一所述的基于KAFKA的網(wǎng)絡(luò)拓撲同步方法的步驟。
9.一種計算機可讀取存儲介質(zhì)，存儲有計算機程序，其特征在于：所述計算機程序被處理器執(zhí)行時實現(xiàn)權(quán)利要求1至6任一所述的基于KAFKA的網(wǎng)絡(luò)拓撲同步方法的步驟。
該專利技術(shù)資料僅供研究查看技術(shù)是否侵權(quán)等信息，商用須獲得專利權(quán)人授權(quán)。該專利全部權(quán)利屬于紫光云技術(shù)有限公司，未經(jīng)紫光云技術(shù)有限公司許可，擅自商用是侵權(quán)行為。如果您想購買此專利、獲得商業(yè)授權(quán)和技術(shù)合作，請聯(lián)系【客服】
本文鏈接：http://www.szxzyx.cn/pat/books/202310072471.2/1.html，轉(zhuǎn)載請聲明來源鉆瓜專利網(wǎng)。
- Kafka集群的數(shù)據(jù)傳送方法和裝置
- KAFKA消息隊列數(shù)監(jiān)控方法、裝置、電子設(shè)備及存儲介質(zhì)
- KAFKA主題監(jiān)控方法、裝置、電子設(shè)備及存儲介質(zhì)
- 基于容器的集群遷移方法及裝置
- kafka消息的測試方法、裝置、計算機設(shè)備及存儲介質(zhì)
- 基于kafka集群的數(shù)據(jù)寫入方法、裝置、電子設(shè)備、存儲介質(zhì)
- 一種可視化部署并管理kafka集群的方法
- kafka消息存儲系統(tǒng)、方法、裝置及計算機可讀存儲介質(zhì)
- 一種基于kafka-connect的數(shù)據(jù)傳遞方法
- 一種將Kafka長連接消費轉(zhuǎn)換成服務(wù)的方法
- 網(wǎng)絡(luò)和網(wǎng)絡(luò)終端
- 網(wǎng)絡(luò)DNA
- 網(wǎng)絡(luò)地址自適應(yīng)系統(tǒng)和方法及應(yīng)用系統(tǒng)和方法
- 網(wǎng)絡(luò)系統(tǒng)及網(wǎng)絡(luò)至網(wǎng)絡(luò)橋接器
- 一種電力線網(wǎng)絡(luò)中根節(jié)點網(wǎng)絡(luò)協(xié)調(diào)方法和系統(tǒng)
- 一種多網(wǎng)絡(luò)定位方法、存儲介質(zhì)及移動終端
- 網(wǎng)絡(luò)裝置、網(wǎng)絡(luò)系統(tǒng)、網(wǎng)絡(luò)方法以及網(wǎng)絡(luò)程序
- 從重復(fù)網(wǎng)絡(luò)地址自動恢復(fù)的方法、網(wǎng)絡(luò)設(shè)備及其存儲介質(zhì)
- 神經(jīng)網(wǎng)絡(luò)的訓(xùn)練方法、裝置及存儲介質(zhì)
- 網(wǎng)絡(luò)管理方法和裝置
- 動態(tài)分布式環(huán)境中的自動拓撲形成方法、系統(tǒng)及程序產(chǎn)品
- 一種網(wǎng)絡(luò)管理拓撲的處理方法及系統(tǒng)
- 物理拓撲使用管理方法和系統(tǒng)
- 拓撲適配方法及裝置
- 一種基于SNMP和HTML5實現(xiàn)web網(wǎng)絡(luò)拓撲的方法
- 一種網(wǎng)絡(luò)拓撲統(tǒng)一管理方法及系統(tǒng)
- 一種拓撲視圖的加載顯示方法及系統(tǒng)
- 開關(guān)磁阻電機功率拓撲推薦方法、系統(tǒng)、終端及存儲介質(zhì)
- 靈活定義的城域網(wǎng)網(wǎng)絡(luò)拓撲生成方法和裝置
- 一種網(wǎng)絡(luò)拓撲優(yōu)化方法、裝置以及系統(tǒng)
