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

在審

• 申請(qǐng)?zhí)枺?/td>: 202010621465.4
• 申請(qǐng)日: 2020-06-30
• 公開(kāi)（公告）號(hào): CN111784329A
• 公開(kāi)（公告）日: 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
• 代理人: 曾軍

本申請(qǐng)公開(kāi)了一種業(yè)務(wù)數(shù)據(jù)的處理方法和裝置、存儲(chǔ)介質(zhì)、電子裝置。其中，該方法包括：獲取業(yè)務(wù)應(yīng)用中業(yè)務(wù)賬號(hào)的業(yè)務(wù)操作，其中，業(yè)務(wù)操作用于業(yè)務(wù)賬號(hào)指示對(duì)數(shù)據(jù)庫(kù)中屬于業(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)過(guò)的業(yè)務(wù)消息；在從目標(biāo)消息隊(duì)列中獲取到目標(biāo)業(yè)務(wù)消息的情況下，對(duì)數(shù)據(jù)庫(kù)中的目標(biāo)業(yè)務(wù)數(shù)據(jù)進(jìn)行處理。本申請(qǐng)解決了相關(guān)技術(shù)中業(yè)務(wù)數(shù)據(jù)的處理效率較低的技術(shù)問(wèn)題。

技術(shù)領(lǐng)域

本申請(qǐng)涉及數(shù)據(jù)處理領(lǐng)域，具體而言，涉及一種業(yè)務(wù)數(shù)據(jù)的處理方法和裝置、存儲(chǔ)介質(zhì)、電子裝置。

背景技術(shù)

熱點(diǎn)賬戶具有以下特征，一是與該賬戶關(guān)聯(lián)的交易量大，交易筆數(shù)多；二是與該賬戶關(guān)聯(lián)的交易頻次高，并發(fā)量高；嚴(yán)格意義上講，只要符合上述兩個(gè)特征的賬戶都可稱為熱點(diǎn)賬戶，而這里的賬戶不局限為實(shí)體賬戶、虛擬賬戶、記賬簿等，只是在金融領(lǐng)域，賬戶的概念及場(chǎng)景涉及相對(duì)較廣泛。

熱點(diǎn)賬戶問(wèn)題是在賬戶系統(tǒng)設(shè)計(jì)、開(kāi)發(fā)中普遍需要解決的技術(shù)難點(diǎn)，需要解決單賬戶余額頻繁修改導(dǎo)致鎖并發(fā)從而影響整個(gè)系統(tǒng)吞吐性能的問(wèn)題，目前解決的方法主要有以下幾個(gè)：降低鎖粒度，將熱點(diǎn)單賬戶拆分多個(gè)子賬戶，將對(duì)一個(gè)賬戶的操作轉(zhuǎn)化為對(duì)多個(gè)賬戶的操作，以此降低了鎖的粒度，減少并發(fā)阻塞概率，從而提高整個(gè)系統(tǒng)吞吐性能；臨時(shí)表異步更新，將所有對(duì)賬戶的操作保存在臨時(shí)表中，然后異步通過(guò)定時(shí)任務(wù)掃描臨時(shí)表對(duì)熱點(diǎn)賬戶進(jìn)行操作。

發(fā)明人經(jīng)過(guò)對(duì)以上解決方案進(jìn)行分析認(rèn)識(shí)到：降低鎖粒度主要存在以下幾個(gè)缺點(diǎn)：會(huì)出現(xiàn)服務(wù)“停頓”，例如將扣減的熱點(diǎn)賬戶拆分多個(gè)子賬戶，如果某個(gè)子賬戶余額不足，會(huì)對(duì)該子賬戶做資金歸集，將其他子賬戶余額歸集到該子賬戶(每個(gè)子賬戶設(shè)置可歸集金額限制)，而在資金歸集過(guò)程，這個(gè)扣減的熱點(diǎn)賬戶是“停頓”狀態(tài)(即服務(wù)不可用狀態(tài))；業(yè)務(wù)比較復(fù)雜，例如要查詢熱點(diǎn)賬戶余額，需要將所有的子賬戶余額進(jìn)行匯總，匯總中各賬戶余額不是同一時(shí)刻狀態(tài)，得到賬戶余額也是不準(zhǔn)確的(業(yè)務(wù)操作頻繁時(shí)，賬戶余額誤差越大)；無(wú)法徹底解決高并發(fā)業(yè)務(wù)場(chǎng)景下賬戶系統(tǒng)吞吐阻塞造成的問(wèn)題。

臨時(shí)表異步更新主要存在以下缺點(diǎn)：業(yè)務(wù)量巨大時(shí)，臨時(shí)表的維護(hù)比較復(fù)雜，因?yàn)楫?dāng)臨時(shí)表數(shù)據(jù)量很大時(shí)，需要解決大表查詢、失效數(shù)據(jù)清除等問(wèn)題，同時(shí)，異步更新的時(shí)效性，也很難保證。

針對(duì)上述的問(wèn)題，目前尚未提出有效的解決方案。

發(fā)明內(nèi)容

本申請(qǐng)實(shí)施例提供了一種業(yè)務(wù)數(shù)據(jù)的處理方法和裝置、存儲(chǔ)介質(zhì)、電子裝置，以至少解決相關(guān)技術(shù)中業(yè)務(wù)數(shù)據(jù)的處理效率較低的技術(shù)問(wèn)題。

根據(jù)本申請(qǐng)實(shí)施例的一個(gè)方面，提供了一種業(yè)務(wù)數(shù)據(jù)的處理方法，包括：獲取業(yè)務(wù)應(yīng)用中業(yè)務(wù)賬號(hào)的業(yè)務(wù)操作，其中，業(yè)務(wù)操作用于業(yè)務(wù)賬號(hào)指示對(duì)數(shù)據(jù)庫(kù)中屬于業(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)過(guò)的業(yè)務(wù)消息；在從目標(biāo)消息隊(duì)列中獲取到目標(biāo)業(yè)務(wù)消息的情況下，對(duì)數(shù)據(jù)庫(kù)中的目標(biāo)業(yè)務(wù)數(shù)據(jù)進(jìn)行處理。

根據(jù)本申請(qǐng)實(shí)施例的另一方面，還提供了一種業(yè)務(wù)數(shù)據(jù)的處理裝置，包括：獲取單元，用于獲取業(yè)務(wù)應(yīng)用中業(yè)務(wù)賬號(hào)的業(yè)務(wù)操作，其中，業(yè)務(wù)操作用于業(yè)務(wù)賬號(hào)指示對(duì)數(shù)據(jù)庫(kù)中屬于業(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)過(guò)的業(yè)務(wù)消息；處理單元，用于在從目標(biāo)消息隊(duì)列中獲取到目標(biāo)業(yè)務(wù)消息的情況下，對(duì)數(shù)據(jù)庫(kù)中的目標(biāo)業(yè)務(wù)數(shù)據(jù)進(jìn)行處理。

根據(jù)本申請(qǐng)實(shí)施例的另一方面，還提供了一種存儲(chǔ)介質(zhì)，該存儲(chǔ)介質(zhì)包括存儲(chǔ)的程序，程序運(yùn)行時(shí)執(zhí)行上述的方法。

根據(jù)本申請(qǐng)實(shí)施例的另一方面，還提供了一種電子裝置，包括存儲(chǔ)器、處理器及存儲(chǔ)在存儲(chǔ)器上并可在處理器上運(yùn)行的計(jì)算機(jī)程序，處理器通過(guò)計(jì)算機(jī)程序執(zhí)行上述的方法。