[發(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
• 代理人: 王宗江

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

企業(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ù)推送服務；

所述數(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)聽通知隊列，并連接到消息服務；

所述數(shù)據(jù)推送服務包括訂閱管理器、數(shù)據(jù)組裝器、推送監(jiān)聽器、推送處理器、推送隊列和數(shù)據(jù)推送器；所述推送監(jiān)聽器連接消息服務，調用推送處理器；所述推送處理器依次調用訂閱管理器、數(shù)據(jù)組裝器和推送隊列；所述訂閱管理器和數(shù)據(jù)組裝器分別連接數(shù)據(jù)庫；所述數(shù)據(jù)推送器監(jiān)聽推送隊列，并調用訂閱系統(tǒng)域的信息系統(tǒng)接口；

所述權威系統(tǒng)域還包括應用控制器和業(yè)務組件，所述應用控制器調用業(yè)務組件，業(yè)務組件調用數(shù)據(jù)適配器；

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

步驟A、權威系統(tǒng)域數(shù)據(jù)起始輸入：用戶域數(shù)據(jù)輸入或外部信息系統(tǒng)輸入或外部數(shù)據(jù)庫輸入；

步驟B、數(shù)據(jù)適配：經步驟A后，通過數(shù)據(jù)適配器接受上層業(yè)務組件的調用并傳入數(shù)據(jù)，也支持外部系統(tǒng)向其輸入數(shù)據(jù)，然后將數(shù)據(jù)存入數(shù)據(jù)庫，同時向外部組件發(fā)送數(shù)據(jù)變化的消息通知；

步驟C、數(shù)據(jù)監(jiān)聽：負責監(jiān)聽數(shù)據(jù)適配器層和Oracle CDC捕捉到的增量數(shù)據(jù)，然后根據(jù)監(jiān)聽到的增量數(shù)據(jù)的類型和特點，生成相應的數(shù)據(jù)推送通知，并將通知發(fā)送到消息服務，經消息服務再發(fā)送給“數(shù)據(jù)推送服務”；

步驟D、數(shù)據(jù)推送：主要負責具體的業(yè)務數(shù)據(jù)向外部系統(tǒng)進行推送，數(shù)據(jù)推送服務收到數(shù)據(jù)后，分別解析出各項所需推送的業(yè)務系統(tǒng)，同時將各數(shù)據(jù)進行標準格式化轉換；最后由數(shù)據(jù)推送服務將格式化的數(shù)據(jù)，通過業(yè)務系統(tǒng)所注冊的接口進行傳輸，并在數(shù)據(jù)庫中記錄數(shù)據(jù)傳輸日志信息；

步驟E、結束數(shù)據(jù)推送：經步驟D后，結束一個數(shù)據(jù)推送過程；

所述步驟C包括以下步驟：

步驟C.1、數(shù)據(jù)監(jiān)聽器收集外部增量數(shù)據(jù)；

步驟C.2、經步驟C.1后，分析器對增量數(shù)據(jù)進行業(yè)務性質的分析，并生成推送通知；

步驟C.3、分析器將生成的推送通知放入通知隊列；

步驟C.4、通知發(fā)送器從通知隊列中取出推送通知，并發(fā)送給消息服務，數(shù)據(jù)監(jiān)聽服務的流程至此完成；

所述步驟D包括以下步驟：

步驟D.1、推送監(jiān)聽器監(jiān)聽來自系統(tǒng)內部的推送通知；

步驟D.2、推送監(jiān)聽器調用推送處理器具體處理推送事務；

步驟D.3、推送處理器首先調用訂閱管理器，找出本次需要推送的外部系統(tǒng)；

步驟D.4、推送處理器調用數(shù)據(jù)組裝器獲取本次需要推送的完整數(shù)據(jù)，再結合需推送的系統(tǒng)信息生成“推送請求”；

步驟D.5、推送處理器將“推送請求”放入推送隊列；

步驟D.6、數(shù)據(jù)推送器以多線程的方式從推送隊列中監(jiān)聽并取出“推送請求”，然后調用“推送請求”中指定的外部系統(tǒng)接口服務；

步驟D.7、數(shù)據(jù)推送器將推送結果寫入“數(shù)據(jù)推送日志”表中，整個推送過程結束。