[發(fā)明專利]一種基于消息驅(qū)動的事務(wù)處理方法及裝置

在審

• 申請?zhí)枺?/td>: 201810735951.1
• 申請日: 2018-07-06
• 公開（公告）號: CN108958955A
• 公開（公告）日: 2018-12-07
• 發(fā)明（設(shè)計）人: 賈英哲;汪洵瀟
• 申請（專利權(quán)）人: 美利車（北京）網(wǎng)絡(luò)技術(shù)有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F17/30
• 代理公司: 北京市天璽沐澤專利代理事務(wù)所(普通合伙) 11532
• 代理人: 謝鑫

本申請公開了一種基于消息驅(qū)動的事務(wù)處理方法及裝置，該方法包括：執(zhí)行攜帶有執(zhí)行狀態(tài)的數(shù)據(jù)庫事務(wù)，監(jiān)測執(zhí)行數(shù)據(jù)庫事務(wù)所產(chǎn)生的事務(wù)消息，攔截監(jiān)測到的事務(wù)消息，并緩存在本地，當數(shù)據(jù)庫事務(wù)攜帶的執(zhí)行狀態(tài)為完成狀態(tài)時，發(fā)送所緩存的事務(wù)消息。通過上述方法，由于將執(zhí)行數(shù)據(jù)庫所產(chǎn)生的各事務(wù)消息緩存到本地，當數(shù)據(jù)庫事務(wù)完成時，再將緩存在本地的各事務(wù)消息發(fā)送出去，因此，即使終端在執(zhí)行數(shù)據(jù)庫事務(wù)的過程中某個操作發(fā)生了故障，也不會出現(xiàn)該操作之前所產(chǎn)生的事務(wù)消息無法撤銷的情況。

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

本申請涉及計算機技術(shù)領(lǐng)域，尤其涉及一種基于消息驅(qū)動的事務(wù)處理方法及裝置。

背景技術(shù)

目前，為了提升終端或數(shù)據(jù)庫業(yè)務(wù)處理效率，緩解終端或數(shù)據(jù)庫的運行負載，通常使用基于消息驅(qū)動的分布式架構(gòu)來處理數(shù)據(jù)庫事務(wù)。

現(xiàn)有的基于消息驅(qū)動的分布式架構(gòu)來處理數(shù)據(jù)庫事務(wù)主要流程為：終端執(zhí)行數(shù)據(jù)庫事務(wù)，當執(zhí)行數(shù)據(jù)庫事務(wù)產(chǎn)生事務(wù)消息時，將所生成的事務(wù)消息發(fā)送給消息中間件，消息中間件將所接收的事務(wù)消息發(fā)送給客戶端。

但是，在現(xiàn)有技術(shù)中，由于終端在執(zhí)行數(shù)據(jù)庫事務(wù)時某個操作發(fā)生了故障，該數(shù)據(jù)庫事務(wù)會重新執(zhí)行，因此，當終端在執(zhí)行數(shù)據(jù)庫事務(wù)的過程中某個操作發(fā)生了故障，就會導(dǎo)致在該操作之前向消息中間件所發(fā)送的事務(wù)消息無法撤銷。

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

本申請實施例提供一種基于消息驅(qū)動的事務(wù)處理方法及裝置，用以解決現(xiàn)有技術(shù)中當終端在執(zhí)行數(shù)據(jù)庫事務(wù)的過程中某個操作發(fā)生了故障，就會導(dǎo)致在該操作之前向消息中間件所發(fā)送的事務(wù)消息無法撤銷的問題。

本申請實施例提供的一種基于消息驅(qū)動的事務(wù)處理的方法，所述方法包括：

執(zhí)行數(shù)據(jù)庫事務(wù)，其中，所執(zhí)行的數(shù)據(jù)庫事務(wù)攜帶有執(zhí)行狀態(tài)；

監(jiān)測執(zhí)行所述數(shù)據(jù)庫事務(wù)所產(chǎn)生的事務(wù)消息；

攔截監(jiān)測到的事務(wù)消息，并緩存在本地；

當所述數(shù)據(jù)庫事務(wù)攜帶的執(zhí)行狀態(tài)為完成狀態(tài)時，發(fā)送所緩存的事務(wù)消息。

優(yōu)選地，所述方法還包括：

在執(zhí)行數(shù)據(jù)庫事務(wù)之前，指定數(shù)據(jù)庫事務(wù)；在指定的數(shù)據(jù)庫事務(wù)內(nèi)添加特定標記；監(jiān)測攜帶有特定標記的數(shù)據(jù)庫事務(wù)為待執(zhí)行的數(shù)據(jù)庫事務(wù)。

優(yōu)選地，所述方法還包括：

當所述數(shù)據(jù)庫事務(wù)攜帶的執(zhí)行狀態(tài)為回滾狀態(tài)時，刪除緩存在本地內(nèi)的事務(wù)消息。

優(yōu)選地，所述事務(wù)消息持久化存儲，所述數(shù)據(jù)庫事務(wù)攜帶的執(zhí)行狀態(tài)持久化存儲。

優(yōu)選地，所述方法還包括：

在發(fā)送所緩存的事務(wù)消息，或刪除緩存在本地內(nèi)的事務(wù)消息之后，將持久化存儲的事務(wù)消息標記為失效。

優(yōu)選地，所述方法還包括：

在執(zhí)行數(shù)據(jù)庫事務(wù)之后，生成所執(zhí)行的數(shù)據(jù)庫事務(wù)對應(yīng)的鍵值；建立所執(zhí)行的數(shù)據(jù)庫事務(wù)對應(yīng)的鍵值、所執(zhí)行的數(shù)據(jù)庫事務(wù)生成的事務(wù)消息以及所執(zhí)行的數(shù)據(jù)庫事務(wù)對應(yīng)的攜帶的執(zhí)行狀態(tài)三者之間的對應(yīng)關(guān)系。

優(yōu)選地，所述方法還包括：

當所述數(shù)據(jù)庫事務(wù)攜帶的執(zhí)行狀態(tài)為完成狀態(tài)時，發(fā)送所緩存的事務(wù)消息之后，接收返回的所述數(shù)據(jù)庫事務(wù)對應(yīng)的事務(wù)消息，根據(jù)建立的所執(zhí)行的數(shù)據(jù)庫事務(wù)對應(yīng)的鍵值、所執(zhí)行的數(shù)據(jù)庫事務(wù)生成的事務(wù)消息以及所執(zhí)行的數(shù)據(jù)庫事務(wù)對應(yīng)的攜帶的執(zhí)行狀態(tài)三者之間的對應(yīng)關(guān)系，將返回的所述數(shù)據(jù)庫事務(wù)對應(yīng)的事務(wù)消息與持久化存儲的所述數(shù)據(jù)庫事務(wù)對應(yīng)的事務(wù)消息進行匹配，確定返回的所述數(shù)據(jù)庫事務(wù)對應(yīng)的事務(wù)消息是否已經(jīng)存在；當未存在返回的所述數(shù)據(jù)庫事務(wù)對應(yīng)的事務(wù)消息時，執(zhí)行返回的所述數(shù)據(jù)庫事務(wù)對應(yīng)的事務(wù)消息。

優(yōu)選地，所述方法還包括：