[發(fā)明專利]一種電力系統(tǒng)網(wǎng)絡(luò)中的消息分銷方法和裝置

在審

• 申請(qǐng)?zhí)枺?/td>: 201811042882.2
• 申請(qǐng)日: 2018-09-07
• 公開（公告）號(hào): CN109257301A
• 公開（公告）日: 2019-01-22
• 發(fā)明（設(shè)計(jì)）人: 胡宇航;卜凡榮;許式崇;汪洋
• 申請(qǐng)（專利權(quán)）人: 國網(wǎng)江蘇省電力有限公司蘇州供電分公司;國網(wǎng)江蘇省電力有限公司昆山市供電分公司;蘇州有志電子有限公司
• 主分類號(hào): H04L12/863
• 分類號(hào): H04L12/863;H04L12/66;G06F9/54
• 代理公司: 蘇州創(chuàng)元專利商標(biāo)事務(wù)所有限公司 32103
• 代理人: 孫仿衛(wèi)

本發(fā)明涉及一種電力系統(tǒng)網(wǎng)絡(luò)中的消息分銷方法，包括以下步驟：步驟1：將接收到各類數(shù)據(jù)分別進(jìn)行編碼封裝形成數(shù)據(jù)消息，然后通過ZMQ消息隊(duì)列發(fā)布數(shù)據(jù)消息；步驟2：訂閱ZMQ消息隊(duì)列的發(fā)布端口而獲得數(shù)據(jù)消息，對(duì)數(shù)據(jù)消息進(jìn)行分類編碼，從而獲得消息、會(huì)話、線程的關(guān)系鏈所構(gòu)成的消息體，并將消息推送至對(duì)應(yīng)線程；步驟3：調(diào)度線程對(duì)消息執(zhí)行對(duì)應(yīng)動(dòng)作，并歸還和銷毀消息體。本發(fā)明還提供一種應(yīng)用上述消息分銷方法的消息分銷裝置，包括消息接入模塊、消息分編模塊和消息銷歸模塊。本發(fā)明可以高效承載各種數(shù)據(jù)流的消息分銷，應(yīng)對(duì)數(shù)據(jù)流蜂擁沖擊。

技術(shù)領(lǐng)域

本發(fā)明屬于電力系統(tǒng)后端技術(shù)領(lǐng)域，具體涉及一種可擴(kuò)展的高效M2ST消息分銷方法和裝置。

背景技術(shù)

電力系統(tǒng)的網(wǎng)絡(luò)被分為多個(gè)網(wǎng)絡(luò)安全區(qū)，同一個(gè)網(wǎng)絡(luò)安全區(qū)中間或者不同網(wǎng)絡(luò)安全區(qū)之間都會(huì)部署很多通信網(wǎng)關(guān)。通信網(wǎng)關(guān)承載各種數(shù)據(jù)流的交互，通信網(wǎng)關(guān)數(shù)據(jù)效率和復(fù)雜度取決于其內(nèi)部消息分銷架構(gòu)。

針對(duì)上述電力系統(tǒng)網(wǎng)絡(luò)，迫切需要一種通用而高效的消息分銷技術(shù)集成在通信網(wǎng)關(guān)，完成各種數(shù)據(jù)流的擺渡和校驗(yàn)，完成大數(shù)據(jù)的高效流通，從而提高和保障電力系統(tǒng)工作效率。

發(fā)明內(nèi)容

本發(fā)明的目的是提供一種適用于電力系統(tǒng)網(wǎng)絡(luò)，能夠使通信網(wǎng)關(guān)能夠高效進(jìn)行數(shù)據(jù)交互的消息分銷方法。

為達(dá)到上述目的，本發(fā)明采用的技術(shù)方案是：

一種電力系統(tǒng)網(wǎng)絡(luò)中的消息分銷方法，應(yīng)用于通信網(wǎng)關(guān)中，所述消息分銷方法包括以下步驟：

步驟1：將接收到各類數(shù)據(jù)按照既定規(guī)則分別進(jìn)行編碼封裝形成對(duì)應(yīng)的數(shù)據(jù)消息，然后通過ZMQ消息隊(duì)列發(fā)布所述數(shù)據(jù)消息；

步驟2：訂閱所述ZMQ消息隊(duì)列的發(fā)布端口而獲得所述數(shù)據(jù)消息，根據(jù)所述數(shù)據(jù)消息的類型對(duì)其進(jìn)行分類編碼，從而獲得所述數(shù)據(jù)消息對(duì)應(yīng)的消息、會(huì)話、線程的關(guān)系鏈所構(gòu)成的消息體，并依據(jù)所述消息體將所述消息推送至對(duì)應(yīng)線程；

步驟3：調(diào)度所述線程對(duì)所述消息執(zhí)行對(duì)應(yīng)動(dòng)作而完成消息業(yè)務(wù)流程，并歸還和銷毀所述消息體。

所述步驟1中，接收到的數(shù)據(jù)包括事件數(shù)據(jù)、業(yè)務(wù)數(shù)據(jù)、音視頻流數(shù)據(jù)。

所述步驟1中，接收到的數(shù)據(jù)的類型具有可擴(kuò)展性。

所述步驟2中，將同一所述會(huì)話對(duì)應(yīng)的全部消息推送至關(guān)聯(lián)的線程。

所述步驟2中，對(duì)所述數(shù)據(jù)消息進(jìn)行分類編碼的方法為：先根據(jù)所述數(shù)據(jù)消息向消息池申請(qǐng)對(duì)應(yīng)消息，并根據(jù)所述消息生成所述對(duì)話，再對(duì)所述消息進(jìn)行編碼并綁定對(duì)應(yīng)所述線程，從而獲得所述數(shù)據(jù)消息對(duì)應(yīng)的消息、會(huì)話、線程的關(guān)系鏈所構(gòu)成的消息體。

所述步驟3中，根據(jù)業(yè)務(wù)邏輯模型對(duì)所述消息執(zhí)行對(duì)應(yīng)動(dòng)作。

本發(fā)明還提供一種應(yīng)用上述消息分銷方法的消息分銷裝置，其設(shè)置于通信網(wǎng)關(guān)中，所述消息分銷裝置包括：

消息接入模塊，所述消息接入模塊用于將接收到各類數(shù)據(jù)按照既定規(guī)則分別進(jìn)行編碼封裝形成對(duì)應(yīng)的數(shù)據(jù)消息，然后通過ZMQ消息隊(duì)列發(fā)布所述數(shù)據(jù)消息；

消息分編模塊，所述消息分編模塊用于訂閱所述ZMQ消息隊(duì)列的發(fā)布端口而獲得所述數(shù)據(jù)消息，根據(jù)所述數(shù)據(jù)消息的類型對(duì)其進(jìn)行分類編碼，從而獲得所述數(shù)據(jù)消息對(duì)應(yīng)的消息、會(huì)話、線程的關(guān)系鏈所構(gòu)成的消息體，并依據(jù)所述消息體將所述消息推送至對(duì)應(yīng)線程；

消息銷歸模塊，所述消息銷歸模塊用于調(diào)度所述線程對(duì)所述消息執(zhí)行對(duì)應(yīng)動(dòng)作而完成消息業(yè)務(wù)流程，并歸還和銷毀所述消息體。

優(yōu)選的，所述消息接入模塊包括：

用于將接收到各類數(shù)據(jù)按照既定規(guī)則分別進(jìn)行編碼封裝形成對(duì)應(yīng)的數(shù)據(jù)消息的接入組件；

用于通過ZMQ消息隊(duì)列發(fā)布所述數(shù)據(jù)消息的發(fā)布組件。