[發明專利]物聯網平臺HTTP信息推送方法、系統、裝置及介質

有效

• 申請號: 202110581242.4
• 申請日: 2021-05-27
• 公開（公告）號: CN113422808B
• 公開（公告）日: 2022-06-17
• 發明（設計）人: 賁興龍;王世杰;丁霞;張婕
• 申請（專利權）人: 天翼物聯科技有限公司
• 主分類號: H04L67/02
• 分類號: H04L67/02;H04L67/55;G16Y30/00
• 代理公司: 廣州嘉權專利商標事務所有限公司 44205
• 代理人: 常柯陽

本發明公開了一種物聯網平臺HTTP信息推送方法、系統、裝置及介質，該方法包括從消息隊列中獲取設備上報信息，并對設備上報信息進行解析得到解析信息；根據解析信息與推送規則進行匹配計算所述設備上報信息需要推送的URL地址，并根據URL地址當前的推送速率和推送時延將設備上報信息分配到預設的時延推送隊列；時延推送隊列為分布式且可根據推送量按需擴展；采用分布式流計算引擎Flink將推送隊列的解析信息通過異步HTTPPost和多線程方式推送給URL地址。本發明實施可以在海量物聯網設備接入狀況下，高效利用資源，給用戶提供差異化的消息推送服務，實現實時推送信息，可廣泛應用于物聯網技術領域。

技術領域

本發明涉及物聯網技術領域，尤其涉及一種物聯網平臺HTTP信息推送方法、系統、裝置及介質。

背景技術

物聯網平臺是為物聯網應用開發者提供快速開發、部署以及應用管理的平臺，開發者無需考慮下層基礎設施擴展、數據管理和歸集、通信協議、通信安全等問題，降低了開發成本、大大縮短了開發時間。物聯網平臺具備終端接入、終端管理、消息推送等通用基礎能力。物聯網終端接入物聯網平臺后，由消息推送模塊根據消息訂閱規則，將終端上報的消息推送給物聯網應用。

HTTP消息推送由于具有標準傳輸協議、支持各種主要開發語言等優點，是物聯網平臺主流的消息推送方式。現有的HTTP消息推送方法，設備消息上報到物聯網平臺后，首先存儲到一個統一的消息隊列，推送程序從隊列獲取消息后，按照訂閱規則直接進行推送。沒有充分考慮到在海量消息推送環境下，各類用戶的推送請求交織在一起，網絡或接收端異常造成的消息推送緩慢，導致其它正常用戶消息在隊列中排隊等待，無法實時推送；或者為了避免各用戶接收端之間相互影響，給不同用戶啟用獨立的推送服務，又會造成資源占用過多，資源無法有效利用等問題。

發明內容

有鑒于此，本發明實施例的目的是提供一種物聯網平臺HTTP信息推送方法、系統、裝置及介質，該方法可以在海量物聯網設備接入狀況下，高效利用資源，給用戶提供差異化的消息推送服務，實現實時推送信息。

第一方面，本發明實施例提供了一種物聯網平臺HTTP信息推送方法，包括步驟：

從消息隊列中獲取設備上報信息，并對所述設備上報信息進行解析得到解析信息；其中，所述解析信息包括用戶ID、設備ID、消息類型、上報時間及消息payload；

根據所述解析信息與推送規則進行匹配計算所述設備上報信息需要推送的URL地址，并根據所述URL地址當前的推送速率和推送時延將所述設備上報信息分配到預設的時延推送隊列；所述時延推送隊列為分布式且可根據推送量按需擴展；

采用分布式流計算引擎Flink將所述推送隊列的解析信息通過異步HTTP Post和多線程方式推送給所述URL地址。

可選地，所述信息推送方法還包括步驟：

當所述設備上報信息的上報時間與當前時間之間的間隔超過預設的第一時間間隔，將所述設備上報信息分配給預設的異常推送隊列。

可選地，所述根據所述URL地址當前的推送速率和推送時延將所述設備上報信息分配到預設的時延推送隊列，包括：

根據所述URL地址當前的推送時延選擇匹配當前的推送時延的時延推送隊列類型；

根據所述URL地址當前的推送速率計算所述設備上報信息可以匹配的所述時延推送隊列類型的推送隊列總量，并計算出所述推送隊列總量中可供選擇的推送隊列實例列表；

從所述可供選擇的推送隊列實例列表中隨機選擇一個推送隊列。

可選地，所述推送隊列總量的計算公式如下：