[發(fā)明專利]一種電力系統(tǒng)消息總線監(jiān)視方法和裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 202110053151.3
• 申請(qǐng)日: 2021-01-15
• 公開(kāi)（公告）號(hào): CN112865311B
• 公開(kāi)（公告）日: 2022-11-01
• 發(fā)明（設(shè)計(jì)）人: 王恒;尚學(xué)偉;劉濤;武楊;趙林;謝俊;馬云龍;徐遐齡;陳宏福;米為民;魯佳雷;湯衛(wèi)東;王躍;甘忠;于宏文;李西太;韋洋;范澤龍
• 申請(qǐng)（專利權(quán)）人: 北京科東電力控制系統(tǒng)有限責(zé)任公司;國(guó)網(wǎng)電力科學(xué)研究院有限公司;國(guó)網(wǎng)上海市電力公司;國(guó)家電網(wǎng)公司華中分部;國(guó)家電網(wǎng)有限公司
• 主分類號(hào): H02J13/00
• 分類號(hào): H02J13/00;H04L41/0677;H04L41/069
• 代理公司: 南京蘇高專利商標(biāo)事務(wù)所(普通合伙) 32204
• 代理人: 柏尚春

1.一種電力系統(tǒng)消息總線監(jiān)視方法，其特征在于，包括：

各節(jié)點(diǎn)對(duì)來(lái)自消息總線的消息監(jiān)視信息進(jìn)行采集與匯聚，包括：對(duì)共享內(nèi)存和鎖進(jìn)行初始化，獲取當(dāng)前節(jié)點(diǎn)的本地主機(jī)名和節(jié)點(diǎn) ID 以及注冊(cè)進(jìn)程管理；然后判斷當(dāng)前節(jié)點(diǎn)在配置文件中是被設(shè)置為服務(wù)端節(jié)點(diǎn)還是被設(shè)置為客戶端節(jié)點(diǎn)，如果是服務(wù)端節(jié)點(diǎn)則創(chuàng)建服務(wù)端線程、消息同步服務(wù)端線程和消息同步客戶端線程；如果是服務(wù)端節(jié)點(diǎn)則創(chuàng)建消息同步客戶端線程；

在各節(jié)點(diǎn)上對(duì)匯聚的消息監(jiān)視信息展示，包括：在各節(jié)點(diǎn)上對(duì)當(dāng)前節(jié)點(diǎn)的運(yùn)行狀態(tài)監(jiān)控信息、消息流量統(tǒng)計(jì)信息、節(jié)點(diǎn)監(jiān)控詳情信息進(jìn)行展示；所述運(yùn)行狀態(tài)監(jiān)控信息包括：各節(jié)點(diǎn)秒級(jí)、分鐘級(jí)、小時(shí)級(jí)有無(wú)收發(fā)消息，各節(jié)點(diǎn)所有應(yīng)用的消息隊(duì)列有無(wú)消息堆積的情況，以及是否存在異常節(jié)點(diǎn)；所述異常節(jié)點(diǎn)是指在分鐘級(jí)時(shí)間粒度內(nèi)沒(méi)有與其他節(jié)點(diǎn)發(fā)生消息交互的節(jié)點(diǎn)；所述消息流量統(tǒng)計(jì)信息包括：從秒級(jí)、分鐘級(jí)、小時(shí)級(jí)三種時(shí)間維度統(tǒng)計(jì)的各節(jié)點(diǎn)消息總線的發(fā)送消息流量、接收消息流量、收發(fā)消息總流量；所述節(jié)點(diǎn)監(jiān)控詳情信息包括：指定域名、態(tài)名、通道名、時(shí)間粒度中的一項(xiàng)或幾項(xiàng)作為檢索條件對(duì)發(fā)送消息流量或接收消息流量進(jìn)行詳細(xì)信息查詢后得到的信息；

各節(jié)點(diǎn)對(duì)消息監(jiān)視信息進(jìn)行落盤存儲(chǔ)，包括：對(duì)于重要的監(jiān)視信息，以日志形式落盤存儲(chǔ)在文件系統(tǒng)中，以備后期的回溯和追查；日志文件記錄了程序運(yùn)行的過(guò)程中的一些關(guān)鍵數(shù)據(jù)，全面記錄消息總線的啟動(dòng)、退出、故障的運(yùn)行信息，記錄消息發(fā)送失敗、丟包重傳、重復(fù)消息過(guò)濾的關(guān)鍵信息。

