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

在審

• 申請號: 202110700492.5
• 申請日: 2021-06-23
• 公開（公告）號: CN113377795A
• 公開（公告）日: 2021-09-10
• 發明（設計）人: 余歡;凌磊
• 申請（專利權）人: 北京沃東天駿信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F9/54
• 代理公司: 中原信達知識產權代理有限責任公司 11219
• 代理人: 楊倩;趙迪

1.一種消息處理的方法，其特征在于，應用于分布式集群；包括：

利用分布式集群中的一個或多個實例分別接收數據庫觸發的多個待處理消息，所述多個待處理消息對應同一數據標識；

根據所述數據標識對所述一個或多個實例進行分布式加鎖處理，得到分布式鎖的屬性值；

利用被加鎖的第一實例對所接收到的所述多個待處理消息進行處理，以根據所述數據庫中數據，對自身所存儲的數據進行處理；

利用未被加鎖的第二實例更新分布式鎖的屬性值；

當所述第一實例和所述第二實例的分布式鎖的屬性值不同時，對所述第一實例和第二實例中的數據進行同步。

2.根據權利要求1所述的方法，其特征在于，所述利用被加鎖的第一實例對所接收到的所述多個待處理消息進行處理，包括：利用所述第一實例根據所述數據標識，對所接收到的所述多個待處理消息進行去重處理，并根據去重處理結果和所述數據庫中數據，對自身所存儲的數據進行處理。

3.根據權利要求2所述的方法，其特征在于，所述根據去重處理結果和所述數據庫中數據，對自身所存儲的數據進行處理，包括：根據所述去重處理結果所指示的所述數據標識，從所述數據庫中獲取與所述數據標識對應的數據表；

根據獲取的所述數據表，對自身所存儲的數據進行更新。

4.根據權利要求1所述的方法，其特征在于，根據所述數據標識對所述一個或多個實例進行分布式加鎖處理，得到分布式鎖的屬性值，包括：

針對所述數據標識，生成隨機數，根據所述隨機數對所述一個或多個實例進行分布式加鎖處理，并將所述隨機數作為所述屬性值。

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

當第二實例再次接收到所述數據庫觸發的數據更新消息時，利用所述第二實例再次更新所述分布式鎖的屬性值。

6.根據權利要求5所述的方法，其特征在于，利用所述第二實例更新所述分布式鎖的屬性值包括：

利用所述第二實例遞增所述分布式的屬性值。

7.根據權利要求1所述的方法，其特征在于，所述對所述第一實例和第二實例中的數據進行同步，包括：

根據所述第一實例和所述第二實例分別對應的分布式鎖的屬性值的大小，從所述第一實例和所述第二實例中確定數據同步源，并根據所述數據同步源中的數據，對數據進行同步。

8.一種數據處理的裝置，其特征在于，包括：

接收模塊、第一處理模塊、確定模塊、第二處理模塊、第三處理模塊和第四處理模塊；其中，

所述接收模塊，用于接收分布式集群中的一個或多個實例分別接收數據庫觸發的多個待處理消息；

所述第一處理模塊，根據所述數據標識對所述一個或多個實例進行分布式加鎖處理，得到分布式鎖的屬性值；

所述第二處理模塊，利用被加鎖的第一實例對所接收到的所述多個待處理消息進行處理，以根據所述數據庫中數據，對自身所存儲的數據進行處理；

所述第三處理模塊，利用未被加鎖的第二實例更新分布式鎖的屬性值；

所述第一確定模塊，用于確定所述第一實例和所述第二實例的分布式鎖的屬性值是否不同。如果是，觸發所述第四處理模塊；如果否，結束進程；

所述第四處理模塊，用于對所述第一實例和第二實例中的數據進行同步。

9.一種消息處理的電子設備，其特征在于，包括：

一個或多個處理器；

存儲裝置，用于存儲一個或多個程序，

當所述一個或多個程序被所述一個或多個處理器執行，使得所述一個或多個處理器實現如權利要求1-7中任一所述的方法。

10.一種計算機可讀介質，其上存儲有計算機程序，其特征在于，所述程序被處理器執行時實現如權利要求1-7中任一所述的方法。