[發(fā)明專利]一種基于Netty的大屏可視化平臺(tái)數(shù)據(jù)推送系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201310022454.4
• 申請(qǐng)日: 2013-01-18
• 公開(kāi)（公告）號(hào): CN103077246A
• 公開(kāi)（公告）日: 2013-05-01
• 發(fā)明（設(shè)計(jì)）人: 邱玉祥;唐汗青;王泉嘯;嚴(yán)晴;武玉峰
• 申請(qǐng)（專利權(quán)）人: 國(guó)網(wǎng)電力科學(xué)研究院;南京南瑞集團(tuán)公司;國(guó)家電網(wǎng)公司
• 主分類號(hào): G06F17/30
• 分類號(hào): G06F17/30
• 代理公司: 南京縱橫知識(shí)產(chǎn)權(quán)代理有限公司 32224
• 代理人: 董建林

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

本發(fā)明涉及一種基于Netty的大屏可視化平臺(tái)數(shù)據(jù)推送系統(tǒng)，在多源異構(gòu)數(shù)據(jù)接入大屏可視化系統(tǒng)時(shí)，并發(fā)連接數(shù)據(jù)高、數(shù)據(jù)更新周期短、數(shù)據(jù)量大的場(chǎng)景上仍能保證數(shù)據(jù)轉(zhuǎn)換及分發(fā)調(diào)度、穩(wěn)定推送、實(shí)時(shí)更新。

背景技術(shù)

國(guó)家電網(wǎng)公司信息調(diào)度運(yùn)行監(jiān)控中心大屏可視化展示系統(tǒng)、國(guó)家電網(wǎng)災(zāi)備中心大屏可視化系統(tǒng)和運(yùn)營(yíng)檢測(cè)大屏可視化平臺(tái)，展示的數(shù)據(jù)內(nèi)容豐富且結(jié)構(gòu)復(fù)雜。為了實(shí)現(xiàn)來(lái)自不同單位、不同系統(tǒng)的數(shù)據(jù)的整體統(tǒng)一，國(guó)家電網(wǎng)公司信息系統(tǒng)經(jīng)歷了SG186的整合建設(shè)，但是各系統(tǒng)內(nèi)的數(shù)據(jù)結(jié)構(gòu)仍存在不同的差異，主要體現(xiàn)在數(shù)據(jù)指標(biāo)的內(nèi)涵與外延在系統(tǒng)中的概念不同，這主要是因?yàn)閿?shù)據(jù)來(lái)自不同單位，而同一系統(tǒng)在不同單位的數(shù)據(jù)結(jié)構(gòu)完全不相同，跨單位數(shù)據(jù)指標(biāo)存在采集不及時(shí)、不完整、推送頻率不同的情況。

由于數(shù)據(jù)最終以圖形化方式進(jìn)行展示，這對(duì)數(shù)據(jù)的合規(guī)性提出了更高的要求，尤其是曲線類指標(biāo)，任意時(shí)間點(diǎn)的數(shù)據(jù)超出合理范圍都會(huì)引起曲線的異動(dòng)，而且這種異常是非常直觀、醒目的。因此實(shí)時(shí)接收到的數(shù)據(jù)，需經(jīng)過(guò)一系統(tǒng)中間過(guò)程，諸如解碼、轉(zhuǎn)換、過(guò)濾、計(jì)算后，把數(shù)據(jù)直接推送至相關(guān)訂閱的客戶端，實(shí)現(xiàn)對(duì)數(shù)據(jù)實(shí)時(shí)更新，滿足客戶端對(duì)數(shù)據(jù)實(shí)時(shí)性的需求以及提高用戶體驗(yàn)度、友好性。

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

發(fā)明目的：針對(duì)傳統(tǒng)的堵塞IO多線程模式不能滿足大屏可視化平臺(tái)大數(shù)據(jù)實(shí)時(shí)、穩(wěn)定推送的問(wèn)題，本發(fā)明提出一種基于Netty的大屏可視化平臺(tái)的數(shù)據(jù)推送系統(tǒng)，通過(guò)異步的、事件驅(qū)動(dòng)的網(wǎng)絡(luò)應(yīng)用程序框架把數(shù)據(jù)直接推送至相關(guān)訂閱的客戶端，實(shí)現(xiàn)了對(duì)數(shù)據(jù)實(shí)時(shí)更新。

技術(shù)方案：為實(shí)現(xiàn)上述目的，本發(fā)明采用的技術(shù)方案為：

Netty是由JBOSS提供的一個(gè)java開(kāi)源框架。Netty提供異步的、事件驅(qū)動(dòng)的網(wǎng)絡(luò)應(yīng)用程序框架和工具，用以快速開(kāi)發(fā)高性能、高可靠性的網(wǎng)絡(luò)服務(wù)器和客戶端程序。

