[發明專利]一種工業互聯網的業務數據處理方法、設備及介質

在審

• 申請號: 202210180085.0
• 申請日: 2022-02-25
• 公開（公告）號: CN114579303A
• 公開（公告）日: 2022-06-03
• 發明（設計）人: 倪志榮;于靜;宋凱月;商廣勇;季伶美
• 申請（專利權）人: 山東浪潮工業互聯網產業股份有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06F16/25;G06F16/27;G16Y10/25
• 代理公司: 北京君慧知識產權代理事務所(普通合伙) 11716
• 代理人: 董延麗

本申請公開了一種工業互聯網的業務數據處理方法、設備及介質，用以解決現有的數據處理方法在數據量過大時處理性能較低的技術問題。方法包括：獲取工業設備上傳的業務信息，并通過IP協議棧對所述業務信息進行分片，得到分片后的若干數據塊；根據預設的流程引擎，確定業務信息對應的多個邏輯處理節點，以及由多個邏輯處理節點組成的主處理流程；根據數據塊的數量，確定當前需調用的子線程數量；按照主處理流程包含的各邏輯處理節點之間的流轉邏輯，依次從各邏輯處理節點對應的線程池中，調用與線程數量對應的多個目標子線；執行目標子線程，以對業務信息對應的若干數據塊進行相應的業務邏輯處理。

技術領域

本申請涉及大數據技術領域，具體涉及一種工業互聯網的業務數據處理方法、設備及介質。

背景技術

隨著大數據技術的不斷發展，越來越多的工廠也相繼進行了智能化改造。但是隨著智能化程度的不斷加深，以及智能聯網設備數量的不斷增多，智能監控、智能生產等應用平臺所面臨的數據處理壓力也隨之增大，易導致數據處理過程中發生阻塞，降低數據處理效率，嚴重時還會引起系統宕機等問題，對工業生產帶來不便。

發明內容

為了解決上述問題，本申請提出了一種工業互聯網的業務數據處理方法，包括：獲取工業設備上傳的業務信息，并通過IP協議棧對業務信息進行分片，得到分片后的若干數據塊；

根據預設的流程引擎，確定業務信息對應的多個邏輯處理節點，以及由多個邏輯處理節點組成的主處理流程；其中，各邏輯處理節點分別對應不同的線程池，線程池由多個子線程組成，線程池包括業務邏輯線程池、網絡連接線程池和數據庫連接線程池；

根據數據塊的數量，確定當前需調用的子線程數量；

按照主處理流程包含的各邏輯處理節點之間的流轉邏輯，依次從各邏輯處理節點對應的線程池中，調用與線程數量對應的多個目標子線程；

執行目標子線程，以對業務信息對應的若干數據塊進行相應的業務邏輯處理。

在本申請的一種實現方式中，確定業務信息對應的多個邏輯處理節點之后，方法還包括：

針對各邏輯處理節點，建立該邏輯處理節點對應的主線程；

將主線程與其對應的邏輯處理節點所包含的多個子線程依次進行綁定，以生成相應的映射關系。

在本申請的一種實現方式中，按照主處理流程包含的各邏輯處理節點之間的流轉邏輯，依次從各邏輯處理節點對應的線程池中，確定與線程數量對應的多個目標子線程，具體包括：

確定業務邏輯線程池對應的第一主線程，根據第一主線程對應的映射關系，將業務信息對應的數據塊分配至業務邏輯線程池中的多個第一目標子線程；

在多個第一目標子線程均完成其對應的業務邏輯處理后，通過第一主線程，將多個第一目標子線程的第一數據處理結果流轉至網絡連接線程池對應的第二主線程，并根據第二主線程對應的映射關系，將多個第一目標子線程的數據處理結果，分配至網絡連接線程池中的多個第二目標子線程；

在多個第二目標子線程均完成其對應的業務邏輯處理后，通過第二主線程，將多個第二目標子線程的第二數據處理結果流轉至數據庫連接線程池對應的第三主線程，并根據第三主線程對應的映射關系，將多個第二目標子線程的數據處理結果，分配至數據庫連接線程池中的多個第三目標子線程；

其中，第一目標子線程、第二目標子線程和第三目標子線程的數量與線程數量相對應，且至少分別對應一個數據塊。

在本申請的一種實現方式中，確定與線程數量對應的多個目標子線程之后，方法還包括：

針對邏輯處理節點，生成業務信息對應的進度標識位，并為進度標識位分配相應的默認值；

在邏輯處理節點對應的任一目標子線程完成其對應的業務邏輯處理之后，在默認值的基礎上將進度標識位加一；