[發(fā)明專利]消息同步方法及裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 202010782075.5
• 申請(qǐng)日: 2020-08-06
• 公開（公告）號(hào): CN111884769B
• 公開（公告）日: 2023-10-27
• 發(fā)明（設(shè)計(jì)）人: 王明濤
• 申請(qǐng)（專利權(quán)）人: 中國銀行股份有限公司
• 主分類號(hào): H04L1/1607
• 分類號(hào): H04L1/1607;H04L1/1809;G06F16/23;G06F16/27
• 代理公司: 北京三友知識(shí)產(chǎn)權(quán)代理有限公司 11127
• 代理人: 周曉飛;許曼

1.一種消息同步方法，其特征在于，包括：

在消息生產(chǎn)者發(fā)布消息后，記錄消息對(duì)應(yīng)的狀態(tài)信息，將消息和對(duì)應(yīng)的狀態(tài)信息存入數(shù)據(jù)庫；

根據(jù)消息消費(fèi)者對(duì)消息的處理數(shù)據(jù)，確定消息對(duì)應(yīng)的新的狀態(tài)信息，將消息對(duì)應(yīng)的新的狀態(tài)信息，更新至數(shù)據(jù)庫；

循環(huán)執(zhí)行以下步驟，直至數(shù)據(jù)庫中記錄的所有消息對(duì)應(yīng)的狀態(tài)信息為第一預(yù)設(shè)值：

每隔第一預(yù)定時(shí)間間隔，調(diào)取數(shù)據(jù)庫中的狀態(tài)信息為第二預(yù)設(shè)值的消息，重新發(fā)布；

根據(jù)消息消費(fèi)者對(duì)重新發(fā)布的消息的處理數(shù)據(jù)，確定重新發(fā)布的消息對(duì)應(yīng)的新的狀態(tài)信息，將重新發(fā)布的消息對(duì)應(yīng)的新的狀態(tài)信息，更新至數(shù)據(jù)庫。

2.如權(quán)利要求1所述的方法，其特征在于，狀態(tài)信息包括：消息的實(shí)時(shí)狀態(tài)和重發(fā)次數(shù)；

所述第一預(yù)設(shè)值為：消息的實(shí)時(shí)狀態(tài)為無需重發(fā)或重發(fā)次數(shù)等于預(yù)定閾值；

所述第二預(yù)設(shè)值為：消息的實(shí)時(shí)狀態(tài)為需重發(fā)且重發(fā)次數(shù)小于預(yù)定閾值。

3.如權(quán)利要求2所述的方法，其特征在于，根據(jù)消息消費(fèi)者對(duì)重新發(fā)布的消息的處理數(shù)據(jù)，確定重新發(fā)布的消息對(duì)應(yīng)的新的狀態(tài)信息，將重新發(fā)布的消息對(duì)應(yīng)的新的狀態(tài)信息，更新至數(shù)據(jù)庫，包括：

在重新發(fā)布消息后，將重新發(fā)布的消息對(duì)應(yīng)的重發(fā)次數(shù)加一，更新至數(shù)據(jù)庫。

4.如權(quán)利要求2所述的方法，其特征在于，還包括：

每隔第二預(yù)定時(shí)間間隔，從數(shù)據(jù)庫中，獲取狀態(tài)信息為第三預(yù)設(shè)值的消息；所述第三預(yù)設(shè)值為消息的實(shí)時(shí)狀態(tài)為需重發(fā)且重發(fā)次數(shù)等于預(yù)定閾值；

將狀態(tài)信息為第三預(yù)設(shè)值的消息，批量發(fā)布；

根據(jù)消息消費(fèi)者對(duì)批量發(fā)布的消息的處理數(shù)據(jù)，確定批量發(fā)布的消息對(duì)應(yīng)的新的狀態(tài)信息，將批量發(fā)布的消息對(duì)應(yīng)的新的狀態(tài)信息，更新至數(shù)據(jù)庫。

5.如權(quán)利要求4所述的方法，其特征在于，根據(jù)消息消費(fèi)者對(duì)批量發(fā)布的消息的處理數(shù)據(jù)，確定批量發(fā)布的消息對(duì)應(yīng)的新的狀態(tài)信息，將批量發(fā)布的消息對(duì)應(yīng)的新的狀態(tài)信息，更新至數(shù)據(jù)庫，包括：

在批量發(fā)布消息后，將批量發(fā)布的消息對(duì)應(yīng)的重發(fā)次數(shù)加一，更新至數(shù)據(jù)庫。

6.如權(quán)利要求5所述的方法，其特征在于，還包括：

將數(shù)據(jù)庫中狀態(tài)信息為第四預(yù)設(shè)值的消息及對(duì)應(yīng)的狀態(tài)信息導(dǎo)出，生成異常消息數(shù)據(jù)；所述第四預(yù)設(shè)值為消息的實(shí)時(shí)狀態(tài)為需重發(fā)且重發(fā)次數(shù)大于預(yù)定閾值；

在數(shù)據(jù)庫中刪除狀態(tài)信息為第四預(yù)設(shè)值的消息及對(duì)應(yīng)的狀態(tài)信息。

7.一種消息同步裝置，其特征在于，包括：

消息存儲(chǔ)模塊，用于在消息生產(chǎn)者發(fā)布消息后，記錄消息對(duì)應(yīng)的狀態(tài)信息，將消息和對(duì)應(yīng)的狀態(tài)信息存入數(shù)據(jù)庫；

第一狀態(tài)更新模塊，用于根據(jù)消息消費(fèi)者對(duì)消息的處理數(shù)據(jù)，確定消息對(duì)應(yīng)的新的狀態(tài)信息，將消息對(duì)應(yīng)的新的狀態(tài)信息，更新至數(shù)據(jù)庫；

循環(huán)模塊，用于調(diào)用重發(fā)模塊和第二狀態(tài)更新模塊，循環(huán)執(zhí)行以下步驟，直至數(shù)據(jù)庫中記錄的所有消息對(duì)應(yīng)的狀態(tài)信息為第一預(yù)設(shè)值：

重發(fā)模塊，用于每隔第一預(yù)定時(shí)間間隔，調(diào)取數(shù)據(jù)庫中的狀態(tài)信息為第二預(yù)設(shè)值的消息，重新發(fā)布；

第二狀態(tài)更新模塊，用于根據(jù)消息消費(fèi)者對(duì)重新發(fā)布的消息的處理數(shù)據(jù)，確定重新發(fā)布的消息對(duì)應(yīng)的新的狀態(tài)信息，將重新發(fā)布的消息對(duì)應(yīng)的新的狀態(tài)信息，更新至數(shù)據(jù)庫。

8.如權(quán)利要求7所述的裝置，其特征在于，狀態(tài)信息包括：消息的實(shí)時(shí)狀態(tài)和重發(fā)次數(shù)；

所述第一預(yù)設(shè)值為：消息的實(shí)時(shí)狀態(tài)為無需重發(fā)或重發(fā)次數(shù)等于預(yù)定閾值；

所述第二預(yù)設(shè)值為：消息的實(shí)時(shí)狀態(tài)為需重發(fā)且重發(fā)次數(shù)小于預(yù)定閾值。

9.如權(quán)利要求8所述的裝置，其特征在于，所述重發(fā)模塊具體用于：

在重新發(fā)布消息后，將重新發(fā)布的消息對(duì)應(yīng)的重發(fā)次數(shù)加一，更新至數(shù)據(jù)庫。