[發(fā)明專利]設(shè)備信息的處理方法、裝置、存儲(chǔ)介質(zhì)及處理器

有效

• 申請(qǐng)?zhí)枺?/td>: 201911420021.8
• 申請(qǐng)日: 2019-12-31
• 公開(kāi)（公告）號(hào): CN111131512B
• 公開(kāi)（公告）日: 2023-02-10
• 發(fā)明（設(shè)計(jì)）人: 宋佳城;陳建偉;呂恒;羅杰;安小建
• 申請(qǐng)（專利權(quán)）人: 中消云（北京）物聯(lián)網(wǎng)科技研究院有限公司
• 主分類號(hào): H04L69/16
• 分類號(hào): H04L69/16;H04L47/50
• 代理公司: 北京康信知識(shí)產(chǎn)權(quán)代理有限責(zé)任公司 11240
• 代理人: 董文倩

1.一種設(shè)備信息的處理方法，其特征在于，包括：

接收到并發(fā)的接入設(shè)備上傳的多個(gè)設(shè)備信息；

基于雙隊(duì)列業(yè)務(wù)架構(gòu)對(duì)所述多個(gè)設(shè)備信息進(jìn)行處理，其中，所述雙隊(duì)列業(yè)務(wù)架構(gòu)由異步的第一消息隊(duì)列和第二消息隊(duì)列構(gòu)成，所述第一消息隊(duì)列支持?jǐn)U容且臨時(shí)存儲(chǔ)所述多個(gè)設(shè)備信息，所述第二消息隊(duì)列的存儲(chǔ)模式使得同一個(gè)設(shè)備消息允許多個(gè)訂閱者并行訂閱；

其中，采用雙隊(duì)列業(yè)務(wù)架構(gòu)對(duì)所述多個(gè)并發(fā)的接入設(shè)備的設(shè)備信息進(jìn)行保存，包括：將所述多個(gè)接入設(shè)備上傳的設(shè)備信息臨時(shí)存儲(chǔ)至所述第一消息隊(duì)列；通過(guò)解析程序?qū)λ雠R時(shí)存儲(chǔ)的設(shè)備信息進(jìn)行解析，得到解析信息；將所述解析信息存儲(chǔ)至所述第二消息隊(duì)列；

在將所述解析信息存儲(chǔ)至所述第二消息隊(duì)列之后，所述方法還包括：接收到多個(gè)業(yè)務(wù)需求指令；基于所述多個(gè)業(yè)務(wù)需求指令，從所述第二消息隊(duì)列中訂閱同一條消息或不同消息，其中，所述消息中攜帶了待處理的設(shè)備信息；對(duì)訂閱到的設(shè)備信息進(jìn)行業(yè)務(wù)處理。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，在將所述多個(gè)接入設(shè)備上傳的設(shè)備信息臨時(shí)存儲(chǔ)至所述第一消息隊(duì)列之后，所述方法還包括：

檢測(cè)所述第一消息隊(duì)列的運(yùn)行情況；

如果所述第一消息隊(duì)列的運(yùn)行情況為滿負(fù)荷或處于等待處理狀態(tài)的數(shù)據(jù)超過(guò)閾值，則對(duì)所述第一消息隊(duì)列進(jìn)行擴(kuò)容。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，在得到解析信息之后，所述方法還包括：

根據(jù)所述解析信息確定所述雙隊(duì)列業(yè)務(wù)架構(gòu)的隊(duì)列運(yùn)行情況；

基于所述雙隊(duì)列業(yè)務(wù)架構(gòu)的隊(duì)列運(yùn)行情況，調(diào)整所述雙隊(duì)列業(yè)務(wù)架構(gòu)的隊(duì)列容量。

4.根據(jù)權(quán)利要求1至3中任意一項(xiàng)所述的方法，其特征在于，所述第一消息隊(duì)列為如下消息隊(duì)列之一：rabbit隊(duì)列、ActiveMQ隊(duì)列、ZeroMQ隊(duì)列和rocketMQ隊(duì)列；所述第二消息隊(duì)列為如下消息隊(duì)列之一：kafka隊(duì)列、多個(gè)組合的rabbit隊(duì)列。

5.一種設(shè)備信息的處理裝置，其特征在于，包括：

第一接收模塊，用于接收到并發(fā)的接入設(shè)備上傳的多個(gè)設(shè)備信息；

保存模塊，用于采用雙隊(duì)列業(yè)務(wù)架構(gòu)對(duì)所述多個(gè)設(shè)備信息進(jìn)行保存，其中，所述雙隊(duì)列業(yè)務(wù)架構(gòu)由異步的第一消息隊(duì)列和第二消息隊(duì)列構(gòu)成，所述第一消息隊(duì)列支持?jǐn)U容且臨時(shí)存儲(chǔ)所述多個(gè)設(shè)備信息，所述第二消息隊(duì)列的存儲(chǔ)模式使得同一個(gè)設(shè)備消息允許多個(gè)訂閱者并行訂閱；其中，所述保存模塊包括：第一存儲(chǔ)模塊，用于將所述多個(gè)接入設(shè)備上傳的設(shè)備信息臨時(shí)存儲(chǔ)至所述第一消息隊(duì)列；解析模塊，用于通過(guò)解析程序?qū)λ雠R時(shí)存儲(chǔ)的設(shè)備信息進(jìn)行解析，得到解析信息；第二存儲(chǔ)模塊，用于將所述解析信息存儲(chǔ)至所述第二消息隊(duì)列；

第二接收模塊，用于接收到多個(gè)業(yè)務(wù)需求指令；

訂閱模塊，用于基于所述多個(gè)業(yè)務(wù)需求指令，從所述第二消息隊(duì)列中訂閱同一條消息或不同消息，其中，所述消息中攜帶了待處理的設(shè)備信息；

處理模塊，用于對(duì)訂閱到的設(shè)備信息進(jìn)行業(yè)務(wù)處理。

6.根據(jù)權(quán)利要求5所述的裝置，其特征在于，所述裝置還包括：

檢測(cè)模塊，用于檢測(cè)所述第一消息隊(duì)列的運(yùn)行情況；

擴(kuò)容模塊，用于如果所述第一消息隊(duì)列的運(yùn)行情況為滿負(fù)荷或處于等待處理狀態(tài)的數(shù)據(jù)超過(guò)閾值，則對(duì)所述第一消息隊(duì)列進(jìn)行擴(kuò)容。

7.根據(jù)權(quán)利要求5所述的裝置，其特征在于，所述裝置還包括：

確定模塊，用于根據(jù)所述解析信息確定所述雙隊(duì)列業(yè)務(wù)架構(gòu)的隊(duì)列運(yùn)行情況；

調(diào)整模塊，用于基于所述雙隊(duì)列業(yè)務(wù)架構(gòu)的隊(duì)列運(yùn)行情況，調(diào)整所述雙隊(duì)列業(yè)務(wù)架構(gòu)的隊(duì)列容量。

8.一種非易失性存儲(chǔ)介質(zhì)，其特征在于，所述非易失性存儲(chǔ)介質(zhì)包括存儲(chǔ)的程序，其中，在所述程序運(yùn)行時(shí)控制所述非易失性存儲(chǔ)介質(zhì)所在設(shè)備執(zhí)行權(quán)利要求1至4中任意一項(xiàng)所述設(shè)備信息的處理方法。