[發明專利]一種傳感器接收系統及其接收方法

有效

• 申請號: 202011489311.0
• 申請日: 2020-12-16
• 公開（公告）號: CN113162962B
• 公開（公告）日: 2023-04-18
• 發明（設計）人: 葉志暉;王文娟;錢杰;張成挺;丁男哲
• 申請（專利權）人: 浙江中煙工業有限責任公司
• 主分類號: H04L67/125
• 分類號: H04L67/125;H04L67/1042;H04L67/02;H04L69/16;H04L47/80
• 代理公司: 南京縱橫知識產權代理有限公司 32224
• 代理人: 許婉靜

1.一種傳感器接收方法，其特征在于，包括以下步驟：

從數據庫中提取預先設置的各傳感器的接入參數，所述接入參數包括連接協議、傳感器的基本參數、數據的優先級和解析協議；

根據所述連接協議，接收傳感數據，并對接收到的傳感數據按照解析協議進行預處理；

實時獲取等待處理的傳感器數據的數據量以及計算集群使用情況；

根據等待處理的傳感器數據的數據量，判斷是否進行緩存處理；若所述數據量超過預設值時，則對超出預設值的傳感數據進行緩存；啟動緩沖操作后，根據數據到達的時間順序進行緩存，避免傳感數據的丟失，數據處理任務需要數據時，從暫存區中取出隊列頭部數據，進行數據處理，當在一個設定的時間間隔內，暫存區內總數據量均少于暫存區存儲量的50%時，結束對數據的緩存；

根據計算集群使用情況以及數據的優先級對傳感數據進行分配，包括以下步驟：為所述數據的優先級對應資源權重，在計算資源不夠時，為高優先級任務優先獲取剩余計算資源；若高優先級任務數量超過剩余計算資源時，暫停低優先級任務，然后重新根據資源權重對數據處理任務進行分配。

2.根據權利要求1所述傳感器接收方法，其特征在于：所述連接協議為TCP或UDP。

3.根據權利要求1所述傳感器接收方法，其特征在于：所述傳感器的基本參數包括傳感器的唯一命名、傳輸方式、數據類別、數據優先級。

4.根據權利要求1所述傳感器接收方法，其特征在于：所述對傳感數據進行緩存根據數據到達的時間順序進行緩存。

5.根據權利要求1所述傳感器接收方法，其特征在于：所述計算集群使用情況包括CPU、內存和IO的使用情況。

6.一種傳感器接收系統，其特征在于：包括交互接口、連接模塊、解析模塊和傳感數據分配模塊，所述交互接口用于設置各傳感器的接入參數；所述連接模塊用于按照預設的連接協議與傳感器建立連接，并接收傳感數據；所述解析模塊用于將連接模塊接收到的傳感數據轉化為內部數據格式；所述傳感數據分配模塊用于將解析過的傳感數據分配至集群的各計算機；所述傳感數據分配模塊包括數據處理任務監聽模塊、緩存模塊和資源匹配模塊；所述數據處理任務監聽模塊用于實時獲取等待處理的傳感數據的數據量以及計算集群使用情況；緩存模塊用于對超過預設值的傳感數據進行存儲；啟動緩沖操作后，根據數據到達的時間順序進行緩存，避免傳感數據的丟失，數據處理任務需要數據時，從暫存區中取出隊列頭部數據，進行數據處理，當在一個設定的時間間隔內，暫存區內總數據量均少于暫存區存儲量的50%時，結束對數據的緩存；所述資源匹配模塊用于根據計算集群使用情況以及數據的優先級對傳感數據進行分配，包括以下步驟：為所述數據的優先級對應資源權重，在計算資源不夠時，為高優先級任務優先獲取剩余計算資源；

若高優先級任務數量超過剩余計算資源時，暫停低優先級任務，然后重新根據資源權重對數據處理任務進行分配。

7.根據權利要求書6所述傳感器接收系統，其特征在于：所述緩存模塊為內存暫存區。

8.根據權利要求書6所述傳感器接收系統，其特征在于：所述交互接口包括交互界面，API或Web服務接口。

9.根據權利要求書6所述傳感器接收系統，其特征在于：所述傳感器接入系統還包括轉發模塊、控制指令模塊和協議倉庫；所述轉發模塊用于根據數據類別，將連接模塊接收到的數據轉發至其他模塊；所述控制指令模塊用于接收CPS系統的操作指令并將所述操作指令轉發至傳感器；所述協議倉庫用于存儲交互接口設置的傳感器的接入參數。