[發(fā)明專利]作業(yè)處理方法、系統(tǒng)以及存儲(chǔ)介質(zhì)

有效

• 申請(qǐng)?zhí)枺?/td>: 202010119689.5
• 申請(qǐng)日: 2020-02-26
• 公開(kāi)（公告）號(hào): CN111340613B
• 公開(kāi)（公告）日: 2023-10-03
• 發(fā)明（設(shè)計(jì)）人: 張?zhí)m英;朱禮華;劉會(huì)明;易程星;龐堃鵬
• 申請(qǐng)（專利權(quán)）人: 中國(guó)郵政儲(chǔ)蓄銀行股份有限公司
• 主分類號(hào): G06Q40/02
• 分類號(hào): G06Q40/02;G06F16/27
• 代理公司: 中國(guó)貿(mào)促會(huì)專利商標(biāo)事務(wù)所有限公司 11038
• 代理人: 方亮

1.一種作業(yè)處理方法，包括：

總控節(jié)點(diǎn)根據(jù)待處理作業(yè)啟動(dòng)至少一個(gè)計(jì)算節(jié)點(diǎn)；其中，所述總控節(jié)點(diǎn)部署在一個(gè)或多個(gè)物理節(jié)點(diǎn)上；

所述計(jì)算節(jié)點(diǎn)獲取自身的計(jì)算能力信息和部署信息，根據(jù)所述計(jì)算能力信息和所述部署信息向所述總控節(jié)點(diǎn)申請(qǐng)作業(yè)；

所述總控節(jié)點(diǎn)根據(jù)所述計(jì)算能力信息和所述部署信息，向各個(gè)所述計(jì)算節(jié)點(diǎn)分配需要處理的節(jié)點(diǎn)作業(yè)；

所述計(jì)算節(jié)點(diǎn)對(duì)所述節(jié)點(diǎn)作業(yè)進(jìn)行相應(yīng)的業(yè)務(wù)處理。

2.如權(quán)利要求1所述的方法，所述總控節(jié)點(diǎn)根據(jù)待處理作業(yè)啟動(dòng)至少一個(gè)計(jì)算節(jié)點(diǎn)包括：

所述總控節(jié)點(diǎn)啟動(dòng)申請(qǐng)啟動(dòng)服務(wù)，通過(guò)所述申請(qǐng)啟動(dòng)服務(wù)獲取作業(yè)屬性并根據(jù)所述作業(yè)屬性生成所述待處理作業(yè)；

通過(guò)所述申請(qǐng)啟動(dòng)服務(wù)根據(jù)所述待處理作業(yè)確定需要參與作業(yè)處理的多個(gè)所述計(jì)算節(jié)點(diǎn)并發(fā)送所述作業(yè)處理啟動(dòng)消息；

其中，業(yè)務(wù)系統(tǒng)包括多個(gè)子系統(tǒng)，在每個(gè)子系統(tǒng)中部署一個(gè)或多個(gè)所述計(jì)算節(jié)點(diǎn)。

3.如權(quán)利要求2所述的方法，所述計(jì)算節(jié)點(diǎn)獲取自身的計(jì)算能力信息和部署信息，根據(jù)所述計(jì)算能力信息和所述部署信息向所述總控節(jié)點(diǎn)申請(qǐng)作業(yè)包括：

所述計(jì)算節(jié)點(diǎn)在接收所述作業(yè)處理啟動(dòng)消息后，啟動(dòng)作業(yè)申請(qǐng)服務(wù)；

通過(guò)所述作業(yè)申請(qǐng)服務(wù)獲取所述計(jì)算能力信息和所述部署信息；其中，所述部署信息包括：子系統(tǒng)信息、數(shù)據(jù)庫(kù)信息和節(jié)點(diǎn)配置信息；

通過(guò)所述作業(yè)申請(qǐng)服務(wù)生成攜帶有所述計(jì)算能力信息和所述部署信息的作業(yè)申請(qǐng)請(qǐng)求并發(fā)送給所述總控節(jié)點(diǎn)。

4.如權(quán)利要求3所述的方法，所述總控節(jié)點(diǎn)根據(jù)所述計(jì)算能力信息和所述部署信息，向各個(gè)所述計(jì)算節(jié)點(diǎn)分配需要處理的節(jié)點(diǎn)作業(yè)包括：

所述總控節(jié)點(diǎn)在接收到所述作業(yè)申請(qǐng)請(qǐng)求后，激活作業(yè)分配服務(wù)；

