[發(fā)明專利]面向用戶用電信息采集系統(tǒng)的實(shí)時數(shù)據(jù)共享系統(tǒng)

有效

• 申請?zhí)枺?/td>: 202011347471.1
• 申請日: 2020-11-26
• 公開（公告）號: CN112492024B
• 公開（公告）日: 2022-04-29
• 發(fā)明（設(shè)計(jì)）人: 黃威;謝儉;陳石東;唐義德;趙俊;張亞萌;齊明;李敏士;孫程;彭清舟
• 申請（專利權(quán)）人: 國網(wǎng)湖南省電力有限公司;國網(wǎng)湖南省電力有限公司信息通信分公司;國家電網(wǎng)有限公司
• 主分類號: H04L67/1095
• 分類號: H04L67/1095;H04L67/568;H04L9/40;G06F16/2455;G06F21/31;G06Q50/06
• 代理公司: 長沙永星專利商標(biāo)事務(wù)所(普通合伙) 43001
• 代理人: 周詠;米中業(yè)

1.一種面向用戶用電信息采集系統(tǒng)的實(shí)時數(shù)據(jù)共享系統(tǒng)，其特征在于包括流數(shù)據(jù)處理模塊、Redis緩存系統(tǒng)、Kafka共享通道和權(quán)限管理模塊；用電信息采集系統(tǒng)數(shù)據(jù)采集消息總線連接流數(shù)據(jù)處理模塊，流數(shù)據(jù)處理模塊的輸出端同時連接用電信息采集系統(tǒng)數(shù)據(jù)庫和Kafka共享通道；Redis緩存系統(tǒng)的輸入端連接用電信息采集系統(tǒng)數(shù)據(jù)庫，Redis緩存系統(tǒng)的輸出端連接流數(shù)據(jù)處理模塊；權(quán)限管理模塊連接外圍系統(tǒng)，權(quán)限管理模塊的輸入端連接外圍系統(tǒng)和Kafka共享通道，權(quán)限管理模塊的輸出端連接外圍系統(tǒng)和流數(shù)據(jù)處理模塊；Kafka共享通道連接外圍系統(tǒng)，同時Kafka共享通道的輸入端連接外圍系統(tǒng)和流數(shù)據(jù)處理模塊，Kafka共享通道的輸出端連接外圍系統(tǒng)和權(quán)限管理模塊；流數(shù)據(jù)處理模塊用于進(jìn)行數(shù)據(jù)流解析，然后把解析后的數(shù)據(jù)寫入到指定Kafka的主題中，同時流數(shù)據(jù)處理模塊還用于負(fù)責(zé)接收權(quán)限管理模塊下發(fā)的數(shù)據(jù)召測指令，并負(fù)責(zé)把指令轉(zhuǎn)發(fā)至用電信息采集系統(tǒng)數(shù)據(jù)采集消息總線；Redis緩存系統(tǒng)用于實(shí)現(xiàn)用電信息采集系統(tǒng)冷熱數(shù)據(jù)分離，以及緩存用電信息采集系統(tǒng)數(shù)據(jù)庫中的電網(wǎng)企業(yè)用戶的檔案數(shù)據(jù)；Kafka共享通道用于接受外圍系統(tǒng)的數(shù)據(jù)請求、實(shí)現(xiàn)用電信息采集系統(tǒng)日常批量實(shí)時數(shù)據(jù)的訂閱/發(fā)布共享以及向外圍系統(tǒng)返回召測的實(shí)時數(shù)據(jù)；權(quán)限管理模塊用于為外圍系統(tǒng)創(chuàng)建賬號及密碼、用于token的生產(chǎn)與返回、權(quán)限驗(yàn)證與指令下發(fā)以及權(quán)限的管理；所述面向用戶用電信息采集系統(tǒng)的實(shí)時數(shù)據(jù)共享系統(tǒng)用于實(shí)現(xiàn)日常批量數(shù)據(jù)的實(shí)時共享和實(shí)時召測數(shù)據(jù)的共享。

