[發(fā)明專利]分布式前置采集通訊鏈路的處理方法、裝置和計算機(jī)設(shè)備

有效

• 申請?zhí)枺?/td>: 201811630230.0
• 申請日: 2018-12-29
• 公開（公告）號: CN109525443B
• 公開（公告）日: 2019-12-10
• 發(fā)明（設(shè)計）人: 黃欣;危國恩;倫惠勤;劉有志;于全喜;王佳;譚軍光;吳任博;孔海濱
• 申請（專利權(quán)）人: 廣州供電局有限公司
• 主分類號: H04L12/24
• 分類號: H04L12/24;H02J13/00
• 代理公司: 44224 廣州華進(jìn)聯(lián)合專利商標(biāo)代理有限公司
• 代理人: 劉艷麗

1.一種分布式前置采集通訊鏈路的處理方法，所述方法包括：

根據(jù)歷史數(shù)據(jù)抽取串行路徑模型，所述串行路徑模型包含采集設(shè)備、規(guī)約、通道的索引；

根據(jù)所述采集設(shè)備、規(guī)約、通道的索引從組件池中組裝對應(yīng)的設(shè)備組件、規(guī)約組件和通道組件；

根據(jù)所述串行路徑模型確定報文消息轉(zhuǎn)換組件；

組合所述設(shè)備組件、規(guī)約組件、通道組件和所述報文消息轉(zhuǎn)換組件，形成用于指示采集通訊鏈路的串行路徑；

確定部署在前置第一節(jié)點上的通訊掃描器的狀態(tài)和連接的數(shù)量，所述連接的數(shù)量對應(yīng)已啟動的串行路徑的數(shù)量；

當(dāng)所述連接的數(shù)量超過所述通訊掃描器的預(yù)設(shè)上限時，將最新接入所述第一節(jié)點通訊掃描器的兩個連接分配至第二節(jié)點的通訊掃描器；或，

當(dāng)所述第一節(jié)點的通訊掃描器異常時，隔離所述第一節(jié)點。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

輪詢所述串行路徑；

根據(jù)輪詢結(jié)果管理所述串行路徑。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述串行路徑的類型包括暫態(tài)連接，所述根據(jù)輪詢結(jié)果管理所述串行路徑的步驟包括：

當(dāng)所述串行路徑中的報文消息轉(zhuǎn)換組件接收到遠(yuǎn)端采集設(shè)備的采集報文時，啟動所述串行路徑；

當(dāng)所述串行路徑處于啟動狀態(tài)且所述報文消息轉(zhuǎn)換組件在預(yù)設(shè)時間段內(nèi)沒有接收到遠(yuǎn)端采集設(shè)備的采集報文時，停止所述串行路徑。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述啟動所述串行路徑的步驟包括：

通過所述設(shè)備組件初始化TCP或UDP通訊鏈路；

通過所述通道組件與所述設(shè)備組件綁定IP和端口，并在建立連接后通知所述規(guī)約組件；

通過所述報文消息轉(zhuǎn)換組件接收所述遠(yuǎn)端采集設(shè)備發(fā)送的采集報文，根據(jù)所述規(guī)約組件將所述采集報文轉(zhuǎn)換為通訊消息，發(fā)送給生產(chǎn)者組件或消費者服務(wù)組件，完成與彈性消息總線的消息交互。

5.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述串行路徑的類型包括常態(tài)連接，所述根據(jù)輪詢結(jié)果管理所述串行路徑的步驟包括：

當(dāng)所述串行路徑對應(yīng)的服務(wù)為啟動狀態(tài)時，不停止所述串行路徑。

6.一種分布式前置采集通訊鏈路的處理裝置，其特征在于，所述裝置包括：

模型抽取模塊，用于根據(jù)歷史數(shù)據(jù)抽取串行路徑模型，所述串行路徑模型包含采集設(shè)備、規(guī)約、通道的索引；

組裝模塊，用于根據(jù)所述采集設(shè)備、規(guī)約、通道的索引從組件池中組裝對應(yīng)的設(shè)備組件、規(guī)約組件和通道組件；

組件確定模塊，用于根據(jù)所述串行路徑模型確定報文消息轉(zhuǎn)換組件；

組合模塊，用于組合所述設(shè)備組件、規(guī)約組件、通道組件和所述報文消息轉(zhuǎn)換組件，形成用于指示采集通訊鏈路的串行路徑；

確定模塊，用于確定部署在前置的第一節(jié)點上的通訊掃描器的狀態(tài)和連接的數(shù)量，該連接的數(shù)量對應(yīng)已啟動的串行路徑的數(shù)量；

接入模塊，用于當(dāng)該連接的數(shù)量超過該通訊掃描器的預(yù)設(shè)上限時，將最新接入該第一節(jié)點通訊掃描器的兩個連接分配至第二節(jié)點的通訊掃描器；

隔離模塊，用于當(dāng)該第一節(jié)點的通訊掃描器異常時，隔離該第一節(jié)點。

7.根據(jù)權(quán)利要求6所述的裝置，其特征在于，所述裝置還包括：

輪詢模塊，用于輪詢所述串行路徑；

管理模塊，用于根據(jù)輪詢結(jié)果管理所述串行路徑。

8.一種計算機(jī)設(shè)備，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機(jī)程序，其特征在于，所述處理器執(zhí)行所述計算機(jī)程序時實現(xiàn)權(quán)利要求1至5中任一項所述方法的步驟。

9.一種計算機(jī)可讀存儲介質(zhì)，其上存儲有計算機(jī)程序，其特征在于，所述計算機(jī)程序被處理器執(zhí)行時實現(xiàn)權(quán)利要求1至5中任一項所述的方法的步驟。