[發明專利]基于消息中間件的數據存儲方法、裝置、設備及存儲介質

有效

• 申請號: 202011606960.4
• 申請日: 2020-12-30
• 公開（公告）號: CN112650814B
• 公開（公告）日: 2023-09-26
• 發明（設計）人: 孫君雅;顧張磊;蒿興旺
• 申請（專利權）人: 平安壹錢包電子商務有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/28
• 代理公司: 深圳市精英專利事務所 44242
• 代理人: 涂年影

1.一種基于消息中間件的數據存儲方法，其特征在于，包括：

當接收到業務數據的請求存儲指令時，判斷數據庫中的標志位是否可用，得到判斷結果；

若所述判斷結果為所述標志位可用，則將所述業務數據存儲到所述數據庫中，并獲取存儲結果；

若所述判斷結果為所述標志位不可用，則將當前線程進行休眠；

若所述當前線程休眠到達預設時間，則將所述業務數據發送到所述消息中間件中；

當監測到所述標志位可用時，將存儲于所述消息中間件中的業務數據同步到所述數據庫中；

當所述存儲結果顯示數據庫存儲失敗時，記錄所述數據庫存儲失敗次數，并將所述業務數據存儲于Redis數據庫中；

若所述數據庫存儲失敗次數達到預設次數，則判定所述數據庫宕機，并將存儲于所述Redis數據庫中的業務數據發送至消息中間件中；

當監測到所述數據庫可用時，將存儲于所述消息中間件中的業務數據同步到所述數據庫中。

2.根據權利要求1所述的基于消息中間件的數據存儲方法，其特征在于，所述若所述判斷結果為所述標志位可用，則將所述業務數據存儲到所述數據庫中，并獲取存儲結果，包括：

若所述判斷結果為所述標志位可用，則調用所述業務數據對應的數據庫接口；

通過所述數據庫接口，將所述業務數據存儲于所述數據庫中；

通過對所述數據庫進行更新，得到數據庫更新數據，并根據所述數據庫更新數據確定所述存儲結果。

3.根據權利要求1所述的基于消息中間件的數據存儲方法，其特征在于，所述當所述存儲結果顯示數據庫存儲失敗時，記錄所述數據庫存儲失敗次數，并將所述業務數據存儲于Redis數據庫中，包括：

當所述存儲結果顯示數據庫存儲失敗時，通過計數器記錄所述數據庫存儲失敗次數；

訪問所述Redis數據庫對應接口，并通過所述對應接口將所述業務數據存儲于所述Redis數據庫中。

4.根據權利要求1所述的基于消息中間件的數據存儲方法，其特征在于，所述若所述數據庫存儲失敗次數達到預設次數，則判定所述數據庫宕機，并將存儲于所述Redis數據庫中的業務數據發送至消息中間件中，包括：

當所述數據庫存儲失敗次數達到預設次數時，則判定所述數據庫宕機，并將所述標志位設置為不可用；

接收所述Redis數據庫的消息存儲指令，將所述存儲于所述Redis數據庫中的業務數據發送至所述消息中間件中。

5.根據權利要求1所述的基于消息中間件的數據存儲方法，其特征在于，所述接收所述Redis數據庫的消息存儲指令，將所述存儲于所述Redis數據庫中的業務數據發送至所述消息中間件中，包括：

在所述消息中間件中，創建消息監聽任務；

通過所述消息監聽任務監聽到來自所述Redis數據庫的消息存儲指令，設置所述消息中間件對應隊列；

通過所述對應隊列，將所述存儲于所述Redis數據庫中的業務數據發送至所述消息中間件中。

6.根據權利要求1至5任一項所述的基于消息中間件的數據存儲方法，其特征在于，所述當監測到所述數據庫可用時，將存儲于所述消息中間件中的業務數據同步到所述數據庫中，包括：

設置定時更新任務，并通過所述定時更新任務定時更新所述數據庫中的數據庫表，得到更新結果；

若所述更新結果為所述數據庫表中數據完成更新，則判定所述數據庫可用，并設置所述標志位為可用且將所述數據庫存儲失敗次數進行清零；

將存儲于所述消息中間件中的業務數據同步到所述數據庫中。