2.根據(jù)權(quán)利要求1所述的面向用戶用電信息采集系統(tǒng)的實(shí)時數(shù)據(jù)共享系統(tǒng)，其特征在于所述的流數(shù)據(jù)處理模塊，從Redis緩存系統(tǒng)中讀取系統(tǒng)用戶檔案信息，然后把采集設(shè)備的地址編號與采集計(jì)量點(diǎn)id、用戶戶號進(jìn)行關(guān)聯(lián)處理，處理后的數(shù)據(jù)以用戶戶號、計(jì)量點(diǎn)id作為數(shù)據(jù)內(nèi)容的標(biāo)識，以JSON格式結(jié)構(gòu)化數(shù)據(jù)寫入至Kafka共享通道對應(yīng)的主題中進(jìn)行共享。

3.根據(jù)權(quán)利要求2所述的面向用戶用電信息采集系統(tǒng)的實(shí)時數(shù)據(jù)共享系統(tǒng)，其特征在于所述的Kafka共享通道包括DataShareQueue、DataQueryQueue與DataBackQueue三個主題；DataShareQueue主題用于實(shí)現(xiàn)用電信息采集系統(tǒng)日常批量實(shí)時數(shù)據(jù)的訂閱/發(fā)布共享，外圍系統(tǒng)訂閱數(shù)據(jù)需求后，從DataShareQueue主題中讀取數(shù)據(jù)；DataQueryQueue主題用于接受外圍系統(tǒng)的實(shí)時數(shù)據(jù)召測請求；DataBackQueue主題用于向外圍系統(tǒng)返回召測的實(shí)時數(shù)據(jù)；不同的外圍系統(tǒng)分別屬于不同的消費(fèi)組，不同的消費(fèi)組可以獲取到相同的消息，實(shí)現(xiàn)數(shù)據(jù)廣播式共享發(fā)布；數(shù)據(jù)分享發(fā)布、雙向交互均采用JSON格式的消息進(jìn)行。

4.根據(jù)權(quán)利要求3所述的面向用戶用電信息采集系統(tǒng)的實(shí)時數(shù)據(jù)共享系統(tǒng)，其特征在于所述的權(quán)限管理模塊，用于為外圍系統(tǒng)創(chuàng)建賬號及密碼，外圍系統(tǒng)需要獲取用電信息采集系統(tǒng)數(shù)據(jù)時，需要通過權(quán)限管理模塊為其創(chuàng)建賬號；其次，權(quán)限管理模塊用于負(fù)責(zé)token生產(chǎn)與返回：用戶首次訪問時，通過“用戶+口令”的形式訪問權(quán)限管理模塊請求權(quán)限認(rèn)證與獲取權(quán)限token，權(quán)限管理模塊會對口令進(jìn)行認(rèn)證，認(rèn)證通過后權(quán)限管理模塊返回一個帶有訪問權(quán)限token；然后，權(quán)限管理模塊用于權(quán)限驗(yàn)證與數(shù)據(jù)召測指令下發(fā)：外部系統(tǒng)帶上用戶名和token請求數(shù)據(jù)時，對token的有效性及token對應(yīng)的權(quán)限進(jìn)行驗(yàn)證，若權(quán)限驗(yàn)證通過，則向流數(shù)據(jù)處理模塊發(fā)送數(shù)據(jù)召測的指令；最后，權(quán)限管理模塊用于為token配置相應(yīng)權(quán)限資源，同時負(fù)責(zé)對token有效期的管理。

5.根據(jù)權(quán)利要求4所述的面向用戶用電信息采集系統(tǒng)的實(shí)時數(shù)據(jù)共享系統(tǒng)，其特征在于所述的Redis緩存系統(tǒng)，具體包含分布式開源Redis鍵值系統(tǒng)和數(shù)據(jù)同步工具；分布式開源Redis鍵值系統(tǒng)采用主從架構(gòu)設(shè)計(jì)；數(shù)據(jù)同步工具由java開發(fā)，數(shù)據(jù)同步工具啟動后進(jìn)行初始化操作，從用電信息采集系統(tǒng)數(shù)據(jù)庫中批量加載電網(wǎng)企業(yè)用戶的檔案數(shù)據(jù)到分布式開源Redis鍵值系統(tǒng)中存儲；同時，數(shù)據(jù)同步工具以設(shè)定的周期從用電信息采集系統(tǒng)數(shù)據(jù)庫中同更新的檔案數(shù)據(jù)內(nèi)容到分布式開源Redis鍵值系統(tǒng)中，確保Redis緩存系統(tǒng)的數(shù)據(jù)內(nèi)容跟用電信息采集系統(tǒng)數(shù)據(jù)庫保持一致。