[發(fā)明專利]一種消息分配部件、消息處理系統(tǒng)以及消息分配方法在審
| 申請?zhí)枺?/td> | 201810214894.2 | 申請日： | 2018-03-15 |
| 公開（公告）號： | CN108459917A | 公開（公告）日： | 2018-08-28 |
| 發(fā)明（設(shè)計）人： | 何沖 | 申請（專利權(quán)）人： | 歐普照明股份有限公司 |
| 主分類號： | G06F9/54 | 分類號： | G06F9/54;H04L29/08 |
| 代理公司： | 北京智匯東方知識產(chǎn)權(quán)代理事務所(普通合伙) 11391 | 代理人： | 康正德;盛惠華 |
| 地址： | 201203 上海市浦*** | 國省代碼： | 上海;31 |
| 權(quán)利要求書： | 查看更多 | 說明書： | 查看更多 |
| 摘要： | |||
| 搜索關(guān)鍵詞： | 消息分配 設(shè)備標識 消息存儲 隊列 處理線程 多條消息 智能設(shè)備 消息處理系統(tǒng) 消息接收器 分配 線程處理器 消息分發(fā)器 順序處理 消息攜帶 并發(fā) 上報 攜帶 保證 | ||
1.一種消息分配部件，其特征在于，所述消息分配部件與一個或多個智能設(shè)備建立連接，對所述一個或多個智能設(shè)備上報的消息進行分配處理，所述消息分配部件具體包括：消息接收器、消息分發(fā)器、一個或多個消息存儲隊列以及消息線程處理器；
所述消息接收器，用于接收所述一個或多個智能設(shè)備上報的多條消息；
所述消息分發(fā)器，與所述消息接收器連接，用于根據(jù)所述多條消息各自攜帶的智能設(shè)備的設(shè)備標識，將所述多條消息分配到所述一個或多個消息存儲隊列中，其中，具有相同的設(shè)備標識的消息被分配到同一個消息存儲隊列；
所述消息線程處理器，與所述一個或多個消息存儲隊列連接，用于讀取各個消息存儲隊列中的消息，并將各個消息存儲隊列中的消息，按照消息攜帶的設(shè)備標識分配到一個或多個處理線程中，其中，具有相同的設(shè)備標識的消息被分配到同一個處理線程。
2.根據(jù)權(quán)利要求1所述的消息分配部件，其特征在于，若所述多條消息各自攜帶時間信息，所述消息分發(fā)器還用于：
根據(jù)所述多條消息各自攜帶的智能設(shè)備的設(shè)備標識，將所述多條消息按照時間的先后順序分配到所述一個或多個消息存儲隊列中。
3.根據(jù)權(quán)利要求1所述的消息分配部件，其特征在于，若所述多條消息各自攜帶時間信息，所述消息線程處理器還用于：
將各個消息存儲隊列中的消息，按照消息攜帶的設(shè)備標識和消息的時間先后順序分配到一個或多個處理線程中。
4.根據(jù)權(quán)利要求1所述的消息分配部件，其特征在于，所述消息分發(fā)器還用于：
對所述多條消息中每一條消息所攜帶的智能設(shè)備的設(shè)備標識進行哈希hash運算，隨后根據(jù)hash運算結(jié)果，將該條信息存入與hash運算結(jié)果對應的消息存儲隊列中。
5.根據(jù)權(quán)利要求1所述的消息分配部件，其特征在于，所述消息線程處理器還用于：
對各個消息存儲隊列中的每一條消息所攜帶的設(shè)備標識進行哈希hash運算，隨后根據(jù)hash運算結(jié)果，將該條信息分發(fā)到與hash運算結(jié)果對應的處理線程中。
6.根據(jù)權(quán)利要求1所述的消息分配部件，其特征在于，所述消息接收器包括：
通信模塊，用于與所述一個或多個智能設(shè)備建立連接；
所述消息接收器通過所述通信模塊接收所述一個或多個智能設(shè)備上報的多條消息。
7.根據(jù)權(quán)利要求1所述的消息分配部件，其特征在于，所述消息接收器的數(shù)量包括多個。
8.根據(jù)權(quán)利要求1所述的消息分配部件，其特征在于，所述消息線程處理器的數(shù)量包括多個，其中，一個消息線程處理器與一個消息存儲隊列連接，該消息線程處理器讀取與其連接的消息存儲隊列中的消息。
9.根據(jù)權(quán)利要求1所述的消息分配部件，其特征在于，所述消息線程處理器還用于：
根據(jù)當前處理線程的負載情況，確定是否新增一個或多個新的處理線程。
10.一種消息處理系統(tǒng)，其特征在于，包括權(quán)利要求1-9中任一項所述的消息分配部件，以及與所述消息分配部件連接的智能設(shè)備數(shù)據(jù)庫組件；
所述消息分配部件將一個或多個智能設(shè)備上報的消息分配到一個或多個處理線程，由所述一個或多個處理線程調(diào)用所述智能設(shè)備數(shù)據(jù)庫組件來對消息進行處理。
11.一種消息分配方法，其特征在于，應用于對一個或多個智能設(shè)備上報的消息進行分配處理的情況，所述方法包括：
接收所述一個或多個智能設(shè)備上報的多條消息；
根據(jù)所述多條消息各自攜帶的智能設(shè)備的設(shè)備標識，將所述多條消息分配到一個或多個消息存儲隊列中，其中，具有相同的設(shè)備標識的消息被分配到同一個消息存儲隊列；
讀取各個消息存儲隊列中的消息，并將各個消息存儲隊列中的消息，按照消息攜帶的設(shè)備標識分配到一個或多個處理線程中，其中，具有相同的設(shè)備標識的消息被分配到同一個處理線程。
該專利技術(shù)資料僅供研究查看技術(shù)是否侵權(quán)等信息，商用須獲得專利權(quán)人授權(quán)。該專利全部權(quán)利屬于歐普照明股份有限公司，未經(jīng)歐普照明股份有限公司許可，擅自商用是侵權(quán)行為。如果您想購買此專利、獲得商業(yè)授權(quán)和技術(shù)合作，請聯(lián)系【客服】
本文鏈接：http://www.szxzyx.cn/pat/books/201810214894.2/1.html，轉(zhuǎn)載請聲明來源鉆瓜專利網(wǎng)。