2.根據(jù)權(quán)利要求 1 所述的電力系統(tǒng)消息總線監(jiān)視方法，其特征在于，所述服務(wù)端線程包括：調(diào)用服務(wù)注冊(cè)接口注冊(cè)服務(wù)，使用請(qǐng)求/響應(yīng)模型發(fā)布服務(wù)，然后在回調(diào)函數(shù)中對(duì)服務(wù)請(qǐng)求進(jìn)行處理，回調(diào)函數(shù)判斷服務(wù)請(qǐng)求所要查詢的節(jié)點(diǎn)是否為當(dāng)前節(jié)點(diǎn)，若是當(dāng)前節(jié)點(diǎn)則調(diào)用本地查詢函數(shù)，反之則在緩沖區(qū)內(nèi)進(jìn)行查詢；查詢時(shí)通過(guò)操作碼和檢索項(xiàng)選擇對(duì)應(yīng)接口，將查詢結(jié)果拼接為應(yīng)答報(bào)文返回。

3.根據(jù)權(quán)利要求 1 所述的電力系統(tǒng)消息總線監(jiān)視方法，其特征在于，所述消息同步服務(wù)端線程包括：調(diào)用初始化函數(shù)對(duì)服務(wù)端進(jìn)行初始化，然后注冊(cè)文件描述符上的事件放在事件表中，監(jiān)聽(tīng)并檢測(cè)到文件描述符上的 I/O 事件發(fā)生時(shí)，接口返回 I/O 事件數(shù)目，對(duì)應(yīng)的文件描述符和事件類型則通過(guò)輸出參數(shù)返回；遍歷所有的 I/O 事件，通過(guò)事件中的文件描述符判斷連接性質(zhì)，若為監(jiān)聽(tīng)套接字接收到的 I/O 事件，代表有新的客戶端申請(qǐng)連接，此時(shí)應(yīng)該接受連接并將該客戶端注冊(cè)到事件表中；若不是監(jiān)聽(tīng)套接字接收到的 I/O事件，代表已經(jīng)連接的客戶端在發(fā)送數(shù)據(jù)，此時(shí)應(yīng)接收來(lái)自其他節(jié)點(diǎn)同步過(guò)來(lái)的監(jiān)控信息；在接收來(lái)自其他節(jié)點(diǎn)同步過(guò)來(lái)的監(jiān)控信息的過(guò)程中，需要接收三次同步報(bào)文，第一次是接收同步報(bào)文頭并對(duì)其進(jìn)行合法性檢查、更新節(jié)點(diǎn)運(yùn)行狀態(tài)信息，第二次是接收監(jiān)控信息數(shù)目并獲取同步報(bào)文長(zhǎng)度，第三次是接收同步報(bào)文內(nèi)容并解析，解析過(guò)程主要是將同步報(bào)文的流量、訂閱和隊(duì)列三項(xiàng)內(nèi)容分別放到內(nèi)存中的相應(yīng)容器，包括所有節(jié)點(diǎn)的流量信息，通道訂閱信息和消息隊(duì)列信息。

4.根據(jù)權(quán)利要求 1 所述的電力系統(tǒng)消息總線監(jiān)視方法，其特征在于，所述消息同步客戶端線程包括：為每個(gè)服務(wù)器節(jié)點(diǎn)建立消息同步客戶端請(qǐng)求線程，在該線程中完成客戶端的初始化和與服務(wù)端的連接；然后從共享內(nèi)存中讀取本節(jié)點(diǎn)的流量信息、訂閱信息和消息隊(duì)列信息寫入到緩存，并將本節(jié)點(diǎn)相應(yīng)監(jiān)控信息拷貝到同步報(bào)文體中；最后發(fā)送三次同步報(bào)文，其中任何一個(gè)失敗都要重新連接服務(wù)端，以保持收發(fā)次序的一致性，客戶端周期性地向服務(wù)端推送監(jiān)控信息，周期由配置文件獲取。

5.根據(jù)權(quán)利要求 1 所述監(jiān)視方法的電力系統(tǒng)消息總線監(jiān)視裝置，設(shè)于各客戶端節(jié)點(diǎn)和服務(wù)端節(jié)點(diǎn)處，其特征在于，包括：

用于對(duì)來(lái)自消息總線的消息監(jiān)視信息進(jìn)行采集與匯聚的組件；

用于對(duì)匯聚的消息監(jiān)視信息展示的組件；

用于對(duì)消息監(jiān)視信息進(jìn)行落盤存儲(chǔ)的組件。