[發(fā)明專(zhuān)利]一種數(shù)據(jù)處理系統(tǒng)、方法及服務(wù)器群

在審

• 申請(qǐng)?zhí)枺?/td>: 202010905490.5
• 申請(qǐng)日: 2020-09-01
• 公開(kāi)（公告）號(hào): CN112035259A
• 公開(kāi)（公告）日: 2020-12-04
• 發(fā)明（設(shè)計(jì)）人: 董亞?wèn)|
• 申請(qǐng)（專(zhuān)利權(quán)）人: 中國(guó)銀行股份有限公司
• 主分類(lèi)號(hào): G06F9/50
• 分類(lèi)號(hào): G06F9/50;G06F9/54
• 代理公司: 北京集佳知識(shí)產(chǎn)權(quán)代理有限公司 11227
• 代理人: 趙曉榮

本申請(qǐng)公開(kāi)了一種數(shù)據(jù)處理系統(tǒng)、方法及服務(wù)器群，包括：應(yīng)用節(jié)點(diǎn)和派發(fā)服務(wù)器；應(yīng)用節(jié)點(diǎn)包括服務(wù)注冊(cè)進(jìn)程和任務(wù)處理進(jìn)程；服務(wù)注冊(cè)進(jìn)程與任務(wù)處理進(jìn)程共用內(nèi)存；服務(wù)注冊(cè)進(jìn)程用于檢測(cè)到內(nèi)存的標(biāo)志位為第一預(yù)設(shè)標(biāo)識(shí)時(shí)，向派發(fā)服務(wù)器發(fā)送注冊(cè)請(qǐng)求；派發(fā)服務(wù)器用于在接收到注冊(cè)請(qǐng)求后，向應(yīng)用節(jié)點(diǎn)傳輸待處理數(shù)據(jù)；任務(wù)處理進(jìn)程用于應(yīng)用節(jié)點(diǎn)接收到待處理數(shù)據(jù)后，對(duì)待處理數(shù)據(jù)進(jìn)行處理，并將內(nèi)存的標(biāo)志位由第一預(yù)設(shè)標(biāo)識(shí)切換為第二預(yù)設(shè)標(biāo)識(shí)。服務(wù)注冊(cè)進(jìn)程和任務(wù)處理進(jìn)程共用一段內(nèi)存，應(yīng)用節(jié)點(diǎn)通過(guò)該標(biāo)志位來(lái)向派發(fā)服務(wù)器提示自身的當(dāng)前狀態(tài)，派發(fā)服務(wù)器決定是否向該應(yīng)用節(jié)點(diǎn)派發(fā)待處理文件。因此本申請(qǐng)無(wú)需負(fù)載均衡服務(wù)器，降低了系統(tǒng)的成本。

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

本申請(qǐng)涉及服務(wù)器技術(shù)領(lǐng)域，特別是涉及一種數(shù)據(jù)處理系統(tǒng)、方法及服務(wù)器群。

背景技術(shù)

當(dāng)有大量數(shù)據(jù)需要處理時(shí)，一臺(tái)服務(wù)器的處理速度較慢，往往無(wú)法在規(guī)定的時(shí)間內(nèi)完成大量數(shù)據(jù)的處理。

為此，提出了多臺(tái)服務(wù)器對(duì)大量數(shù)據(jù)進(jìn)行處理的方法，進(jìn)而提高了對(duì)大量數(shù)據(jù)的處理速度，但是在實(shí)際實(shí)現(xiàn)過(guò)程中，需要一臺(tái)負(fù)載均衡服務(wù)器，為處理服務(wù)器分配需要處理的數(shù)據(jù)。

但是，負(fù)載均衡服務(wù)器是一個(gè)特殊的服務(wù)器，該服務(wù)器的價(jià)格昂貴。

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

為了解決上述技術(shù)問(wèn)題，本申請(qǐng)?zhí)峁┝艘环N數(shù)據(jù)處理系統(tǒng)、方法及服務(wù)器群，無(wú)需負(fù)載均衡服務(wù)器即可實(shí)現(xiàn)待處理數(shù)據(jù)的分配。

本申請(qǐng)實(shí)施例公開(kāi)了如下技術(shù)方案：

