[發(fā)明專利]一種工業(yè)互聯(lián)網(wǎng)的業(yè)務(wù)數(shù)據(jù)處理方法、設(shè)備及介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202210180085.0
• 申請(qǐng)日: 2022-02-25
• 公開(kāi)（公告）號(hào): CN114579303A
• 公開(kāi)（公告）日: 2022-06-03
• 發(fā)明（設(shè)計(jì)）人: 倪志榮;于靜;宋凱月;商廣勇;季伶美
• 申請(qǐng)（專利權(quán)）人: 山東浪潮工業(yè)互聯(lián)網(wǎng)產(chǎn)業(yè)股份有限公司
• 主分類號(hào): G06F9/50
• 分類號(hào): G06F9/50;G06F16/25;G06F16/27;G16Y10/25
• 代理公司: 北京君慧知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11716
• 代理人: 董延麗

1.一種工業(yè)互聯(lián)網(wǎng)的業(yè)務(wù)數(shù)據(jù)處理方法，其特征在于，所述方法包括：

獲取工業(yè)設(shè)備上傳的業(yè)務(wù)信息，并通過(guò)IP協(xié)議棧對(duì)所述業(yè)務(wù)信息進(jìn)行分片，得到分片后的若干數(shù)據(jù)塊；

根據(jù)預(yù)設(shè)的流程引擎，確定所述業(yè)務(wù)信息對(duì)應(yīng)的多個(gè)邏輯處理節(jié)點(diǎn)，以及由所述多個(gè)邏輯處理節(jié)點(diǎn)組成的主處理流程；其中，各邏輯處理節(jié)點(diǎn)分別對(duì)應(yīng)不同的線程池，所述線程池由多個(gè)子線程組成，所述線程池包括業(yè)務(wù)邏輯線程池、網(wǎng)絡(luò)連接線程池和數(shù)據(jù)庫(kù)連接線程池；

根據(jù)所述數(shù)據(jù)塊的數(shù)量，確定當(dāng)前需調(diào)用的子線程數(shù)量；

按照所述主處理流程包含的各邏輯處理節(jié)點(diǎn)之間的流轉(zhuǎn)邏輯，依次從各所述邏輯處理節(jié)點(diǎn)對(duì)應(yīng)的線程池中，調(diào)用與所述線程數(shù)量對(duì)應(yīng)的多個(gè)目標(biāo)子線程；

執(zhí)行所述目標(biāo)子線程，以對(duì)所述業(yè)務(wù)信息對(duì)應(yīng)的若干數(shù)據(jù)塊進(jìn)行相應(yīng)的業(yè)務(wù)邏輯處理。

2.根據(jù)權(quán)利要求1所述的一種工業(yè)互聯(lián)網(wǎng)的業(yè)務(wù)數(shù)據(jù)處理方法，其特征在于，確定所述業(yè)務(wù)信息對(duì)應(yīng)的多個(gè)邏輯處理節(jié)點(diǎn)之后，所述方法還包括：

針對(duì)各邏輯處理節(jié)點(diǎn)，建立該邏輯處理節(jié)點(diǎn)對(duì)應(yīng)的主線程；

將所述主線程與其對(duì)應(yīng)的邏輯處理節(jié)點(diǎn)所包含的多個(gè)子線程依次進(jìn)行綁定，以生成相應(yīng)的映射關(guān)系。

3.根據(jù)權(quán)利要求2所述的一種工業(yè)互聯(lián)網(wǎng)的業(yè)務(wù)數(shù)據(jù)處理方法，其特征在于，按照所述主處理流程包含的各邏輯處理節(jié)點(diǎn)之間的流轉(zhuǎn)邏輯，依次從各所述邏輯處理節(jié)點(diǎn)對(duì)應(yīng)的線程池中，確定與所述線程數(shù)量對(duì)應(yīng)的多個(gè)目標(biāo)子線程，具體包括：

確定所述業(yè)務(wù)邏輯線程池對(duì)應(yīng)的第一主線程，根據(jù)所述第一主線程對(duì)應(yīng)的映射關(guān)系，將所述業(yè)務(wù)信息對(duì)應(yīng)的數(shù)據(jù)塊分配至所述業(yè)務(wù)邏輯線程池中的多個(gè)第一目標(biāo)子線程；

在所述多個(gè)第一目標(biāo)子線程均完成其對(duì)應(yīng)的業(yè)務(wù)邏輯處理后，通過(guò)所述第一主線程，將所述多個(gè)第一目標(biāo)子線程的第一數(shù)據(jù)處理結(jié)果流轉(zhuǎn)至所述網(wǎng)絡(luò)連接線程池對(duì)應(yīng)的第二主線程，并根據(jù)所述第二主線程對(duì)應(yīng)的映射關(guān)系，將所述多個(gè)第一目標(biāo)子線程的數(shù)據(jù)處理結(jié)果，分配至所述網(wǎng)絡(luò)連接線程池中的多個(gè)第二目標(biāo)子線程；

