[發(fā)明專利]企業(yè)權威源系統(tǒng)數(shù)據(jù)實時推送方法

有效

• 申請?zhí)枺?/td>: 201410323087.6
• 申請日: 2014-07-08
• 公開（公告）號: CN104156798B
• 公開（公告）日: 2017-12-01
• 發(fā)明（設計）人: 高磊;莊光友;孟憲奎;李衛(wèi)陽;谷波;楊帆;石金平;桂湖
• 申請（專利權）人: 四川中電啟明星信息技術有限公司
• 主分類號: G06F19/00
• 分類號: G06F19/00;G06Q10/06;H04L29/06
• 代理公司: 成都君合集專利代理事務所(普通合伙)51228
• 代理人: 王宗江

技術領域

本發(fā)明涉及用信息技術領域，具體的說，是企業(yè)權威源系統(tǒng)數(shù)據(jù)實時推送方法。

背景技術

在企業(yè)信息架構中，特別是在大型企業(yè)信息化體系架構中，往往存在業(yè)務含意相同，而技術平臺以及存儲模型不同的信息，這使得企業(yè)的數(shù)據(jù)架構顯得混亂，難以管理。在這樣的場景下，通常的解決方法是確定一個權威源，由權威源對信息進行統(tǒng)籌管理，相關的系統(tǒng)通過與權威源進行數(shù)據(jù)集成實現(xiàn)數(shù)據(jù)共享。這就要求作為權威源的系統(tǒng)應具備跨系統(tǒng)數(shù)據(jù)推送能力，其基本方法是當權威源所管理的信息發(fā)生變化之后，實時將變化信息推送到關聯(lián)系統(tǒng)，實現(xiàn)數(shù)據(jù)在企業(yè)內部的一致性。

關于數(shù)據(jù)一致性問題，尤其是實時一致性，在企業(yè)應用架構中面臨一些難題。它的困難之處不在于技術瓶頸，主要在于兩個方面：一方面，由于企業(yè)數(shù)據(jù)的關聯(lián)性、多樣性和復雜性，導致數(shù)據(jù)難以梳理和跨系統(tǒng)地被識別；另一方面，由于技術平臺的異構性，導致系統(tǒng)間的數(shù)據(jù)交互難以一種簡單、統(tǒng)籌的方法進行。

要在企業(yè)內部達成數(shù)據(jù)的整體一致性，將面臨如下幾個問題：

1、如何確保數(shù)據(jù)能夠被跨系統(tǒng)地識別；

2、如何應對異構系統(tǒng)所帶來的數(shù)據(jù)和技術平臺的復雜性；

3、如何在復雜的系統(tǒng)環(huán)境中精準地、實時地捕捉系統(tǒng)增量變化數(shù)據(jù)；

4、如何保證數(shù)據(jù)傳輸安全性和穩(wěn)定性。

這幾個問題，是大型企業(yè)信息架構中面臨的典型問題；大多數(shù)企業(yè)的應用現(xiàn)狀是，維護著一種雜亂、臃腫而且繁瑣的數(shù)據(jù)同步機制，負擔著高度的維護成本，效率不高，數(shù)據(jù)容易失真等諸多問題。

目前在業(yè)內已經有一些工具和產品專注于解決數(shù)據(jù)實時同步問題，企業(yè)應用中典型的有Oracle GodenGate以及類似產品。它主要實現(xiàn)各種關系型數(shù)據(jù)庫之間的數(shù)據(jù)實時同步，例如支持SQL Server、DB2、Oracle、MySQL、Sybase等多種流行數(shù)據(jù)庫之間的數(shù)據(jù)同步。在應用目標上GodenGate這類產品與本文的討論具有相近性，都是解決企業(yè)數(shù)據(jù)同步問題，但在具體的實施方案上，則完全不同。GodenGate主要從數(shù)據(jù)庫層實現(xiàn)數(shù)據(jù)同步，應用系統(tǒng)和開發(fā)者都無法捕捉和干預其同步過程，擴展性有限；GodenGate多用于系統(tǒng)災難備份。

發(fā)明內容