第一方面，本申請(qǐng)?zhí)峁┝艘环N數(shù)據(jù)處理系統(tǒng)，包括：應(yīng)用節(jié)點(diǎn)和派發(fā)服務(wù)器；

所述應(yīng)用節(jié)點(diǎn)包括服務(wù)注冊(cè)進(jìn)程和任務(wù)處理進(jìn)程；所述服務(wù)注冊(cè)進(jìn)程與所述任務(wù)處理進(jìn)程共用內(nèi)存；

所述服務(wù)注冊(cè)進(jìn)程，用于檢測(cè)到內(nèi)存的標(biāo)志位為第一預(yù)設(shè)標(biāo)識(shí)時(shí)，向所述派發(fā)服務(wù)器發(fā)送注冊(cè)請(qǐng)求；

所述派發(fā)服務(wù)器，用于在接收到所述注冊(cè)請(qǐng)求后，向所述應(yīng)用節(jié)點(diǎn)傳輸待處理數(shù)據(jù)；

所述任務(wù)處理進(jìn)程，用于所述應(yīng)用節(jié)點(diǎn)接收到所述待處理數(shù)據(jù)后，對(duì)所述待處理數(shù)據(jù)進(jìn)行處理，并將所述內(nèi)存的標(biāo)志位由所述第一預(yù)設(shè)標(biāo)識(shí)切換為第二預(yù)設(shè)標(biāo)識(shí)。

可選的，所述任務(wù)處理進(jìn)程，還用于完成對(duì)所述待處理文件的處理后，將所述內(nèi)存的標(biāo)志位由所述第二預(yù)設(shè)標(biāo)識(shí)切換為所述第一預(yù)設(shè)標(biāo)識(shí)。

可選的，所述派發(fā)服務(wù)器，具體用于在接收到所述注冊(cè)請(qǐng)求后，根據(jù)所述待處理數(shù)據(jù)的優(yōu)先級(jí)對(duì)所述待處理數(shù)據(jù)進(jìn)行排列，向所述應(yīng)用節(jié)點(diǎn)傳輸所述優(yōu)先級(jí)較高的待處理數(shù)據(jù)。

可選的，所述任務(wù)處理進(jìn)程，用于完成對(duì)所述待處理文件的處理后，將處理結(jié)果返回給所述派發(fā)服務(wù)器；

所述派發(fā)服務(wù)器，還用于將所述處理結(jié)果轉(zhuǎn)發(fā)給客戶(hù)端。

可選的，所述待處理文件由客戶(hù)端生成。

第二方面，本申請(qǐng)?zhí)峁┝艘环N數(shù)據(jù)處理方法，包括：

服務(wù)注冊(cè)進(jìn)程檢測(cè)到內(nèi)存的標(biāo)志位為第一預(yù)設(shè)標(biāo)識(shí)時(shí)，向派發(fā)服務(wù)器發(fā)送注冊(cè)請(qǐng)求；

所述派發(fā)服務(wù)器在接收到所述注冊(cè)請(qǐng)求后，向所述應(yīng)用節(jié)點(diǎn)傳輸待處理數(shù)據(jù)；

所述應(yīng)用節(jié)點(diǎn)接收到所述待處理數(shù)據(jù)后，任務(wù)處理進(jìn)程對(duì)所述待處理數(shù)據(jù)進(jìn)行處理，并將內(nèi)存的標(biāo)志位由所述第一預(yù)設(shè)標(biāo)識(shí)切換為第二預(yù)設(shè)標(biāo)識(shí)；

其中，所述應(yīng)用節(jié)點(diǎn)包括服務(wù)注冊(cè)進(jìn)程和任務(wù)處理進(jìn)程；所述服務(wù)注冊(cè)進(jìn)程與所述任務(wù)處理進(jìn)程共用所述內(nèi)存。

可選的，所述方法還包括：

所述任務(wù)處理進(jìn)程完成對(duì)所述待處理文件的處理后，將所述內(nèi)存的標(biāo)志位由所述第二預(yù)設(shè)標(biāo)識(shí)切換為所述第一預(yù)設(shè)標(biāo)識(shí)。