[發(fā)明專利]業(yè)務(wù)數(shù)據(jù)的處理方法和裝置、存儲(chǔ)介質(zhì)、電子裝置

在審

• 申請(qǐng)?zhí)枺?/td>: 202010621465.4
• 申請(qǐng)日: 2020-06-30
• 公開（公告）號(hào): CN111784329A
• 公開（公告）日: 2020-10-16
• 發(fā)明（設(shè)計(jì)）人: 馮鵬
• 申請(qǐng)（專利權(quán)）人: 京東數(shù)字科技控股有限公司
• 主分類號(hào): G06Q20/22
• 分類號(hào): G06Q20/22;G06Q40/04;G06F16/25;G06F11/14
• 代理公司: 北京華夏泰和知識(shí)產(chǎn)權(quán)代理有限公司 11662
• 代理人: 曾軍

1.一種業(yè)務(wù)數(shù)據(jù)的處理方法，其特征在于，包括：

獲取業(yè)務(wù)應(yīng)用中業(yè)務(wù)賬號(hào)的業(yè)務(wù)操作，其中，所述業(yè)務(wù)操作用于所述業(yè)務(wù)賬號(hào)指示對(duì)數(shù)據(jù)庫中屬于所述業(yè)務(wù)賬號(hào)的目標(biāo)業(yè)務(wù)數(shù)據(jù)進(jìn)行處理；

生成用于表示所述業(yè)務(wù)操作的目標(biāo)業(yè)務(wù)消息；

將所述目標(biāo)業(yè)務(wù)消息保存至目標(biāo)消息隊(duì)列，其中，所述目標(biāo)消息隊(duì)列用于保存未被成功消費(fèi)過的業(yè)務(wù)消息；

在從所述目標(biāo)消息隊(duì)列中獲取到所述目標(biāo)業(yè)務(wù)消息的情況下，對(duì)所述數(shù)據(jù)庫中的所述目標(biāo)業(yè)務(wù)數(shù)據(jù)進(jìn)行處理。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，

在生成用于表示所述業(yè)務(wù)操作的目標(biāo)業(yè)務(wù)消息之后，所述方法還包括：將所述目標(biāo)業(yè)務(wù)消息保存至第二數(shù)據(jù)庫，其中，所述第二數(shù)據(jù)庫用于備份生成的業(yè)務(wù)消息；

在將所述目標(biāo)業(yè)務(wù)消息保存至目標(biāo)消息隊(duì)列之后，所述方法還包括：在通過對(duì)比所述目標(biāo)消息隊(duì)列中的業(yè)務(wù)消息和所述第二數(shù)據(jù)庫中的業(yè)務(wù)消息確定所述目標(biāo)業(yè)務(wù)消息保存失敗或者所述目標(biāo)消息隊(duì)列發(fā)生故障的情況下，將所述第二數(shù)據(jù)庫中的所述目標(biāo)業(yè)務(wù)消息保存至所述目標(biāo)消息隊(duì)列。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，生成用于表示所述業(yè)務(wù)操作的目標(biāo)業(yè)務(wù)消息包括：

從多個(gè)生產(chǎn)者中查找目標(biāo)生產(chǎn)者，其中，所述目標(biāo)生產(chǎn)者為所述多個(gè)生產(chǎn)者中資源利用率最低或者資源余量最大或者被指定的生產(chǎn)者；

通過所述目標(biāo)生產(chǎn)者生成用于表示所述業(yè)務(wù)操作的所述目標(biāo)業(yè)務(wù)消息。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，從所述目標(biāo)消息隊(duì)列中獲取所述目標(biāo)業(yè)務(wù)消息包括：

確定多個(gè)消費(fèi)者中的第一消費(fèi)者，其中，所述第一消費(fèi)者是所述多個(gè)消費(fèi)者中用于消費(fèi)所述目標(biāo)業(yè)務(wù)消息的消費(fèi)者；

通過所述目標(biāo)消息隊(duì)列從所述目標(biāo)消息隊(duì)列中獲取所述目標(biāo)業(yè)務(wù)消息。

5.根據(jù)權(quán)利要求4所述的方法，其特征在于，確定多個(gè)消費(fèi)者中的第一消費(fèi)者包括：

在所述目標(biāo)消息隊(duì)列的偏向鎖未被分配的情況下，接收到所述多個(gè)消費(fèi)者中的消費(fèi)者獲取所述偏向鎖的請(qǐng)求，確定所述多個(gè)消費(fèi)者中當(dāng)前被分配所述偏向鎖的消費(fèi)者為所述第一消費(fèi)者，其中，所述偏向鎖用于獲取所述目標(biāo)消息隊(duì)列中業(yè)務(wù)消息的處理權(quán)限；

在所述目標(biāo)消息隊(duì)列的所述偏向鎖已被分配的情況下，將所述多個(gè)消費(fèi)者中被分配所述偏向鎖的消費(fèi)者作為所述第一消費(fèi)者。

6.根據(jù)權(quán)利要求1所述的方法，其特征在于，在將所述目標(biāo)業(yè)務(wù)消息保存至目標(biāo)消息隊(duì)列之后，所述方法還包括：

在第一消費(fèi)者從所述目標(biāo)消息隊(duì)列中獲取所述目標(biāo)業(yè)務(wù)消息之后，將所述目標(biāo)業(yè)務(wù)消息的處理狀態(tài)由待處理變更為處理中；

在對(duì)所述數(shù)據(jù)庫中的所述目標(biāo)業(yè)務(wù)數(shù)據(jù)的處理失敗的情況下，將所述目標(biāo)業(yè)務(wù)消息的處理狀態(tài)由處理中變更為處理失敗；

在對(duì)所述數(shù)據(jù)庫中的所述目標(biāo)業(yè)務(wù)數(shù)據(jù)的處理完成的情況下，將所述目標(biāo)業(yè)務(wù)消息的處理狀態(tài)由處理中變更為處理成功。

7.根據(jù)權(quán)利要求6所述的方法，其特征在于，在對(duì)所述數(shù)據(jù)庫中的所述目標(biāo)業(yè)務(wù)數(shù)據(jù)的處理失敗的情況下，所述方法還包括：

在所述目標(biāo)業(yè)務(wù)消息的處理失敗次數(shù)未達(dá)到目標(biāo)閾值的情況下，直接重復(fù)執(zhí)行所述目標(biāo)業(yè)務(wù)消息，或者將所述目標(biāo)業(yè)務(wù)消息的處理狀態(tài)由處理失敗變更為待處理，并保存至所述目標(biāo)消息隊(duì)列，以等待再次被執(zhí)行；

在所述目標(biāo)業(yè)務(wù)消息的處理失敗次數(shù)達(dá)到所述目標(biāo)閾值的情況下，將所述目標(biāo)業(yè)務(wù)消息交由多個(gè)消費(fèi)者中的第二消費(fèi)者進(jìn)行消費(fèi)或者生成用于表示所述目標(biāo)業(yè)務(wù)消息處理失敗的提示信息，其中，所述第二消費(fèi)者不同于所述第一消費(fèi)者。

8.根據(jù)權(quán)利要求1所述的方法，其特征在于，在對(duì)所述數(shù)據(jù)庫中的所述目標(biāo)業(yè)務(wù)數(shù)據(jù)進(jìn)行處理之后，所述方法還包括：

將對(duì)所述目標(biāo)業(yè)務(wù)消息的處理狀態(tài)發(fā)送至目標(biāo)生產(chǎn)者。