[發明專利]設備信息的處理方法、裝置、存儲介質及處理器

有效

• 申請號: 201911420021.8
• 申請日: 2019-12-31
• 公開（公告）號: CN111131512B
• 公開（公告）日: 2023-02-10
• 發明（設計）人: 宋佳城;陳建偉;呂恒;羅杰;安小建
• 申請（專利權）人: 中消云（北京）物聯網科技研究院有限公司
• 主分類號: H04L69/16
• 分類號: H04L69/16;H04L47/50
• 代理公司: 北京康信知識產權代理有限責任公司 11240
• 代理人: 董文倩

本發明公開了一種設備信息的處理方法、裝置、存儲介質及處理器。其中，該方法包括：接收到多個并發的接入設備上傳的設備信息；采用雙隊列業務架構對所述多個設備信息進行保存，其中，所述雙隊列業務架構由異步的第一消息隊列和第二消息隊列構成，所述第一消息隊列易擴容且臨時存儲所述多個設備信息，所述第二消息隊列的存儲模式使得同一個設備消息允許多個訂閱者并行訂閱。本發明解決了目前的云端數據處理方案無法及時處理設備信息造成的平臺處理效率低的技術問題。

技術領域

本發明涉及信息處理領域，具體而言，涉及一種設備信息的處理方法、裝置、存儲介質及處理器。

背景技術

現有技術中在大量設備接入云端后，原來的業務流程是平臺接收到設備信息后通過緩存或數據庫進行信息處理、并根據處理后的設備信息判斷進行后期業務推送處理。由于上述方式無法滿足接入設備數量的極速增長，即服務器已經無法及時處理設備信息，導致平臺處理效率低的技術問題。

針對上述的問題，目前尚未提出有效的解決方案。

發明內容

本發明實施例提供了一種設備信息的處理方法、裝置、存儲介質及處理器，以至少解決目前的云端數據處理方案無法及時處理設備信息造成的平臺處理效率低的技術問題。

根據本發明實施例的一個方面，提供了一種設備信息的處理方法，包括：接收到并發的接入設備上傳的多個設備信息；基于雙隊列業務架構對多個設備信息進行處理，其中，雙隊列業務架構由異步的第一消息隊列和第二消息隊列構成，第一消息隊列支持擴容且臨時存儲多個設備信息，第二消息隊列的存儲模式使得同一個設備消息允許多個訂閱者并行訂閱。

可選地，采用雙隊列業務架構對多個并發的接入設備的設備信息進行保存，包括：將多個接入設備上傳的設備信息臨時存儲至第一消息隊列；通過解析程序對臨時存儲的設備信息進行解析，得到解析信息；將解析信息存儲至第二消息隊列。

可選地，將解析信息存儲至第二消息隊列之后，方法還包括：接收到多個業務需求指令；基于多個業務需求指令，從第二消息隊列中訂閱同一條消息或不同消息，其中，消息中攜帶了待處理的設備信息；對訂閱到的設備信息進行業務處理。

可選地，在將多個接入設備上傳的設備信息臨時存儲至第一消息隊列之后，方法還包括：檢測第一消息隊列的運行情況；如果第一消息隊列的運行情況為滿負荷或處于等待處理狀態的數據超過閾值，則對第一消息隊列進行擴容。

可選地，在得到解析信息之后，方法還包括：根據解析信息確定雙隊列業務架構的隊列運行情況；基于雙隊列業務架構的隊列運行情況，調整雙隊列業務架構的隊列容量。

可選地，第一消息隊列為如下消息隊列之一：rabbit隊列、ActiveMQ隊列、ZeroMQ隊列和rocketMQ隊列；第二消息隊列為如下消息隊列之一：kafka隊列、多個組合的rabbit隊列。

根據本發明實施例的另一方面，還提供了一種設備信息的處理方法，包括：接收到并發的接入設備上傳的多個設備信息；將多個設備信息保存至消息隊列，其中，消息隊列的存儲模式使得同一個設備消息允許多個訂閱者并行訂閱，消息隊列為如下消息隊列之一：kafka隊列、多個組合的rabbit隊列。

根據本發明實施例的另一方面，還提供了一種設備信息的處理裝置，包括：第一接收模塊，用于接收到并發的接入設備上傳的多個設備信息；保存模塊，用于采用雙隊列業務架構對多個設備信息進行保存，其中，雙隊列業務架構由異步的第一消息隊列和第二消息隊列構成，第一消息隊列支持擴容且臨時存儲多個設備信息，第二消息隊列的存儲模式使得同一個設備消息允許多個訂閱者并行訂閱。

可選地，保存模塊包括：第一存儲模塊，用于將多個接入設備上傳的設備信息臨時存儲至第一消息隊列；解析模塊，用于通過解析程序對臨時存儲的設備信息進行解析，得到解析信息；第二存儲模塊，用于將解析信息存儲至第二消息隊列。