[發(fā)明專利]基于數(shù)據(jù)的細(xì)粒度交換系統(tǒng)和方法

在審

• 申請(qǐng)?zhí)枺?/td>: 201910156604.8
• 申請(qǐng)日: 2019-03-01
• 公開（公告）號(hào): CN110008241A
• 公開（公告）日: 2019-07-12
• 發(fā)明（設(shè)計(jì)）人: 郝文威;趙春明;盧章瑋;肖彬彬
• 申請(qǐng)（專利權(quán)）人: 北京招通致晟科技有限公司
• 主分類號(hào): G06F16/2455
• 分類號(hào): G06F16/2455;G06F16/25
• 代理公司: 北京輕創(chuàng)知識(shí)產(chǎn)權(quán)代理有限公司 11212
• 代理人: 趙秀斌

本發(fā)明屬于數(shù)據(jù)交換技術(shù)領(lǐng)域，具體涉及一種基于數(shù)據(jù)的細(xì)粒度交換系統(tǒng)和方法。系統(tǒng)包括：用戶管理模塊，用于獲取各用戶與各用戶所訂閱的數(shù)據(jù)類型之間的映射關(guān)系；消息管理模塊，用于將獲取的實(shí)時(shí)或非實(shí)時(shí)消息劃分為若干字段的集合，各字段包含至少一個(gè)數(shù)據(jù)類型的數(shù)據(jù)；數(shù)據(jù)接收及發(fā)布模塊，用于獲取實(shí)時(shí)或非實(shí)消息，并根據(jù)映射關(guān)系，將各字段分別發(fā)布到對(duì)應(yīng)的用戶。本發(fā)明的數(shù)據(jù)細(xì)粒度交換系統(tǒng)支持基于數(shù)據(jù)庫(kù)表、數(shù)據(jù)庫(kù)視圖、數(shù)據(jù)庫(kù)腳本、接口等的數(shù)據(jù)發(fā)布方式。支持接口被動(dòng)發(fā)布接受和主動(dòng)采集的方式，提高系統(tǒng)對(duì)不同需求的滿足能力。對(duì)于獲取的數(shù)據(jù)采用細(xì)粒度的分發(fā)機(jī)制，對(duì)不同用戶分發(fā)同一數(shù)據(jù)的不同字段組合，實(shí)現(xiàn)按需獲取，減少系統(tǒng)開銷。

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

本發(fā)明屬于數(shù)據(jù)交換技術(shù)領(lǐng)域，具體涉及一種基于數(shù)據(jù)的細(xì)粒度交換系統(tǒng)和方法。

背景技術(shù)

當(dāng)前各行業(yè)機(jī)構(gòu)都設(shè)計(jì)和建設(shè)了屬于機(jī)構(gòu)、業(yè)務(wù)本身的應(yīng)用、流程以及數(shù)據(jù)的信息處理系統(tǒng)，系統(tǒng)設(shè)計(jì)建設(shè)的時(shí)期不同、業(yè)務(wù)模式不同，信息化建設(shè)缺乏有效的總體規(guī)劃，缺乏統(tǒng)一的設(shè)計(jì)標(biāo)準(zhǔn)，使信息交互共享困難，存在大量的信息孤島和流程孤島。

當(dāng)前主流的數(shù)據(jù)交互方式主要是通過(guò)WebService接口、數(shù)據(jù)庫(kù)視圖、Excel文件及基于MQ等消息中間件的數(shù)據(jù)交換等。這些方式各有優(yōu)劣，單獨(dú)使用無(wú)法滿足當(dāng)前越發(fā)龐大的數(shù)據(jù)量和多樣的數(shù)據(jù)需求。1)WebService接口：適用于少量的實(shí)時(shí)數(shù)據(jù)交換，可以做業(yè)務(wù)接口對(duì)接，但是對(duì)數(shù)據(jù)量較大的數(shù)據(jù)交互無(wú)法滿足，占用資源較多；2)數(shù)據(jù)庫(kù)視圖：對(duì)數(shù)據(jù)庫(kù)要求較高，適用于大數(shù)據(jù)量的交換，但是對(duì)自身系統(tǒng)的壓力較大，風(fēng)險(xiǎn)系數(shù)較高，適用范圍較小。3)Excel文件：適用于非實(shí)時(shí)的少量數(shù)據(jù)交互，操作復(fù)雜。無(wú)法滿足實(shí)時(shí)性數(shù)據(jù)。4)基于MQ等消息中間件：適用于批量非實(shí)時(shí)數(shù)據(jù)下發(fā)，數(shù)據(jù)可靠性較低，發(fā)布、獲取方式復(fù)雜。

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

