[發(fā)明專利]一種將數(shù)據(jù)更新快速同步到業(yè)務(wù)系統(tǒng)的裝置及方法

有效

• 申請(qǐng)?zhí)枺?/td>: 201611078665.X
• 申請(qǐng)日: 2016-11-30
• 公開（公告）號(hào): CN108121730B
• 公開（公告）日: 2021-01-26
• 發(fā)明（設(shè)計(jì)）人: 馬文軍
• 申請(qǐng)（專利權(quán)）人: 北京京東尚科信息技術(shù)有限公司;北京京東世紀(jì)貿(mào)易有限公司
• 主分類號(hào): G06F16/23
• 分類號(hào): G06F16/23;G06F16/27;G06Q30/04
• 代理公司: 中原信達(dá)知識(shí)產(chǎn)權(quán)代理有限責(zé)任公司 11219
• 代理人: 張一軍;姜?jiǎng)?/td>

1.一種將數(shù)據(jù)更新快速同步到業(yè)務(wù)系統(tǒng)的裝置，其特征在于，所述裝置包括數(shù)據(jù)更新模塊和數(shù)據(jù)同步模塊，其中，

所述數(shù)據(jù)更新模塊在發(fā)生數(shù)據(jù)的更新時(shí)，向所述數(shù)據(jù)同步模塊發(fā)送數(shù)據(jù)更新消息，所述數(shù)據(jù)更新消息包括所述數(shù)據(jù)的標(biāo)識(shí)和更新時(shí)間；

所述數(shù)據(jù)同步模塊由多套MQ消息集群組成，包括緩存和監(jiān)控模塊，所述緩存保存所述數(shù)據(jù)的標(biāo)識(shí)和對(duì)應(yīng)的最后更新時(shí)間，所述監(jiān)控模塊用于將發(fā)送時(shí)間最快且可用的所述MQ消息集群的編號(hào)保存至所述緩存中，使得在接收和發(fā)送消息時(shí)利用發(fā)送時(shí)間最快且可用的所述MQ消息集群；

其中，當(dāng)接收到所述數(shù)據(jù)更新消息時(shí)，所述數(shù)據(jù)同步模塊根據(jù)接收的所述數(shù)據(jù)更新消息中的所述標(biāo)識(shí)確定所述緩存中保存的所述標(biāo)識(shí)對(duì)應(yīng)的最后更新時(shí)間，如果所述數(shù)據(jù)更新消息中的所述更新時(shí)間晚于所述最后更新時(shí)間，則從所述數(shù)據(jù)更新模塊獲取對(duì)應(yīng)的數(shù)據(jù)并作為數(shù)據(jù)消息發(fā)送至所述業(yè)務(wù)系統(tǒng)，并且把所述緩存中的所述最后更新時(shí)間替換為所述數(shù)據(jù)更新消息中的所述更新時(shí)間。

2.根據(jù)權(quán)利要求1所述的裝置，其特征在于，所述數(shù)據(jù)是增值稅發(fā)票資質(zhì)信息。

3.根據(jù)權(quán)利要求1所述的裝置，其特征在于，所述監(jiān)控模塊還用于定期檢測(cè)各所述MQ消息集群的可用率和發(fā)送時(shí)間。

4.一種將數(shù)據(jù)更新快速同步到業(yè)務(wù)系統(tǒng)的方法，其特征在于，所述方法，其中，

當(dāng)數(shù)據(jù)更新模塊發(fā)生數(shù)據(jù)的更新時(shí)，向數(shù)據(jù)同步模塊發(fā)送數(shù)據(jù)更新消息，所述數(shù)據(jù)更新消息包括所述數(shù)據(jù)的標(biāo)識(shí)和更新時(shí)間，所述數(shù)據(jù)同步模塊由多套MQ消息集群組成，包括緩存和監(jiān)控模塊，所述緩存保存數(shù)據(jù)的數(shù)據(jù)標(biāo)識(shí)和對(duì)應(yīng)的最后更新時(shí)間，所述監(jiān)控模塊用于將發(fā)送時(shí)間最快且可用的所述MQ消息集群的編號(hào)保存至所述緩存中，使得在接收和發(fā)送消息時(shí)利用發(fā)送時(shí)間最快且可用的所述MQ消息集群；

當(dāng)所述數(shù)據(jù)同步模塊接收到數(shù)據(jù)更新消息時(shí)，所述數(shù)據(jù)同步模塊根據(jù)接收的所述數(shù)據(jù)更新消息中的所述標(biāo)識(shí)確定所述緩存中保存的所述標(biāo)識(shí)對(duì)應(yīng)的最后更新時(shí)間，如果所述數(shù)據(jù)更新消息中的所述更新時(shí)間晚于所述最后更新時(shí)間，則從所述數(shù)據(jù)更新模塊獲取對(duì)應(yīng)的所述數(shù)據(jù)并作為數(shù)據(jù)消息發(fā)送至業(yè)務(wù)系統(tǒng)，并且把所述緩存中的所述最后更新時(shí)間替換為所述數(shù)據(jù)更新消息中的更新時(shí)間。

5.根據(jù)權(quán)利要求4所述的方法，其特征在于，所述數(shù)據(jù)是增值稅發(fā)票資質(zhì)信息。

6.根據(jù)權(quán)利要求4所述的方法，其特征在于，還包括：

定期檢測(cè)各MQ消息集群的可用率和發(fā)送時(shí)間。

7.一種將數(shù)據(jù)更新快速同步到業(yè)務(wù)系統(tǒng)的電子設(shè)備，其特征在于，包括：

一個(gè)或多個(gè)處理器；

存儲(chǔ)裝置，用于存儲(chǔ)一個(gè)或多個(gè)程序，

當(dāng)所述一個(gè)或多個(gè)程序被所述一個(gè)或多個(gè)處理器執(zhí)行，使得所述一個(gè)或多個(gè)處理器實(shí)現(xiàn)如權(quán)利要求4-6中任一所述的方法。

8.一種計(jì)算機(jī)可讀介質(zhì)，其上存儲(chǔ)有計(jì)算機(jī)程序，其特征在于，所述程序被處理器執(zhí)行時(shí)實(shí)現(xiàn)如權(quán)利要求4-6中任一所述的方法。