[發明專利]數據讀取一致性系統及方法

在審

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

本發明一種數據讀取一致性更新系統及方法，包括：第一微服務云平臺接收數據更新請求并對對應的分庫數據庫進行數據更新，其后將數據更新的事件消息通過事務組件存儲至事件數據庫中，并向RocketMQ組件發送更新事件消息；其他微服務云平臺監聽RocketMQ組件接收到的消息，第二微服務云平臺監聽到消息為更新事件消息時，第二微服務云平臺通過事務組件向事件數據庫查詢是否有該更新事件消息且該更新事件消息的狀態為未完成，在有該更新事件消息且狀態為未完成時第二微服務云平臺對對應的分庫數據庫進行數據更新，并通過事務組件將該更新事件消息的狀態更新為已完成；事務組件用于將更新成功的確認消息發送給RocketMQ組件。

技術領域

本發明涉及數據讀取一致性技術領域，特別是涉及一種數據讀取一致性系統及方法。

背景技術

對于一個微服務云平臺來說，數據量日益增大帶來的是數據庫壓力激增的問題。為了緩解數據庫壓力，水平分庫和垂直分庫就成為了許多公司的選擇。不同的業務使用不同的數據庫，但在一些特殊場合又必須同時對不同數據庫的數據進行新增和更改，由此又帶來了事務一致性的問題。

發明內容

本發明針對現有技術存在的問題和不足，提供一種數據讀取一致性系統及方法。

本發明是通過下述技術方案來解決上述技術問題的：

本發明提供一種數據讀取一致性更新系統，其特點在于，其包括多個分庫數據庫、用于與分庫數據庫一一對應的微服務云平臺、RocketMQ組件、事務組件和事件數據庫；

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

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

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

較佳地，所述事務組件用于定時從事件數據庫中取出狀態為未完成的更新事件消息并將狀態為未完成的更新事件消息發送給RocketMQ組件重新執行更新。

較佳地，所述事務組件用于判斷該更新事件消息的重試次數是否超出一設定閾值，在為是時通過短信或郵件方式發送通知信息給相關運維人員。

較佳地，所述事件數據庫采用MongoDB或者Redis非關系型數據庫。

較佳地，所述第一微服務云平臺用于在對對應的分庫數據庫進行數據更新之前向RocketMQ組件發送預告消息；

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

本發明還提供一種數據讀取一致性更新方法，其特點在于，其利用上述的系統實現，其包括以下步驟：

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

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

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

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

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