為解決現(xiàn)有技術(shù)的不足，本發(fā)明提供了一種基于數(shù)據(jù)的細(xì)粒度交換系統(tǒng)和方法。本發(fā)明所提供的基于數(shù)據(jù)的細(xì)粒度交換系統(tǒng)和方法針對(duì)實(shí)時(shí)消息、非實(shí)時(shí)消息、歷史消息、增量消息均有有效的解決方案，對(duì)數(shù)據(jù)操作便利性、數(shù)據(jù)交換安全性等有提高。本發(fā)明通過(guò)數(shù)據(jù)的細(xì)粒度定向發(fā)布，可以實(shí)現(xiàn)安全穩(wěn)定的多種類型的數(shù)據(jù)交換。

本發(fā)明所提供的技術(shù)方案如下：

本發(fā)明提供了一種基于數(shù)據(jù)的細(xì)粒度交換系統(tǒng)，包括：

用戶管理模塊，用于獲取各用戶與各用戶所訂閱的數(shù)據(jù)類型之間的映射關(guān)系；

消息管理模塊，用于將獲取的實(shí)時(shí)或非實(shí)時(shí)消息劃分為若干字段的集合，各所述字段包含至少一個(gè)所述數(shù)據(jù)類型的數(shù)據(jù)；

數(shù)據(jù)接收及發(fā)布模塊，用于獲取實(shí)時(shí)或非實(shí)消息，并根據(jù)所述映射關(guān)系，將各所述字段分別發(fā)布到對(duì)應(yīng)的所述用戶。

基于上述技術(shù)方案，將消息劃分為若干字段的集合，集合中的各字段包含了用戶所訂閱的數(shù)據(jù)。然后根據(jù)映射關(guān)系，就可將同一個(gè)字段發(fā)給所有訂閱該字段的用戶，以獲取實(shí)時(shí)消息數(shù)據(jù)、非實(shí)時(shí)消息數(shù)據(jù)。進(jìn)一步而言，系統(tǒng)設(shè)置為被動(dòng)獲取實(shí)時(shí)消息，可以從實(shí)時(shí)消息服務(wù)獲得實(shí)時(shí)消息；設(shè)置為主動(dòng)獲取，可以從實(shí)時(shí)消息服務(wù)中獲取歷史消息；設(shè)置為主動(dòng)獲取，可以從非實(shí)時(shí)消息數(shù)據(jù)庫(kù)中獲取非實(shí)時(shí)消息。

進(jìn)一步地，還包括路由表，用于存儲(chǔ)所述映射關(guān)系。

就映射關(guān)系的確定方法，例如，用戶管理模塊對(duì)用戶注冊(cè)信息進(jìn)行管理，可以通過(guò)將用戶ID與用戶注冊(cè)時(shí)訂閱的數(shù)據(jù)類型進(jìn)行關(guān)聯(lián)，即可以得到該映射關(guān)系。進(jìn)一步地，該映射關(guān)系可以路由表的方式進(jìn)行維護(hù)。

進(jìn)一步地，所述數(shù)據(jù)接收及發(fā)布模塊還包括轉(zhuǎn)化器和過(guò)濾器：

所述轉(zhuǎn)換器用于將業(yè)務(wù)庫(kù)中各消息中的各數(shù)據(jù)的數(shù)據(jù)結(jié)構(gòu)轉(zhuǎn)化為各用戶所訂閱的數(shù)據(jù)類型的數(shù)據(jù)結(jié)構(gòu)；

所述過(guò)濾器用于對(duì)業(yè)務(wù)庫(kù)中已轉(zhuǎn)化為各用戶所訂閱的數(shù)據(jù)類型的數(shù)據(jù)結(jié)構(gòu)的數(shù)據(jù)進(jìn)行過(guò)濾，保留與所述數(shù)據(jù)類型匹配的數(shù)據(jù)，以獲取實(shí)時(shí)或非實(shí)時(shí)消息。