在所述多個(gè)第二目標(biāo)子線程均完成其對(duì)應(yīng)的業(yè)務(wù)邏輯處理后，通過(guò)所述第二主線程，將所述多個(gè)第二目標(biāo)子線程的第二數(shù)據(jù)處理結(jié)果流轉(zhuǎn)至所述數(shù)據(jù)庫(kù)連接線程池對(duì)應(yīng)的第三主線程，并根據(jù)所述第三主線程對(duì)應(yīng)的映射關(guān)系，將所述多個(gè)第二目標(biāo)子線程的數(shù)據(jù)處理結(jié)果，分配至所述數(shù)據(jù)庫(kù)連接線程池中的多個(gè)第三目標(biāo)子線程；

其中，所述第一目標(biāo)子線程、所述第二目標(biāo)子線程和所述第三目標(biāo)子線程的數(shù)量與所述線程數(shù)量相對(duì)應(yīng)，且至少分別對(duì)應(yīng)一個(gè)所述數(shù)據(jù)塊。

4.根據(jù)權(quán)利要求1所述的一種工業(yè)互聯(lián)網(wǎng)的業(yè)務(wù)數(shù)據(jù)處理方法，其特征在于，確定與所述線程數(shù)量對(duì)應(yīng)的多個(gè)目標(biāo)子線程之后，所述方法還包括：

針對(duì)所述邏輯處理節(jié)點(diǎn)，生成所述業(yè)務(wù)信息對(duì)應(yīng)的進(jìn)度標(biāo)識(shí)位，并為所述進(jìn)度標(biāo)識(shí)位分配相應(yīng)的默認(rèn)值；

在所述邏輯處理節(jié)點(diǎn)對(duì)應(yīng)的任一目標(biāo)子線程完成其對(duì)應(yīng)的業(yè)務(wù)邏輯處理之后，在所述默認(rèn)值的基礎(chǔ)上將所述進(jìn)度標(biāo)識(shí)位加一；

在所述進(jìn)度標(biāo)識(shí)位與所述數(shù)據(jù)塊的數(shù)量相等時(shí)，確定所述目標(biāo)子線程已完成對(duì)所述業(yè)務(wù)信息的業(yè)務(wù)邏輯處理。

5.根據(jù)權(quán)利要求1所述的一種工業(yè)互聯(lián)網(wǎng)的業(yè)務(wù)數(shù)據(jù)處理方法，其特征在于，執(zhí)行所述目標(biāo)子線程，以對(duì)所述業(yè)務(wù)信息對(duì)應(yīng)的若干數(shù)據(jù)塊進(jìn)行相應(yīng)的業(yè)務(wù)邏輯處理之后，所述方法還包括：

獲取所述目標(biāo)子線程的開(kāi)始執(zhí)行時(shí)間；

根據(jù)所述開(kāi)始執(zhí)行時(shí)間，確定所述目標(biāo)子線程的已執(zhí)行時(shí)長(zhǎng)，若所述已執(zhí)行時(shí)長(zhǎng)大于預(yù)設(shè)執(zhí)行時(shí)長(zhǎng)，則發(fā)送超時(shí)提示信息至流程引擎，以根據(jù)所述超時(shí)提示信息停用當(dāng)前正在執(zhí)行的所述目標(biāo)子線程。

6.根據(jù)權(quán)利要求1所述的一種工業(yè)互聯(lián)網(wǎng)的業(yè)務(wù)數(shù)據(jù)處理方法，其特征在于，獲取工業(yè)設(shè)備上傳的業(yè)務(wù)信息之前，所述方法還包括：

在所述業(yè)務(wù)信息對(duì)應(yīng)的處理任務(wù)為非實(shí)時(shí)任務(wù)的情況下，確定所述業(yè)務(wù)信息對(duì)應(yīng)的任務(wù)優(yōu)先級(jí)；

按照所述任務(wù)優(yōu)先級(jí)的順序，將所述業(yè)務(wù)信息添加至對(duì)應(yīng)的任務(wù)隊(duì)列中，并生成所述業(yè)務(wù)信息對(duì)應(yīng)的優(yōu)先級(jí)標(biāo)識(shí)，以根據(jù)所述優(yōu)先級(jí)標(biāo)識(shí)，在預(yù)設(shè)處理時(shí)間時(shí)按照所述任務(wù)優(yōu)先級(jí)，從所述任務(wù)隊(duì)列中獲取待處理的業(yè)務(wù)信息。