一種基于Netty的大屏可視化平臺(tái)數(shù)據(jù)推送系統(tǒng)，包括數(shù)據(jù)采集服務(wù)層、數(shù)據(jù)集查詢服務(wù)層和客戶端展現(xiàn)層，

所述數(shù)據(jù)采集服務(wù)層用于將外部的多源異構(gòu)數(shù)據(jù)接入到可視化平臺(tái)內(nèi)；

所述數(shù)據(jù)集查詢服務(wù)層用于將外部接入到可視化平臺(tái)內(nèi)的數(shù)據(jù)轉(zhuǎn)換成內(nèi)部的消息實(shí)體，并將這些消息實(shí)體放置到相應(yīng)的消息隊(duì)列上，通過(guò)消息隊(duì)列調(diào)度器提供給相應(yīng)的Netty管道；

所述客戶端展現(xiàn)層用于通過(guò)Netty管道推送方式解析消息實(shí)體獲取數(shù)據(jù)集數(shù)據(jù)，并將數(shù)據(jù)集數(shù)據(jù)與控件進(jìn)行關(guān)聯(lián)，刷新控件數(shù)據(jù)；

其中，Netty管道將消息處理器以隊(duì)列的形式順序組織起來(lái)，形成處理數(shù)據(jù)流的上下文。

上述系統(tǒng)，首先將外部數(shù)據(jù)源數(shù)據(jù)接入到可視化平臺(tái)之中，再將接入的數(shù)據(jù)轉(zhuǎn)換成可視化平臺(tái)的內(nèi)部消息實(shí)體，將消息實(shí)體放置到消息隊(duì)列中，并通過(guò)消息隊(duì)列調(diào)度器提供給相應(yīng)的Netty管道，通過(guò)Netty管道中的各個(gè)消息處理器的順序處理，最終將得到的數(shù)據(jù)集推送至客戶端（客戶端展現(xiàn)層），客戶端通過(guò)客戶端的狀態(tài)列表定位來(lái)相關(guān)客戶端的展現(xiàn)數(shù)據(jù)集，從而實(shí)現(xiàn)數(shù)據(jù)的實(shí)時(shí)更新功能。消息處理的核心由若干個(gè)消息處理器組成，不同的消息處理器的功能也不盡相同，而Netty管道將這些消息處理器以隊(duì)列的形式順序組織起來(lái)，形成處理數(shù)據(jù)流的上下文，通過(guò)對(duì)消息處理器的調(diào)度實(shí)現(xiàn)諸如對(duì)消息解碼、存儲(chǔ)、轉(zhuǎn)換等功能；同時(shí)，管道中輸出的數(shù)據(jù)為為界面展現(xiàn)提供了數(shù)據(jù)來(lái)源。

在數(shù)據(jù)采集服務(wù)層中，外部的多源異構(gòu)數(shù)據(jù)包括不同程序、不同協(xié)議、不同操作系統(tǒng)、不同位置的數(shù)據(jù)，數(shù)據(jù)采集服務(wù)層允入不同外部系統(tǒng)的數(shù)據(jù)通過(guò)不同協(xié)議上報(bào)到可視化平臺(tái)內(nèi)，所述數(shù)據(jù)采集服務(wù)層的數(shù)據(jù)接入方式包括JMS、WEBSERVICE、SOCKET等。

優(yōu)選的，所述數(shù)據(jù)集查詢服務(wù)層的采集服務(wù)方式包括可視化系統(tǒng)服務(wù)和SQL服務(wù)兩種，數(shù)據(jù)集查詢服務(wù)層的工作流程包括以下步驟：

（a1）前置處理類處理；

（a2）首先通過(guò)指標(biāo)采集服務(wù)定義獲得采集服務(wù)方式；

（a3）若采集服務(wù)方式為可視化系統(tǒng)服務(wù)，則后臺(tái)將可視化數(shù)據(jù)原的配置信息解析為SQL語(yǔ)句并行執(zhí)行，并將查詢的數(shù)據(jù)封裝為VSDataset對(duì)象；

（a4）若采集服務(wù)方式為SQL方式，則根據(jù)客戶端展現(xiàn)層配置的SQL語(yǔ)句直接執(zhí)行，并將查詢的數(shù)據(jù)封裝為VSDataset對(duì)象；

（a5）后置處理類處理。

優(yōu)選的，所述客戶端展現(xiàn)層的工作流程包括以下步驟：

（b1）首先將需要發(fā)送的數(shù)據(jù)加入隊(duì)列中，按照隊(duì)列的調(diào)度順序發(fā)送數(shù)據(jù)；

（b2）Netty編碼器響應(yīng)，將數(shù)據(jù)對(duì)象序列化為Hessian二進(jìn)制流；