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

有效

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

1.一種物聯網平臺HTTP信息推送方法，其特征在于，包括步驟：

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

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

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

2.根據權利要求1所述的物聯網平臺HTTP信息推送方法，其特征在于，所述信息推送方法還包括步驟：

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

3.根據權利要求1所述的物聯網平臺HTTP信息推送方法，其特征在于，所述根據所述URL地址當前的推送速率和推送時延將所述設備上報信息分配到預設的時延推送隊列，包括：

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

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

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

4.根據權利要求3所述的物聯網平臺HTTP信息推送方法，其特征在于，所述推送隊列總量的計算公式如下：

其中，n表示推送隊列類型的推送隊列總量，v表示當前的推送速率，M1表示單個隊列每個URL的最大推送速率，T1表示時延推送隊列類型當前的實例總數。

5.根據權利要求4所述的物聯網平臺HTTP信息推送方法，其特征在于，所述計算出所述推送隊列總量中可供選擇的推送隊列實例列表，包括步驟：

計算可選擇的第一個隊列實例編號q1＝(Hash(URL)mode T1)+1；

從q1開始，按照隊列實例編號依次往后取n-1個隊列；若實例編號T1，從實例編號1號開始循環選擇。

6.根據權利要求1所述的物聯網平臺HTTP信息推送方法，其特征在于，所述采用分布式流計算引擎Flink將所述預設的推送隊列的解析信息通過異步HTTP Post和多線程方式推送給所述URL地址，包括步驟：

基于Flink ProcessFunction組件，創建HTTP推送線程池和阻塞隊列；

將所述解析信息存入所述阻塞隊列；若阻塞隊列已滿，阻塞等待；

從所述HTTP推送線程池中獲取一個線程，采用異步HTTP Post的方式推送所述解析信息。

7.根據權利要求6所述的物聯網平臺HTTP信息推送方法，其特征在于，所述信息推送方法還包括：

通過異步HTTP回調函數，從所述阻塞隊列中移除所述解析消息，并將推送結果記錄到推送結果列表中；所述推送結果包括推送速率和推送時延；

采用Flink timerService，以預設的第二時間間隔觸發的方式，將結果列表中的推送結果發送到推送指標統計模塊；

按URL維度，采用Flink滾動窗口的方式統計推送速率和推送時延，并將統計結果寫入分布式緩存。