通過(guò)所述作業(yè)分配服務(wù)根據(jù)所述部署信息在所述待處理作業(yè)中確定各個(gè)所述計(jì)算節(jié)點(diǎn)需要處理的節(jié)點(diǎn)作業(yè)集合；其中，所述待處理作業(yè)的信息包括：子系統(tǒng)信息、數(shù)據(jù)庫(kù)信息、計(jì)算節(jié)點(diǎn)信息、子系統(tǒng)間并發(fā)信息和子系統(tǒng)內(nèi)并發(fā)信息；

通過(guò)所述作業(yè)分配服務(wù)根據(jù)所述計(jì)算能力信息以及每個(gè)作業(yè)需要的計(jì)算能力，為各個(gè)所述計(jì)算節(jié)點(diǎn)在對(duì)應(yīng)的所述節(jié)點(diǎn)作業(yè)集合中確定需要批量處理的所述節(jié)點(diǎn)作業(yè)并分別發(fā)送給各個(gè)所述計(jì)算節(jié)點(diǎn)。

5.如權(quán)利要求4所述的方法，所述計(jì)算節(jié)點(diǎn)對(duì)所述節(jié)點(diǎn)作業(yè)進(jìn)行相應(yīng)的業(yè)務(wù)處理包括：

所述計(jì)算節(jié)點(diǎn)通過(guò)所述作業(yè)申請(qǐng)服務(wù)調(diào)度多個(gè)作業(yè)處理服務(wù)，以使所述多個(gè)作業(yè)處理服務(wù)對(duì)所述節(jié)點(diǎn)作業(yè)進(jìn)行并發(fā)業(yè)務(wù)處理。

6.如權(quán)利要求5所述的方法，還包括：

所述計(jì)算節(jié)點(diǎn)通過(guò)所述作業(yè)申請(qǐng)服務(wù)獲取所述作業(yè)處理服務(wù)對(duì)于所述節(jié)點(diǎn)作業(yè)進(jìn)行業(yè)務(wù)處理的處理結(jié)果，基于所述處理結(jié)果向所述總控節(jié)點(diǎn)發(fā)送作業(yè)狀態(tài)更新請(qǐng)求；

所述總控節(jié)點(diǎn)通過(guò)作業(yè)狀態(tài)更新服務(wù)處理所述作業(yè)狀態(tài)更新請(qǐng)求，用以對(duì)所述待處理作業(yè)的狀態(tài)進(jìn)行更新處理。

7.如權(quán)利要求6所述的方法，還包括：

如果確定所述節(jié)點(diǎn)作業(yè)被處理完成后，所述計(jì)算節(jié)點(diǎn)通過(guò)所述作業(yè)申請(qǐng)服務(wù)重新生成攜帶有所述計(jì)算能力信息和所述部署信息的作業(yè)申請(qǐng)請(qǐng)求并向所述總控節(jié)點(diǎn)發(fā)送。

8.如權(quán)利要求2所述的方法，其中，

在每個(gè)子系統(tǒng)中部署多個(gè)所述計(jì)算節(jié)點(diǎn)，所述子系統(tǒng)包括：分布式數(shù)據(jù)庫(kù)；多個(gè)所述總控節(jié)點(diǎn)根據(jù)加鎖機(jī)制實(shí)現(xiàn)協(xié)同處理。

9.一種作業(yè)處理系統(tǒng)，包括：總控節(jié)點(diǎn)和計(jì)算節(jié)點(diǎn)；

總控節(jié)點(diǎn)，用于根據(jù)待處理作業(yè)啟動(dòng)至少一個(gè)計(jì)算節(jié)點(diǎn)；其中，所述總控節(jié)點(diǎn)部署在一個(gè)或多個(gè)物理節(jié)點(diǎn)上；

所述計(jì)算節(jié)點(diǎn)，用于獲取自身的計(jì)算能力信息和部署信息，根據(jù)所述計(jì)算能力信息和所述部署信息向所述總控節(jié)點(diǎn)申請(qǐng)作業(yè)；

所述總控節(jié)點(diǎn)，還用于根據(jù)所述計(jì)算能力信息和所述部署信息，向各個(gè)所述計(jì)算節(jié)點(diǎn)分配需要處理的節(jié)點(diǎn)作業(yè)，以使所述計(jì)算節(jié)點(diǎn)對(duì)所述節(jié)點(diǎn)作業(yè)進(jìn)行相應(yīng)的業(yè)務(wù)處理。