[發(fā)明專利]一種實時數(shù)據(jù)庫冗余的工控系統(tǒng)數(shù)據(jù)傳輸方法和系統(tǒng)

在審

• 申請?zhí)枺?/td>: 202111064431.0
• 申請日: 2021-09-10
• 公開（公告）號: CN113779148A
• 公開（公告）日: 2021-12-10
• 發(fā)明（設(shè)計）人: 馬瑞瑞;何清;王毅;何新
• 申請（專利權(quán)）人: 西安熱工研究院有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/23;G06F11/14
• 代理公司: 西安通大專利代理有限責(zé)任公司 61200
• 代理人: 崔方方

1.一種實時數(shù)據(jù)庫冗余的工控系統(tǒng)數(shù)據(jù)傳輸方法，其特征在于，包括以下步驟:

數(shù)據(jù)采集接口同時向兩路數(shù)據(jù)傳輸中間件上傳數(shù)據(jù)，并寫入兩路工業(yè)實時數(shù)據(jù)庫中；

若檢測到一路數(shù)據(jù)傳輸中間件到工業(yè)實時數(shù)據(jù)庫的寫數(shù)鏈路中斷，記錄所述寫路數(shù)據(jù)中斷的數(shù)據(jù)時間段信息；

當讀、寫數(shù)據(jù)鏈路恢復(fù)后，向所述數(shù)據(jù)傳輸中間件上報未上傳的數(shù)據(jù)時間段信息；

所述數(shù)據(jù)傳輸中間件啟動數(shù)據(jù)同步服務(wù)進程，通過另一路數(shù)據(jù)傳輸中間件從其實時數(shù)據(jù)庫中抽取歷史數(shù)據(jù)，并補寫數(shù)據(jù)到恢復(fù)網(wǎng)絡(luò)通訊的工業(yè)實時數(shù)據(jù)庫中。

2.根據(jù)權(quán)利要求1所述的實時數(shù)據(jù)庫冗余的工控系統(tǒng)數(shù)據(jù)傳輸方法，其特征在于，

所述兩路工業(yè)實時數(shù)據(jù)庫的測點表配置完全一致。

3.根據(jù)權(quán)利要求1所述的實時數(shù)據(jù)庫冗余的工控系統(tǒng)數(shù)據(jù)傳輸方法，其特征在于，

所述記錄該路數(shù)據(jù)上傳中斷的數(shù)據(jù)時間段信息是指所有未上傳數(shù)據(jù)集合的時間最小值到最大值的時間差。

4.根據(jù)權(quán)利要求1所述的實時數(shù)據(jù)庫冗余的工控系統(tǒng)數(shù)據(jù)傳輸方法，其特征在于，

所述數(shù)據(jù)同步服務(wù)在數(shù)據(jù)傳輸中間件讀、寫鏈路都正常時，才執(zhí)行補寫數(shù)據(jù)到恢復(fù)網(wǎng)絡(luò)通訊的工業(yè)實時數(shù)據(jù)庫中的任務(wù)，否則處于等待狀態(tài)；任務(wù)執(zhí)行完后，數(shù)據(jù)同步服務(wù)進入休眠狀態(tài)，等待下次喚醒。

5.一種實時數(shù)據(jù)庫冗余的工控系統(tǒng)數(shù)據(jù)傳輸系統(tǒng)，其特征在于，包括:

上傳寫入單元，用于數(shù)據(jù)采集接口同時向兩路數(shù)據(jù)傳輸中間件上傳數(shù)據(jù)，并寫入兩路工業(yè)實時數(shù)據(jù)庫中；

中斷檢測單元，用于若檢測到一路數(shù)據(jù)傳輸中間件到工業(yè)實時數(shù)據(jù)庫的寫數(shù)鏈路中斷，記錄所述寫路數(shù)據(jù)中斷的數(shù)據(jù)時間段信息；

恢復(fù)上報單元，用于當讀、寫數(shù)據(jù)鏈路恢復(fù)后，向所述數(shù)據(jù)傳輸中間件上報未上傳的數(shù)據(jù)時間段信息；

數(shù)據(jù)同步單元，用于所述數(shù)據(jù)傳輸中間件啟動數(shù)據(jù)同步服務(wù)進程，通過另一路數(shù)據(jù)傳輸中間件從其實時數(shù)據(jù)庫中抽取歷史數(shù)據(jù)，并補寫數(shù)據(jù)到恢復(fù)網(wǎng)絡(luò)通訊的工業(yè)實時數(shù)據(jù)庫中。

