[發(fā)明專利]異步任務(wù)執(zhí)行方法、異步調(diào)度系統(tǒng)、裝置、設(shè)備和介質(zhì)

在審

• 申請?zhí)枺?/td>: 202310137244.3
• 申請日: 2023-02-10
• 公開（公告）號: CN116225647A
• 公開（公告）日: 2023-06-06
• 發(fā)明（設(shè)計）人: 胡琳;鄒泳彤;李俊杰;周潤坤
• 申請（專利權(quán)）人: 中國工商銀行股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/38
• 代理公司: 中科專利商標代理有限責任公司 11021
• 代理人: 張體南

本公開提供了異步任務(wù)執(zhí)行方法，涉及金融領(lǐng)域。其中由分布式服務(wù)節(jié)點執(zhí)行的方法包括：向控制中心發(fā)起異步任務(wù)執(zhí)行請求，其中，所述控制中心被配置為接收N個分布式服務(wù)節(jié)點中至少部分節(jié)點發(fā)起的異步任務(wù)執(zhí)行請求，N大于或等于2；接收所述控制中心響應(yīng)于所述異步任務(wù)執(zhí)行請求而返回的執(zhí)行權(quán)結(jié)果；若獲取到異步任務(wù)執(zhí)行權(quán)，則確定異步并發(fā)數(shù)量；并發(fā)執(zhí)行與所述異步并發(fā)數(shù)量對應(yīng)的異步任務(wù)。本公開還提供了異步調(diào)度系統(tǒng)、異步任務(wù)執(zhí)行裝置、設(shè)備、存儲介質(zhì)和程序產(chǎn)品。

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

本公開涉及金融領(lǐng)域，更具體地，涉及一種異步任務(wù)執(zhí)行方法、異步調(diào)度系統(tǒng)、裝置、設(shè)備、介質(zhì)和程序產(chǎn)品。

背景技術(shù)

在計算機編程中，異步是指獨立于主程序流發(fā)生的事件，以及處理這些事件的方法。這些行為與程序執(zhí)行并發(fā)發(fā)生，不需要阻塞程序等待結(jié)果。在業(yè)務(wù)系統(tǒng)有部分功能執(zhí)行耗時較長且耗資源，因此會將該部分功能用異步作業(yè)的方式處理，該功能同時對響應(yīng)時間也有要求，需要及時反饋客戶。

在實現(xiàn)本公開發(fā)明構(gòu)思的過程中，發(fā)明人發(fā)現(xiàn)：現(xiàn)有的異步調(diào)度方法大多是一級的并發(fā)控制模式，即通過一個單點管理(數(shù)據(jù)庫或者分布式下的服務(wù)注冊的方式)并發(fā)量，導致無法及時響應(yīng)，并經(jīng)常由于并發(fā)過高而引發(fā)系統(tǒng)崩潰。

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

鑒于上述問題，本公開提供了一種異步任務(wù)執(zhí)行方法、異步調(diào)度系統(tǒng)、裝置、設(shè)備、介質(zhì)和程序產(chǎn)品。

本公開實施例的一個方面提供了一種異步任務(wù)執(zhí)行方法，由分布式服務(wù)節(jié)點執(zhí)行，包括：向控制中心發(fā)起異步任務(wù)執(zhí)行請求，其中，所述控制中心被配置為接收N個分布式服務(wù)節(jié)點中至少部分節(jié)點發(fā)起的異步任務(wù)執(zhí)行請求，N大于或等于2；接收所述控制中心響應(yīng)于所述異步任務(wù)執(zhí)行請求而返回的執(zhí)行權(quán)結(jié)果；若獲取到異步任務(wù)執(zhí)行權(quán)，則確定異步并發(fā)數(shù)量；并發(fā)執(zhí)行與所述異步并發(fā)數(shù)量對應(yīng)的異步任務(wù)。

在一些實施例中，若獲取到異步任務(wù)執(zhí)行權(quán)，在所述確定異步并發(fā)數(shù)量之前，所述方法還包括：向所述控制中心發(fā)起異常節(jié)點清理請求，其中，所述異常節(jié)點包括所述N個分布式服務(wù)節(jié)點中被所述控制中心檢測出異常的節(jié)點；從所述控制中心獲取所述N個分布式服務(wù)節(jié)點中具有所述異步任務(wù)執(zhí)行權(quán)的節(jié)點數(shù)量；在所述節(jié)點數(shù)量小于并發(fā)節(jié)點數(shù)閾值的情況下，確定成功獲取所述異步任務(wù)執(zhí)行權(quán)。

在一些實施例中，若未獲取到所述異步任務(wù)執(zhí)行權(quán)，所述方法還包括：每隔第一預定時間段重復執(zhí)行所述向控制中心發(fā)起異步任務(wù)執(zhí)行請求的操作，并接收所述執(zhí)行權(quán)結(jié)果。

在一些實施例中，所述方法還包括：每隔第二預定時間段向所述控制中心上報心跳信息，其中，所述控制中心被配置為若未接收到該分布式服務(wù)節(jié)點的心跳信息，將其異步任務(wù)執(zhí)行權(quán)分配至其他節(jié)點。

在一些實施例中，所述確定異步并發(fā)數(shù)量包括：向令牌管理器申請令牌，其中，所述令牌管理器被配置為根據(jù)所述控制中心的令牌控制數(shù)量發(fā)放所述令牌；根據(jù)申請到的所述令牌的數(shù)量確定所述異步并發(fā)數(shù)量。

在一些實施例中，所述令牌管理器被安裝在該分布式服務(wù)節(jié)點中，利用所述令牌管理器執(zhí)行以下操作：每隔第三預定時間段向所述控制中心查詢所述令牌控制數(shù)量，其中，所述控制中心被配置為動態(tài)調(diào)整所述令牌控制數(shù)量；將所述控制中心返回的最新所述令牌控制數(shù)量與令牌總數(shù)進行比對，獲得比對結(jié)果，所述令牌總數(shù)包括已發(fā)令牌和待發(fā)令牌；根據(jù)所述比對結(jié)果發(fā)放或回收所述令牌。

本公開實施例的另一方面提供了一種異步任務(wù)執(zhí)行方法，由控制中心執(zhí)行，包括：接收N個分布式服務(wù)節(jié)點中至少部分節(jié)點發(fā)起的異步任務(wù)執(zhí)行請求，N大于或等于2；響應(yīng)于所述異步任務(wù)執(zhí)行請求，根據(jù)并發(fā)節(jié)點數(shù)閾值向所述N個分布式服務(wù)節(jié)點返回執(zhí)行權(quán)結(jié)果；其中，所述N個分布式服務(wù)節(jié)點中Q個分布式服務(wù)節(jié)點獲取到異步任務(wù)執(zhí)行權(quán)，所述Q個分布式服務(wù)節(jié)點中任一節(jié)點被配置為確定該節(jié)點的異步并發(fā)數(shù)量，并發(fā)執(zhí)行與所述異步并發(fā)數(shù)量對應(yīng)的異步任務(wù)，Q小于或等于N。