[發(fā)明專利]一種分布式水利RTU數(shù)據(jù)采集系統(tǒng)及方法

在審

• 申請?zhí)枺?/td>: 202010023292.6
• 申請日: 2020-01-09
• 公開（公告）號: CN111241101A
• 公開（公告）日: 2020-06-05
• 發(fā)明（設計）人: 向其星;陳俞安;李超文
• 申請（專利權(quán)）人: 深圳市東深電子股份有限公司
• 主分類號: G06F16/22
• 分類號: G06F16/22;G06F16/25;G06F16/28;G06F16/51;G06F9/46;G06F9/54;H04L29/08
• 代理公司: 北京德高行遠知識產(chǎn)權(quán)代理有限公司 11549
• 代理人: 吳襄帥

本發(fā)明公開一種分布式水利RTU數(shù)據(jù)采集系統(tǒng)及方法，包括RTU報文發(fā)送模塊、Netty接收模塊、第一MQ消息發(fā)布模塊、第一數(shù)據(jù)庫模塊、訂閱接收模塊、圖片報文判斷模塊、圖片數(shù)據(jù)包判斷模塊、Redis模塊、Redis讀取模塊、組裝生成模塊和第二數(shù)據(jù)庫模塊；該分布式水利RTU數(shù)據(jù)采集系統(tǒng)采用分布式架構(gòu)，基于被廣泛使用的Java網(wǎng)絡編程框架Netty，配合高性能的Redis數(shù)據(jù)庫以及NOSQL數(shù)據(jù)庫MongoDB、高吞吐的消息隊列Kafka。通過在接收報文、解析報文、存儲報文明文的各個環(huán)節(jié)，合理利用各種高性能框架或技術(shù)，使得在高并發(fā)情況下保證采集數(shù)據(jù)的時效性、完整性。

技術(shù)領域

本發(fā)明涉及一種分布式水利RTU數(shù)據(jù)采集系統(tǒng)及方法。

背景技術(shù)

隨著社會的不斷前進、信息化的高速發(fā)展，在水利行業(yè)監(jiān)測數(shù)據(jù)采集管理中，管理部門對其管理要求越來越精細化、智能化。

水文水資源部門管理的水文站網(wǎng)越來越密集。面對高頻的采集、海量的采集數(shù)據(jù)，研發(fā)出一款高性能、高可用的智能設備采集平臺可為管理單位在防洪搶險、水資源稅征收等場景提供精準、可靠的數(shù)據(jù)保障的系統(tǒng)是亟待解決的。

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

本發(fā)明要解決的技術(shù)問題是提供一種分布式水利RTU數(shù)據(jù)采集系統(tǒng),其采用分布式架構(gòu)，基于被廣泛使用的Java網(wǎng)絡編程框架 Netty，配合高性能的Redis數(shù)據(jù)庫以及NOSQL數(shù)據(jù)庫MongoDB、高吞吐的消息隊列Kafka。通過在接收報文、解析報文、存儲報文明文的各個環(huán)節(jié)，合理利用各種高性能框架或技術(shù)，使得在高并發(fā)情況下保證采集數(shù)據(jù)的時效性、完整性。

為解決上述問題，本發(fā)明采用如下技術(shù)方案：

一種分布式水利RTU數(shù)據(jù)采集系統(tǒng)，其特征在于：包括RTU報文發(fā)送模塊、Netty接收模塊、第一MQ消息發(fā)布模塊、第一數(shù)據(jù)庫模塊、訂閱接收模塊、圖片報文判斷模塊、圖片數(shù)據(jù)包判斷模塊、Redis 模塊、Redis讀取模塊、組裝生成模塊和第二數(shù)據(jù)庫模塊。

作為優(yōu)選，還包含有解析模塊、第二MQ消息發(fā)布模塊、第二訂閱接收模塊和發(fā)布數(shù)據(jù)服務模塊。

作為優(yōu)選，所述第一數(shù)據(jù)庫模塊為NoSQL數(shù)據(jù)庫。

作為優(yōu)選，所述第一數(shù)據(jù)庫模塊為MongoDB數(shù)據(jù)庫。

作為優(yōu)選，所述第二數(shù)據(jù)庫模塊為關(guān)系型數(shù)據(jù)庫模塊。

作為優(yōu)選，所述Netty接收模塊被配置為在RTU與Netty建立連接并創(chuàng)建處理通道之后，采用java中的HashMap以RTU的地址為key, 通道對象為value的方式存入內(nèi)存中，下次該RTU再上報的時候，根據(jù)RTU的地址直接從內(nèi)存中取到通道對象進行下一步處理，當該RTU 下線之后，從內(nèi)存中去掉該通道信息。

作為優(yōu)選，所述Netty接收模塊還被配置為響應RTU報文發(fā)送模塊,通知RTU報文發(fā)送模塊接收成功。

本發(fā)明還提供一種分布式水利RTU數(shù)據(jù)采集系統(tǒng)的工作方法：包括以下步驟：

S1：RTU發(fā)布報文；

S2：Netty接收報文，在RTU與Netty建立連接并創(chuàng)建處理通道之后，采用java中的HashMap以RTU的地址為key,通道對象為 value的方式存入內(nèi)存中，下次該RTU再上報時，根據(jù)RTU的地址直接從內(nèi)存中取到通道對象進行下一步處理，當該RTU下線之后，從內(nèi)存中去掉該通道信息；

S3：正常報文，Netty響應TUR，通知TUR接收成功；

S4：MQ發(fā)布消息并將報文存入數(shù)據(jù)庫；

S5：訂閱接收；

S6：圖片報文；

S7：判斷圖片報文是否為最后一個圖片數(shù)據(jù)包；