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

有效

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

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

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

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

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

所述第一服務器在確定出所述待處理消息攜帶的時間戳早于獲取的已記錄數據的最新時間戳時，通過所述第一線程發送所述待處理消息的消息成功確認消息，所述消息成功確認消息為：成功確認出是否已消費所述待處理消息的消息。

2.如權利要求1所述的方法，其特征在于，所述第一服務器在確定出所述待處理消息攜帶的時間戳早于獲取的已記錄數據的最新時間戳時，通過所述第一線程發送所述待處理消息的消息成功確認消息，包括：

所述第一服務器獲取本地緩存中已記錄數據；

所述第一服務器在確定出所述待處理消息攜帶的時間戳早于所述本地緩存中已記錄數據的最新時間戳時，通過所述第一線程發送所述待處理消息的消費成功確認。

3.如權利要求1所述的方法，其特征在于，所述第一服務器在確定出所述待處理消息攜帶的時間戳早于獲取的已記錄數據的最新時間戳時，通過所述第一線程發送所述待處理消息的消息成功確認消息，包括：

所述第一服務器獲取本地緩存中已記錄數據；

所述第一服務器在確定出所述待處理消息攜帶的時間戳不早于所述本地緩存中已記錄數據的最新時間戳時，所述第一服務器獲取數據更新表中已記錄數據，所述數據更新表用于記錄各數據庫的操作日志的數據表；

所述第一服務器在確定出所述待處理消息攜帶的時間戳早于所述數據更新表中已記錄數據的最新時間戳時，所述第一服務器通過所述第一線程發送所述待處理消息的消費成功確認。

4.如權利要求3所述的方法，其特征在于，在所述第一服務器獲取數據更新表中已記錄數據之后，所述方法還包括：

所述第一服務器在確定出所述待處理消息攜帶的時間戳不早于所述數據更新表中已記錄數據的最新時間戳時，通過所述第一服務器將所述待處理消息寫入所述第一服務器的數據庫中；

所述第一服務器在確定出將所述待處理消息寫入所述第一服務器的數據庫中成功時，發送所述待處理消息的消費成功確認。

5.如權利要求4所述的方法，其特征在于，所述寫入所述第一服務器的數據庫中的過程中，包括：

所述第一服務器在確定出將所述待處理消息寫入所述第一服務器的數據庫中失敗時，發送所述待處理消息的遺棄確認消費。

6.一種消息處理裝置，其特征在于，應用于第一服務器，所述裝置包括：

接收模塊，用于接收由消息隊列中間件發送的待處理消息，所述待處理消息攜帶用戶ID；

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

讀取模塊，用于通過所述第一線程讀取所述待處理消息，并對所述待處理消息進行多線程加鎖；

第一處理模塊，用于在確定出所述待處理消息攜帶的時間戳早于獲取的已記錄數據的最新時間戳時，通過所述第一線程發送所述待處理消息的消息成功確認消息，所述消息成功確認消息為：成功確認出是否已消費所述待處理消息的消息。

7.如權利要求6所述的裝置，其特征在于，所述第一處理模塊，用于：

獲取本地緩存中已記錄數據；

在確定出所述待處理消息攜帶的時間戳早于所述本地緩存中已記錄數據的最新時間戳時，通過所述第一線程發送所述待處理消息的消費成功確認。