[發(fā)明專利]任務的處理方法和裝置

在審

• 申請?zhí)枺?/td>: 202210142819.6
• 申請日: 2022-02-16
• 公開（公告）號: CN116643799A
• 公開（公告）日: 2023-08-25
• 發(fā)明（設計）人: 郜業(yè)鋒;董俊峰;強群力;劉超千;趙彤;沈村敬;劉海龍
• 申請（專利權(quán)）人: 網(wǎng)聯(lián)清算有限公司
• 主分類號: G06F9/4401
• 分類號: G06F9/4401;G06F9/50
• 代理公司: 北京清亦華知識產(chǎn)權(quán)代理事務所(普通合伙) 11201
• 代理人: 杜月

本申請?zhí)岢隽艘环N任務的處理方法和裝置，該處理方法包括：根據(jù)業(yè)務系統(tǒng)的任務拉取請求啟用與業(yè)務系統(tǒng)對應的任務拉取線程，并使啟用的任務拉取線程休眠預設時間；在滿足喚醒條件時，將當前已休眠的任務拉取線程對應的業(yè)務系統(tǒng)作為候選業(yè)務系統(tǒng)；根據(jù)各候選業(yè)務系統(tǒng)的任務分配權(quán)重，確定處理任務的目標業(yè)務系統(tǒng)；喚醒與該目標業(yè)務系統(tǒng)對應的目標任務拉取線程，基于目標任務拉取線程從數(shù)據(jù)中心拉取任務，并將拉取的任務發(fā)給目標業(yè)務系統(tǒng)。本申請通過任務分配權(quán)重來確定目標業(yè)務系統(tǒng)，向權(quán)重較高的候選業(yè)務系統(tǒng)較大概率的分配任務，權(quán)重較低的候選業(yè)務系統(tǒng)較小概率的發(fā)送任務，能夠?qū)崿F(xiàn)任務的均衡分配，避免某個或者某幾個業(yè)務系統(tǒng)過載。

技術(shù)領域

本申請涉及計算機技術(shù)領域，尤其涉及一種任務的處理方法和裝置。

背景技術(shù)

相關技術(shù)中，隨著業(yè)務量越來越大，通過單一設備無法滿足任務處理的需求，因此，利用分布式系統(tǒng)來處理任務成為了一種解決方式。但該方式存在的問題是，無法提供一種較為均衡的任務分配方式，例如，由任務分配節(jié)點向各任務處理節(jié)點分發(fā)任務的模式下，可能使某些負載很高的任務處理節(jié)點也接收到任務，導致對業(yè)務產(chǎn)生影響，甚至產(chǎn)生生產(chǎn)事故，而且在任務處理節(jié)點重啟或者某些情況宕機時，可能導致任務丟失。

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

本申請在至少在一定程度上解決相關技術(shù)中的技術(shù)問題之一。

為此，本申請的一個目的在于提出一種任務的處理方法，實現(xiàn)任務的均衡分配，避免某個或者某幾個業(yè)務系統(tǒng)過載，進而可以實現(xiàn)負載均衡。同時，將任務儲存在數(shù)據(jù)中心，避免了在業(yè)務系統(tǒng)重啟發(fā)布或者某些情況宕機時導致任務丟失。

本申請的第二個目的在于提出一種任務的處理裝置。

本申請的第三個目的在于提出一種電子設備。

本申請的第四個目的在于提出一種非瞬時計算機可讀存儲介質(zhì)。

本申請的第五個目的在于提出一種計算機程序產(chǎn)品。

為達上述目的，本申請第一方面實施例提出了一種任務的處理方法，包括：根據(jù)業(yè)務系統(tǒng)的任務拉取請求啟用與業(yè)務系統(tǒng)對應的任務拉取線程，并使啟用的任務拉取線程休眠預設時間；在滿足喚醒條件時，將當前已休眠的任務拉取線程對應的業(yè)務系統(tǒng)作為候選業(yè)務系統(tǒng)；根據(jù)各候選業(yè)務系統(tǒng)的任務分配權(quán)重，確定處理任務的目標業(yè)務系統(tǒng)；喚醒與該目標業(yè)務系統(tǒng)對應的目標任務拉取線程，基于目標任務拉取線程從數(shù)據(jù)中心拉取任務，并將拉取的任務發(fā)給目標業(yè)務系統(tǒng)。

根據(jù)本申請的一個實施例，根據(jù)各候選業(yè)務系統(tǒng)的任務分配權(quán)重，確定處理任務的目標業(yè)務系統(tǒng)，包括：根據(jù)各候選業(yè)務系統(tǒng)的任務分配權(quán)重，以及多個候選業(yè)務系統(tǒng)的順序，確定各候選業(yè)務系統(tǒng)分別對應的數(shù)值區(qū)間；在根據(jù)總?cè)蝿辗峙錂?quán)重確定的隨機數(shù)區(qū)間之內(nèi)生成隨機數(shù)，總?cè)蝿辗峙錂?quán)重為各候選業(yè)務系統(tǒng)的任務分配權(quán)重之和；確定隨機數(shù)所處的目標數(shù)值區(qū)間，將目標數(shù)值區(qū)間對應的候選業(yè)務系統(tǒng)作為目標業(yè)務系統(tǒng)。

根據(jù)本申請的一個實施例，根據(jù)各候選業(yè)務系統(tǒng)的任務分配權(quán)重，以及多個候選業(yè)務系統(tǒng)的順序，確定各候選業(yè)務系統(tǒng)分別對應的數(shù)值區(qū)間，包括：從根據(jù)順序確定的第一個候選業(yè)務系統(tǒng)開始，將第一個候選業(yè)務系統(tǒng)的任務分配權(quán)重設置為第一個候選業(yè)務系統(tǒng)對應的第一個數(shù)據(jù)區(qū)間的上端點；針對第i個候選業(yè)務系統(tǒng)，以第i-1個候選業(yè)務系統(tǒng)對應的數(shù)值區(qū)間的上端點為第i個候選業(yè)務系統(tǒng)對應的第i個數(shù)據(jù)區(qū)間的下端點，并將第i個候選業(yè)務系統(tǒng)的任務分配權(quán)重與第i個數(shù)據(jù)區(qū)間的下端點相加，得到第i個數(shù)據(jù)區(qū)間的上端點；其中，最后一個候選業(yè)務系統(tǒng)的上端點為總?cè)蝿辗峙錂?quán)重。

根據(jù)本申請的一個實施例，多個候選業(yè)務系統(tǒng)的順序是根據(jù)各候選業(yè)務系統(tǒng)首次發(fā)送任務拉取請求的時刻或各業(yè)務系統(tǒng)的標識信息確定的。

根據(jù)本申請的一個實施例，候選業(yè)務系統(tǒng)的任務分配權(quán)重是通過如下方式確定的：在權(quán)重記錄表中查找與候選業(yè)務系統(tǒng)的標識信息對應的任務分配權(quán)重記錄；若在權(quán)重記錄表中無法查找到某個標識信息，則為相應的標識信息配置預設的任務分配權(quán)重，并對應記錄在權(quán)重記錄表中。