本發(fā)明的目的在于，解決大型企業(yè)信息化架構中，權威系統(tǒng)數(shù)據(jù)對外實時推送所面臨的困難性和復雜性等問題，而提出的企業(yè)權威源系統(tǒng)數(shù)據(jù)實時推送方法，采用基于應用層同步技術，以達到最終解決企業(yè)信息內部一致性的問題，并可有效和靈活地控制數(shù)據(jù)流向，便于管理和監(jiān)控，整個系統(tǒng)及方法具有應用系統(tǒng)和開發(fā)者自定義數(shù)據(jù)轉換邏輯和推送方式的特性。

本發(fā)明通過下述技術方案實現(xiàn)：企業(yè)權威源系統(tǒng)數(shù)據(jù)實時推送架構，包括權威系統(tǒng)域、用戶域、集成系統(tǒng)域、訂閱系統(tǒng)域，所述用戶域、集成系統(tǒng)域分別連接權威系統(tǒng)域，所述權威系統(tǒng)域連接訂閱系統(tǒng)域；所述權威系統(tǒng)域包括數(shù)據(jù)適配器、數(shù)據(jù)庫、數(shù)據(jù)監(jiān)聽服務、消息服務、數(shù)據(jù)推送服務，所述數(shù)據(jù)適配器分別連接數(shù)據(jù)庫和消息服務，所述數(shù)據(jù)監(jiān)聽服務和數(shù)據(jù)推送服務均連接數(shù)據(jù)庫，所述消息服務分別連接數(shù)據(jù)監(jiān)聽服務和數(shù)據(jù)推送服務。

進一步的，為更好的實現(xiàn)本發(fā)明，所述數(shù)據(jù)監(jiān)聽服務包括數(shù)據(jù)監(jiān)聽器、數(shù)據(jù)分析器、通知隊列和通知發(fā)送器，所述數(shù)據(jù)監(jiān)聽器監(jiān)聽和掃描增量數(shù)據(jù)源，并調用數(shù)據(jù)分析器；數(shù)據(jù)分析器調用通知隊列；所述通知發(fā)送器監(jiān)聽通知隊列，并連接到消息服務；所述數(shù)據(jù)監(jiān)聽器包括消息監(jiān)聽器、數(shù)據(jù)表監(jiān)聽器、其它監(jiān)聽器，所述數(shù)據(jù)分析器包括消息分析器、數(shù)據(jù)表分析器、其它分析器；所述消息監(jiān)聽器監(jiān)聽和掃描增量數(shù)據(jù)源，并調用消息分析器；消息分析器調用通知隊列；所述通知發(fā)送器監(jiān)聽通知隊列，并連接到消息服務；所述數(shù)據(jù)表監(jiān)聽器監(jiān)聽和掃描增量數(shù)據(jù)源，并調用數(shù)據(jù)表分析器；數(shù)據(jù)表分析器調用通知隊列；所述通知發(fā)送器監(jiān)聽通知隊列，并連接到消息服務；所述其它監(jiān)聽器監(jiān)聽和掃描增量數(shù)據(jù)源，并調用其它分析器；其它分析器調用通知隊列；所述通知發(fā)送器監(jiān)聽通知隊列，并連接到消息服務。

進一步的，為更好的實現(xiàn)本發(fā)明，所述權威系統(tǒng)域還包括應用控制器和業(yè)務組件，所述應用控制器調用業(yè)務組件，業(yè)務組件調用數(shù)據(jù)適配器。

進一步的，為更好的實現(xiàn)本發(fā)明，所述數(shù)據(jù)推送服務包括訂閱管理器、數(shù)據(jù)組裝器、推送監(jiān)聽器、推送處理器、推送隊列和數(shù)據(jù)推送器；所述推送監(jiān)聽器連接消息服務，調用推送處理器；所述推送處理器依次調用訂閱管理器、數(shù)據(jù)組裝器和推送隊列；所述訂閱管理器和數(shù)據(jù)組裝器分別連接數(shù)據(jù)庫；所述數(shù)據(jù)推送器監(jiān)聽推送隊列，并調用訂閱系統(tǒng)域的信息系統(tǒng)接口。

企業(yè)權威源系統(tǒng)數(shù)據(jù)實時推送方法，其特征在于：包括以下步驟：