[發明專利]一種消息處理方法及裝置

有效

• 申請號: 201910236790.6
• 申請日: 2019-03-27
• 公開（公告）號: CN110008041B
• 公開（公告）日: 2021-03-19
• 發明（設計）人: 趙鴻楠;艾國信;湯文強;周志成;宋超
• 申請（專利權）人: 北京奇藝世紀科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F16/23
• 代理公司: 北京柏杉松知識產權代理事務所(普通合伙) 11413
• 代理人: 丁蕓;項京

本發明實施例提供了一種消息處理方法及裝置，其中方法包括：第一服務器接收由消息隊列中間件發送的待處理消息，所述待處理消息攜帶用戶ID；所述第一服務器利用所述用戶ID，獲取為所述用戶ID分配的第一線程，所述第一線程用于處理所述用戶ID產生的各消息，所述待處理消息是由所述消息隊列中間件接收的變化消息，所述變化消息是通過第二服務器的數據庫中消息發生變化時發送的；所述第一服務器通過所述第一線程讀取所述待處理消息，并對所述待處理消息進行多線程加鎖；所述第一服務器在確定出所述待處理消息攜帶的時間戳早于獲取的已記錄數據的最新時間戳時，通過所述第一線程發送所述待處理消息的消息成功確認消息。

技術領域

本發明涉及數據處理領域，特別是涉及一種消息處理方法及裝置。

背景技術

不同系統之間數據庫中的數據，由于各種不確定因素，比如任一系統的服務器鏈接超時，導致數據不一致現象時有發生。以下進行詳細說明。

第一步，用戶向X系統發送A消息；第二步，X系統接收到用戶發送的A消息，X系統在X系統的x₁數據庫中寫入A消息；第三步，當監控到x₁數據庫中的A消息的狀態發生變化，這里的A消息的狀態發生變化比如A消息被讀取或被更新，其中被更新的A消息是指同一用戶發送的內容相同的消息，內容相同的消息攜帶的時間戳不同，使用消息隊列記錄這個變化的A消息，并將這個變化的A消息發送給Y系統；第四步，Y系統接收到變化的A消息后，Y系統會準備在Y系統的y₁數據庫中寫入這個變化的A消息。但是，Y系統在y₁數據庫中寫入這個變化的A消息過程中，出現的網絡異常的不確定因素，使得y₁數據庫中未成功寫入這個變化的A消息，此時這個變化的A消息會被認為屬于未被消費的消息，重新返回消息隊列的最后。

以支付結清系統為例進行說明：用戶向支付清結算系統發送一個請求支付消息，支付清結算系統接收到用戶發送的請求支付消息，在支付清結算系統的x₁數據庫中寫入請求支付消息；當監控到x₁數據庫中寫入請求支付消息被更新，使用消息隊列按照“先進先出”的原則，記錄這個變化的請求支付消息，并將這個變化的請求支付消息發送給支付認證系統，這個支付認證系統接收到這個變化的請求支付消息后，會準備在支付認證系統的數據庫中寫入這個變化的請求支付消息。在支付認證系統中寫入這個變化的請求支付消息，出現的網絡異常的不確定因素，使得在支付認證系統的數據庫中未寫入這個變化的請求支付消息，此時這個變化的請求支付消息會被認為屬于未被消費的消息，重新返回消息隊列的最后。

然而，發明人在實現本發明的過程中發現，現有技術不僅會存在Y系統的y₁數據庫與X系統的x₁數據庫中的消息不一致的問題，而且，由于消息隊列會按照“先進先出”的原則存放消息進行消費，那么在目前消息隊列中，A消息之前先進消息隊列的其他消息先被消費，再去消費這個A消息。

綜上所述，現有技術中會存在不同系統的數據庫的消息不一致以及處理消息發生錯亂的問題。

發明內容

本發明實施例的目的在于提供一種消息處理方法及裝置，用以解決現有技術中會存在不同系統的數據庫的消息不一致以及處理消息發生錯亂的問題。具體技術方案如下：

第一方面，本發明實施提供了一種消息處理方法，包括：

第一服務器接收由消息隊列中間件發送的待處理消息，所述待處理消息攜帶用戶ID；

所述第一服務器利用所述用戶ID，獲取為所述用戶ID分配的第一線程，所述第一線程用于處理所述用戶ID產生的各消息，所述待處理消息是由所述消息隊列中間件接收的變化消息，所述變化消息是通過第二服務器的數據庫中消息發生變化時發送的；

所述第一服務器通過所述第一線程讀取所述待處理消息，并對所述待處理消息進行多線程加鎖；