6.根據(jù)權(quán)利要求5所述的實時數(shù)據(jù)庫冗余的工控系統(tǒng)數(shù)據(jù)傳輸系統(tǒng)，其特征在于，

所述中斷檢測單元記錄該路數(shù)據(jù)上傳中斷的數(shù)據(jù)時間段信息是指所有未上傳數(shù)據(jù)集合的時間最小值到最大值的時間差。

7.根據(jù)權(quán)利要求5所述的實時數(shù)據(jù)庫冗余的工控系統(tǒng)數(shù)據(jù)傳輸系統(tǒng)，其特征在于，

所述數(shù)據(jù)同步服務(wù)在數(shù)據(jù)傳輸中間件讀、寫鏈路都正常時，才執(zhí)行補寫數(shù)據(jù)到恢復(fù)網(wǎng)絡(luò)通訊的工業(yè)實時數(shù)據(jù)庫中的任務(wù)，否則處于等待狀態(tài)；任務(wù)執(zhí)行完后，數(shù)據(jù)同步服務(wù)進入休眠狀態(tài)，等待下次喚醒。

8.一種實時數(shù)據(jù)庫冗余的工控系統(tǒng)數(shù)據(jù)傳輸系統(tǒng)，其特征在于，包括：主/從數(shù)據(jù)采集接口服務(wù)器、兩個數(shù)據(jù)上傳服務(wù)器、代理HA服務(wù)器、兩個數(shù)據(jù)傳輸中間件服務(wù)器、兩個數(shù)據(jù)同步服務(wù)器和兩個工業(yè)實時數(shù)據(jù)庫；

所述主/從數(shù)據(jù)采集接口服務(wù)器采用雙機熱備冗余架構(gòu)，用于從工控系統(tǒng)采集生產(chǎn)過程實時數(shù)據(jù)；

所述數(shù)據(jù)上傳服務(wù)器，用于將采集到的數(shù)據(jù)上傳至數(shù)據(jù)傳輸中間件；

所述代理HA服務(wù)器，用于第三方應(yīng)用程序接口雙路寫數(shù)據(jù)的冗余處理；

所述主/從數(shù)據(jù)采集接口服務(wù)器和代理HA服務(wù)器同時與兩臺數(shù)據(jù)傳輸中間件服務(wù)器相連接，將數(shù)據(jù)轉(zhuǎn)發(fā)至兩個數(shù)據(jù)傳輸中間件服務(wù)器，再分別寫入兩個工業(yè)實時數(shù)據(jù)庫中；

所述數(shù)據(jù)同步服務(wù)器，用于數(shù)據(jù)傳輸中間件服務(wù)器的子服務(wù)，分別本地化運行在兩個數(shù)據(jù)傳輸中間件服務(wù)器中，由數(shù)據(jù)傳輸中間件進行調(diào)度，完成實時數(shù)據(jù)庫的數(shù)據(jù)同步任務(wù)。

9.根據(jù)權(quán)利要求8所述的實時數(shù)據(jù)庫冗余的工控系統(tǒng)數(shù)據(jù)傳輸系統(tǒng)，其特征在于，

所述數(shù)據(jù)上傳服務(wù)器設(shè)置在數(shù)據(jù)采集接口服務(wù)器上，作為數(shù)據(jù)采集接口服務(wù)器的子服務(wù)運行；如果數(shù)據(jù)采集接口服務(wù)器受工控系統(tǒng)數(shù)據(jù)發(fā)布接口技術(shù)限制，或無法保證兩路數(shù)據(jù)采集接口服務(wù)器數(shù)據(jù)上傳不出現(xiàn)沖突時，將數(shù)據(jù)采集接口服務(wù)器的上傳服務(wù)器設(shè)置到代理HA服務(wù)器上，由代理HA服務(wù)器進行數(shù)據(jù)集合，再通過雙路轉(zhuǎn)發(fā)至兩個數(shù)據(jù)傳輸中間件服務(wù)器。

10.一種電子設(shè)備，包括存儲器、處理器以及存儲在所述存儲器中并可在所述處理器上運行的計算機程序，所述處理器執(zhí)行所述計算機程序時實現(xiàn)如權(quán)利要求1-4任一項所述的實時數(shù)據(jù)庫冗余的工控系統(tǒng)數(shù)據(jù)傳輸方法的步驟。