[發明專利]一種業務變更消息的處理方法及裝置

在審

• 申請號: 202011083983.1
• 申請日: 2020-10-12
• 公開（公告）號: CN114422577A
• 公開（公告）日: 2022-04-29
• 發明（設計）人: 歐陽晶;程楠;袁易之;司超
• 申請（專利權）人: 騰訊科技（深圳）有限公司
• 主分類號: H04L67/51
• 分類號: H04L67/51;H04L67/55;H04L67/10;H04L67/562;H04L49/901;G06F11/14;G06F9/54
• 代理公司: 北京同達信恒知識產權代理有限公司 11291
• 代理人: 李娟

1.一種業務變更消息的處理方法，其特征在于，包括：

接收到攜帶至少一個業務變更消息的業務變更請求時，將所述至少一個業務變更消息寫入持久化消息隊列，所述持久化消息隊列位于服務器的非易失存儲介質中，且所述持久化消息隊列中的業務變更消息備份保存在所述服務器的非易失存儲介質中；

根據先入先出的順序，從所述持久化消息隊列中獲取業務變更消息，并將獲取的業務變更消息的消息標識寫入消息中間件；

通過所述消息中間件將消息標識推送給對應的消息訂閱端，所述消息訂閱端為訂閱了業務變更消息的訂閱端，以使所述消息訂閱端基于消息標識從所述服務器的非易失存儲介質中獲取對應的業務變更消息。

2.如權利要求1所述的方法，其特征在于，所述將所述至少一個業務變更消息寫入持久化消息隊列，包括：

針對所述至少一個業務變更消息中的每個業務變更消息，將業務變更消息寫入所述持久化消息隊列中結尾指針指向的位置；

將所述結尾指針的位置向隊尾方向移動一個位置。

3.如權利要求2所述的方法，其特征在于，所述根據先入先出的順序，從所述持久化消息隊列中獲取業務變更消息，包括：

獲取所述持久化消息隊列中位于起始指針指向的位置的業務變更消息；

從所述持久化消息隊列中刪除位于所述起始指針指向的位置的業務變更消息；

將所述起始指針的位置向隊尾方向移動一個位置。

4.如權利要求1所述的方法，其特征在于，還包括：

將所述業務變更請求寫入請求數據庫，將所述業務變更請求的處理日志保存在大數據處理平臺中。

5.如權利要求4所述的方法，其特征在于，還包括：

根據所述消息中間件以及所述大數據處理平臺中保存的數據，校驗接收的業務變更消息是否丟失。

6.如權利要求1至5任一所述的方法，其特征在于，所述持久化消息隊列為Leveldb中的持久化消息隊列。

7.一種業務變更消息的處理裝置，其特征在于，包括：

接收模塊，用于接收到攜帶至少一個業務變更消息的業務變更請求時，將所述至少一個業務變更消息寫入持久化消息隊列，所述持久化消息隊列位于服務器的非易失存儲介質中，且所述持久化消息隊列中的業務變更消息備份保存在所述服務器的非易失存儲介質中；

處理模塊，用于根據先入先出的順序，從所述持久化消息隊列中獲取業務變更消息，并將獲取的業務變更消息的消息標識寫入消息中間件；

推送模塊，用于通過所述消息中間件將消息標識推送給對應的消息訂閱端，所述消息訂閱端為訂閱了業務變更消息的訂閱端，以使所述消息訂閱端基于消息標識從所述服務器的非易失存儲介質中獲取對應的業務變更消息。

8.如權利要求7所述的裝置，其特征在于，所述接收模塊具體用于：

針對所述至少一個業務變更消息中的每個業務變更消息，將業務變更消息寫入所述持久化消息隊列中結尾指針指向的位置；

將所述結尾指針的位置向隊尾方向移動一個位置。

9.一種計算機設備，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，其特征在于，所述處理器執行所述程序時實現權利要求1～6任一權利要求所述方法的步驟。

10.一種計算機可讀存儲介質，其特征在于，其存儲有可由計算機設備執行的計算機程序，當所述程序在計算機設備上運行時，使得所述計算機設備執行權利要求1～6任一所述方法的步驟。