[發明專利]一種物聯網消息服務方法及服務器

有效

• 申請號: 202010140450.6
• 申請日: 2020-03-03
• 公開（公告）號: CN111427700B
• 公開（公告）日: 2023-05-05
• 發明（設計）人: 李旭濱;楊興云;李少華
• 申請（專利權）人: 云知聲智能科技股份有限公司;廈門云知芯智能科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F9/50
• 代理公司: 北京冠和權律師事務所 11399
• 代理人: 張楠楠

本發明公開了一種物聯網消息服務方法及服務器，方法包括：S1、接收基于應用服務生產的消息建立的消息隊列；S2、實時收集服務器的狀態指標信息；S3、根據所述狀態指標信息按照第一預設規則得到服務器的處理能力數據；S4、根據所述處理能力數據分配所述消息隊列的最大長度；S5、根據所述消息隊列的最大長度動態調整所述消息隊列的長度。有益效果：避免出現消息洪峰對服務器沖擊造成消息擁堵，導致服務器“假死”甚至宕機的問題。

技術領域

本發明涉及網絡信息技術領域，特別涉及一種物聯網消息服務方法及服務器。

背景技術

目前，物聯網技術的不斷提高，諸多業務領域產生海量、實時的數據。當前物聯網逐漸以連續、實時的流數據為主，大規模、多元、異構的數據的分析利用，是以數據能夠被接入為前提，于是面向物聯網大數據的播發技術成為技術趨勢，消息服務器應用而生。如圖1所示，現有技術中，消息服務器提供進程間的消息傳遞，接收應用服務生產的消息，再基于一定規則與算法，將消息分發至一個或多個目標應用服務、移動終端等。消息服務器的核心功能是消息的收發、消息回執上報。

現有技術中存在的問題：1、高并發下服務不可用，在服務器突然涌入大量的消息超出服務器的處理能力時，導致服務器“假死”甚至宕機；2、消息觸達的可靠行性差，對于一些重要又不能遺漏的信息，在發生網絡抖動、服務宕機、服務重啟的情況下，可能會導致消息的無法送達、消息回執上報失敗，造成消息丟失或消息的二次重發；還有一些消息有明確的消費順序，普通消息服務無法保證終端消費的有序性；3、消息存儲的不可靠，當存儲服務(比如文件存儲、redis、mysql等)不可用時，大量消息耗盡內置的消息隊列，會觸發消息的淘汰機制造成消息丟失。

發明內容

本發明旨在至少一定程度上解決上述技術中的技術問題之一。為此，本發明的第一個目的在于提出一種物聯網消息服務方法，避免出現消息洪峰對服務器沖擊造成消息擁堵，導致服務器“假死”甚至宕機的問題。

本發明的第二個目的在于提出一種服務器。

為達到上述目的，本發明第一方面實施例提出了一種物聯網消息服務方法，應用于服務器，包括：

S1、接收基于應用服務生產的消息建立的消息隊列；

S2、實時收集服務器的狀態指標信息；

S3、根據所述狀態指標信息按照第一預設規則得到服務器的處理能力數據；

S4、根據所述處理能力數據分配所述消息隊列的最大長度；

S5、根據所述消息隊列的最大長度動態調整所述消息隊列的長度。

根據本發明第一方面實施例提出的物聯網消息服務方法，接收基于應用服務生產的消息建立的消息隊列，可以對生產的消息進行統一有序的管理，提高對消息的管理效率。實時收集服務器的狀態指標信息，按照第一預設規則得到服務器的處理能力數據，根據所述處理能力數據分配所述消息隊列的最大長度，根據所述消息隊列的最大長度動態調整所述消息隊列的長度。動態調整消息隊列的長度，限制應用服務生產的消息的速度及數量，使服務器能及時有效的處理，避免消息洪峰對服務器沖擊造成消息擁堵，通過削峰防止瞬間流量過大造成服務器不可用，同時通過填谷把空閑資源分攤給其他服務以提升處理能力，讓服務器能高效的運行。

根據本發明的一些實施例，對動態調整后的消息隊列進行消息分發，包括：

S6、判斷消息接收端的在線狀態，在確定消息接收端不在線時，執行步驟S7；否則，執行步驟S8；

S7、將消息隊列作為離線消息進行存儲；

S8、構建消息頭部標簽，所述消息頭部標簽包括節點ID、消息優先級信息、消息類型、消息質量；

S9、根據所述消息頭部標簽按照第二預設規則得出消息發送渠道信息；