[發(fā)明專利]一種懸掛事務(wù)自動處理的方法和裝置

有效

• 申請?zhí)枺?/td>: 201610127425.8
• 申請日: 2016-03-07
• 公開（公告）號: CN107168775B
• 公開（公告）日: 2020-07-31
• 發(fā)明（設(shè)計(jì)）人: 田野
• 申請（專利權(quán)）人: 阿里巴巴集團(tuán)控股有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46;G06F9/50
• 代理公司: 北京國昊天誠知識產(chǎn)權(quán)代理有限公司 11315
• 代理人: 許志勇

本發(fā)明公開了一種懸掛事務(wù)自動處理的方法和裝置，屬于計(jì)算機(jī)通信技術(shù)領(lǐng)域。所述方法包括：當(dāng)預(yù)設(shè)懸掛定時查詢時間到達(dá)時，查詢參與者事務(wù)記錄表；根據(jù)所述參與者事務(wù)記錄表中記載的所述事務(wù)的狀態(tài)、所述事務(wù)的創(chuàng)建時間，以及當(dāng)前時間，確定所述事務(wù)是否屬于懸掛事務(wù)；當(dāng)確定所述事務(wù)屬于懸掛事務(wù)時，根據(jù)所述事務(wù)的ID，查詢所述事務(wù)的業(yè)務(wù)處理日志；根據(jù)所述事務(wù)的業(yè)務(wù)處理日志，按照預(yù)設(shè)懸掛事務(wù)處理規(guī)則，對所述事務(wù)進(jìn)行懸掛處理。所述裝置包括：第一查詢模塊、確定模塊、第二查詢模塊和處理模塊。本發(fā)明可以及時發(fā)現(xiàn)并處理懸掛事務(wù)，可以避免后續(xù)業(yè)務(wù)請求的重試失敗和資金損失，同時對于某些業(yè)務(wù)系統(tǒng)(如賬務(wù))，避免影響該系統(tǒng)日終結(jié)算等。

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

本發(fā)明涉及計(jì)算機(jī)通信技術(shù)領(lǐng)域，具體涉及一種懸掛事務(wù)自動處理的方法和裝置。

背景技術(shù)

分布式事務(wù)是指事務(wù)的參與者、支持事務(wù)的服務(wù)器、資源服務(wù)器以及事務(wù)管理器分別位于不同的分布式系統(tǒng)的不同節(jié)點(diǎn)之上。分布式事務(wù)的成員包括發(fā)起者、協(xié)調(diào)者和參與者。其中，發(fā)起者是分布式事務(wù)的發(fā)起方，一次分布式事務(wù)請求只有一個發(fā)起者。協(xié)調(diào)者是分布式事務(wù)的總控，負(fù)責(zé)分布式事務(wù)生命周期管理和所有分支的管理，一次分布式事務(wù)請求只有一個協(xié)調(diào)者。參與者是分布式事務(wù)當(dāng)中的分支事務(wù)的控制者，一次分布式事務(wù)請求可以用多個分支事務(wù)實(shí)現(xiàn)，因此可以有多個參與者。

分布式事務(wù)處理過程中，往往會有多個參與者發(fā)起的多個分支事務(wù)，且這些分支事務(wù)處于不同的網(wǎng)絡(luò)環(huán)境和服務(wù)器集群，由于分布式事務(wù)的環(huán)境復(fù)雜性，常常導(dǎo)致產(chǎn)生懸掛事務(wù)。現(xiàn)有技術(shù)在懸掛事務(wù)產(chǎn)生后，只有在收到業(yè)務(wù)沒有成功的反饋，或進(jìn)行日切(就是更換系統(tǒng)記賬的時間，也稱為日志切換)操作時，才會發(fā)現(xiàn)產(chǎn)生了懸掛事務(wù)，對懸掛事務(wù)進(jìn)行人工處理。

現(xiàn)有技術(shù)無法及時發(fā)現(xiàn)并處理懸掛事務(wù)，導(dǎo)致后續(xù)業(yè)務(wù)請求的重試失敗或者資金損失，同時對于某些業(yè)務(wù)系統(tǒng)(如賬務(wù))，會影響該系統(tǒng)日終結(jié)算等。

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

為了解決現(xiàn)有技術(shù)的問題，本發(fā)明提供了一種懸掛事務(wù)自動處理的方法和裝置，可以及時發(fā)現(xiàn)并處理懸掛事務(wù)，可以避免后續(xù)業(yè)務(wù)請求的重試失敗和資金損失，同時對于某些業(yè)務(wù)系統(tǒng)(如賬務(wù))，避免影響該系統(tǒng)日終結(jié)算等。

為了解決上述問題，本發(fā)明公開了一種懸掛事務(wù)自動處理的方法，所述方法包括：

當(dāng)預(yù)設(shè)懸掛定時查詢時間到達(dá)時，查詢參與者事務(wù)記錄表；其中，所述參與者事務(wù)記錄表中記載有參與者執(zhí)行的事務(wù)的ID、所述事務(wù)的狀態(tài)、所述事務(wù)的創(chuàng)建時間；

根據(jù)所述參與者事務(wù)記錄表中記載的所述事務(wù)的狀態(tài)、所述事務(wù)的創(chuàng)建時間，以及當(dāng)前時間，確定所述事務(wù)是否屬于懸掛事務(wù)；

當(dāng)確定所述事務(wù)屬于懸掛事務(wù)時，根據(jù)所述事務(wù)的ID，查詢所述事務(wù)的業(yè)務(wù)處理日志；

根據(jù)所述事務(wù)的業(yè)務(wù)處理日志，按照預(yù)設(shè)懸掛事務(wù)處理規(guī)則，對所述事務(wù)進(jìn)行懸掛處理。

進(jìn)一步地，根據(jù)所述參與者事務(wù)記錄表中記載的所述事務(wù)的狀態(tài)、所述事務(wù)的創(chuàng)建時間，以及當(dāng)前時間，確定所述事務(wù)是否屬于懸掛事務(wù)，包括：

判斷所述參與者事務(wù)記錄表中記載的所述事務(wù)的狀態(tài)是否為正在執(zhí)行；

如果所述事務(wù)的狀態(tài)為正在執(zhí)行，則計(jì)算所述當(dāng)前時間與所述事務(wù)的創(chuàng)建時間的間隔；

判斷所述當(dāng)前時間與所述事務(wù)的創(chuàng)建時間的間隔是否大于預(yù)設(shè)懸掛時間間隔閾值；

如果所述當(dāng)前時間與所述事務(wù)的創(chuàng)建時間的間隔大于所述預(yù)設(shè)懸掛時間間隔閾值，則確定所述事務(wù)屬于懸掛事務(wù)。

進(jìn)一步地，當(dāng)確定所述事務(wù)屬于懸掛事務(wù)時，根據(jù)所述事務(wù)的ID，查詢所述事務(wù)的業(yè)務(wù)處理日志，包括：

當(dāng)確定所述事務(wù)屬于懸掛事務(wù)時，在所述參與者事務(wù)記錄表中標(biāo)記所述事務(wù)的屬性為懸掛事務(wù)；