[發明專利]一種消息分配部件、消息處理系統以及消息分配方法

在審

• 申請號: 201810214894.2
• 申請日: 2018-03-15
• 公開（公告）號: CN108459917A
• 公開（公告）日: 2018-08-28
• 發明（設計）人: 何沖
• 申請（專利權）人: 歐普照明股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;H04L29/08
• 代理公司: 北京智匯東方知識產權代理事務所(普通合伙) 11391
• 代理人: 康正德;盛惠華

本發明提供了一種消息分配部件、消息處理系統以及消息分配方法，該消息分配部件包括：消息接收器，用于接收一個或多個智能設備上報的多條消息；消息分發器，與消息接收器連接，用于根據多條消息各自攜帶的智能設備的設備標識，將多條消息分配到一個或多個消息存儲隊列中，其中，具有相同的設備標識的消息被分配到同一個消息存儲隊列；消息線程處理器，與一個或多個消息存儲隊列連接，用于將各個消息存儲隊列中的消息，按照消息攜帶的設備標識分配到一個或多個處理線程中，其中，具有相同的設備標識的消息被分配到同一個處理線程。本發明提供的消息分配部件使得任何一個智能設備產生的消息有唯一的處理線程去處理，保證消息的高并發和順序處理。

技術領域

本發明涉及通信技術領域，特別是一種消息分配部件、消息處理系統、消息分配方法以及消息處理方法。

背景技術

隨著物聯網、云計算的快速發展，智能設備(如智能照明設備、智能攝像機等)出現了爆發式的增長，智能設備的節點越來越多，這些設備每時每刻都會產生海量的數據，如何采集和處理智能設備上報的數據也越來越受到廠商的重視，但是如何能保證高并發和有序地處理這些海量數據，成為一個迫切需要解決的問題。

發明內容

鑒于上述問題，提出了本發明以便提供一種克服上述問題或者至少部分地解決上述問題的消息分配部件、消息處理系統、消息分配方法以及消息處理方法，能夠實現消息數據的高并發分配處理，同時能夠保證消息的順序處理。

本發明實施例提供了一種消息分配部件，所述消息分配部件與一個或多個智能設備建立連接，對所述一個或多個智能設備上報的消息進行分配處理，所述消息分配部件具體包括：消息接收器、消息分發器、一個或多個消息存儲隊列以及消息線程處理器；

所述消息接收器，用于接收所述一個或多個智能設備上報的多條消息；

所述消息分發器，與所述消息接收器連接，用于根據所述多條消息各自攜帶的智能設備的設備標識，將所述多條消息分配到所述一個或多個消息存儲隊列中，其中，具有相同的設備標識的消息被分配到同一個消息存儲隊列；

所述消息線程處理器，與所述一個或多個消息存儲隊列連接，用于讀取各個消息存儲隊列中的消息，并將各個消息存儲隊列中的消息，按照消息攜帶的設備標識分配到一個或多個處理線程中，其中，具有相同的設備標識的消息被分配到同一個處理線程。

可選地，若所述多條消息各自攜帶時間信息，所述消息分發器還用于：

根據所述多條消息各自攜帶的智能設備的設備標識，將所述多條消息按照時間的先后順序分配到一個或多個消息存儲隊列中。

可選地，若所述多條消息各自攜帶時間信息，所述消息線程處理器還用于：

將各個消息存儲隊列中的消息，按照消息攜帶的設備標識和消息的時間先后順序分配到一個或多個處理線程中。

可選地，所述消息分發器還用于：

對所述多條消息中每一條消息所攜帶的智能設備的設備標識進行哈希hash運算，隨后根據hash運算結果，將該條信息存入與hash運算結果對應的消息存儲隊列中。

可選地，所述消息線程處理器還用于：

對各個消息存儲隊列中的每一條消息所攜帶的設備標識進行哈希hash運算，隨后根據hash運算結果，將該條信息分發到與hash運算結果對應的處理線程中。

可選地，所述消息接收器包括：

通信模塊，用于與所述一個或多個智能設備建立連接；

所述消息接收器通過所述通信模塊接收所述一個或多個智能設備上報的多條消息。

可選地，所述消息接收器的數量包括多個。