[發(fā)明專利]數(shù)據(jù)讀取一致性系統(tǒng)及方法

在審

• 申請?zhí)枺?/td>: 201811550757.2
• 申請日: 2018-12-18
• 公開（公告）號: CN109634978A
• 公開（公告）日: 2019-04-16
• 發(fā)明（設計）人: 王智
• 申請（專利權）人: 鈦馬信息網(wǎng)絡技術有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23
• 代理公司: 上海容慧專利代理事務所(普通合伙) 31287
• 代理人: 于曉菁

1.一種數(shù)據(jù)讀取一致性更新系統(tǒng)，其特征在于，其包括多個分庫數(shù)據(jù)庫、用于與分庫數(shù)據(jù)庫一一對應的微服務云平臺、RocketMQ組件、事務組件和事件數(shù)據(jù)庫；

所述微服務云平臺中的一個微服務云平臺作為第一微服務云平臺用于接收數(shù)據(jù)更新請求并對對應的分庫數(shù)據(jù)庫進行數(shù)據(jù)更新，其后將數(shù)據(jù)更新的事件消息通過事務組件存儲至事件數(shù)據(jù)庫中，并向RocketMQ組件發(fā)送更新事件消息；

所述微服務云平臺中的其他微服務云平臺用于監(jiān)聽RocketMQ組件接收到的消息，在其他微服務云平臺中的一個微服務云平臺作為第二微服務云平臺監(jiān)聽到消息為更新事件消息時，第二微服務云平臺通過事務組件向事件數(shù)據(jù)庫查詢是否有該更新事件消息且該更新事件消息的狀態(tài)為未完成，在有該更新事件消息且狀態(tài)為未完成時第二微服務云平臺對對應的分庫數(shù)據(jù)庫進行數(shù)據(jù)更新，并通過事務組件將事件數(shù)據(jù)庫中的該更新事件消息的狀態(tài)更新為已完成；

所述事務組件用于將更新成功的確認消息發(fā)送給RocketMQ組件。

2.如權利要求1所述的數(shù)據(jù)讀取一致性更新系統(tǒng)，其特征在于，所述事務組件用于定時從事件數(shù)據(jù)庫中取出狀態(tài)為未完成的更新事件消息并將狀態(tài)為未完成的更新事件消息發(fā)送給RocketMQ組件重新執(zhí)行更新。

3.如權利要求2所述的數(shù)據(jù)讀取一致性更新系統(tǒng)，其特征在于，所述事務組件用于判斷該更新事件消息的重試次數(shù)是否超出一設定閾值，在為是時通過短信或郵件方式發(fā)送通知信息給相關運維人員。

4.如權利要求1所述的數(shù)據(jù)讀取一致性更新系統(tǒng)，其特征在于，所述事件數(shù)據(jù)庫采用MongoDB或者Redis非關系型數(shù)據(jù)庫。

5.如權利要求1所述的數(shù)據(jù)讀取一致性更新系統(tǒng)，其特征在于，所述第一微服務云平臺用于在對對應的分庫數(shù)據(jù)庫進行數(shù)據(jù)更新之前向RocketMQ組件發(fā)送預告消息；

所述RocketMQ組件用于在收到預告消息后定期向第一微服務云平臺發(fā)送該預告消息是否執(zhí)行完成的確認信息。

6.一種數(shù)據(jù)讀取一致性更新方法，其特征在于，其利用如權利要求1所述的系統(tǒng)實現(xiàn)，其包括以下步驟：

S1、所述第一微服務云平臺接收數(shù)據(jù)更新請求；

S2、所述第一微服務云平臺對對應的分庫數(shù)據(jù)庫進行數(shù)據(jù)更新；

S3、所述第一微服務云平臺將數(shù)據(jù)更新的事件消息通過事務組件存儲至事件數(shù)據(jù)庫中；

S4、所述第一微服務云平臺向RocketMQ組件發(fā)送更新事件消息；

S5、所述第二微服務云平臺監(jiān)聽RocketMQ組件接收到的消息且監(jiān)聽到消息為更新事件消息；

S6、所述第二微服務云平臺通過事務組件向事件數(shù)據(jù)庫查詢是否有該更新事件消息且該更新事件消息的狀態(tài)為未完成；

S7、所述第二微服務云平臺查詢出有該更新事件消息且狀態(tài)為未完成時對對應的分庫數(shù)據(jù)庫進行數(shù)據(jù)更新；

S8、所述第二微服務云平臺通過事務組件將事件數(shù)據(jù)庫中的該更新事件消息的狀態(tài)更新為已完成；

S9、所述事務組件將更新成功的確認消息發(fā)送給RocketMQ組件。

7.如權利要求6所述的數(shù)據(jù)讀取一致性更新方法，其特征在于，在步驟S7中數(shù)據(jù)更新失敗時，所述事務組件定時從事件數(shù)據(jù)庫中取出狀態(tài)為未完成的更新事件消息并將狀態(tài)為未完成的更新事件消息發(fā)送給RocketMQ組件重新執(zhí)行更新。

8.如權利要求7所述的數(shù)據(jù)讀取一致性更新方法，其特征在于，所述事務組件判斷該更新事件消息的重試次數(shù)是否超出一設定閾值，在為是時通過短信或郵件方式發(fā)送通知信息給相關運維人員。

9.如權利要求6所述的數(shù)據(jù)讀取一致性更新方法，其特征在于，所述事件數(shù)據(jù)庫采用MongoDB或者Redis非關系型數(shù)據(jù)庫。

10.如權利要求6所述的數(shù)據(jù)讀取一致性更新方法，其特征在于，在步驟S2之前，所述第一微服務云平臺在對對應的分庫數(shù)據(jù)庫進行數(shù)據(jù)更新之前向RocketMQ組件發(fā)送預告消息；

所述RocketMQ組件在收到預告消息后定期向第一微服務云平臺發(fā)送該預告消息是否執(zhí)行完成的確認信息。