[發(fā)明專利]千萬級物聯(lián)網(wǎng)場景的數(shù)據(jù)采集及弱推送方法

有效

• 申請?zhí)枺?/td>: 201710556722.9
• 申請日: 2017-07-10
• 公開（公告）號: CN107302582B
• 公開（公告）日: 2021-03-09
• 發(fā)明（設(shè)計(jì)）人: 陳光科;陳俊洪;曾碧
• 申請（專利權(quán)）人: 廣東工業(yè)大學(xué)
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L29/06;H04L1/16;H04L1/18
• 代理公司: 廣東廣信君達(dá)律師事務(wù)所 44329
• 代理人: 楊曉松

1.一種千萬級物聯(lián)網(wǎng)場景的數(shù)據(jù)采集及弱推送方法，其特征在于：

通過獲取接入服務(wù)器的步驟來實(shí)現(xiàn)登錄驗(yàn)證、負(fù)載均衡功能；UDP服務(wù)器對接收到的數(shù)據(jù)包采用批量驗(yàn)證的方式，降低數(shù)據(jù)庫連接池獲取頻率，減少鎖競爭；服務(wù)器端維護(hù)一個(gè)LRU算法的列表用于緩存udp地址，若有消息需要推送，則查找地址并發(fā)送，若不存在，則把消息保存在nosql數(shù)據(jù)庫中，當(dāng)節(jié)點(diǎn)定時(shí)上報(bào)時(shí)，立刻讀出消息推送給節(jié)點(diǎn)；每個(gè)上報(bào)的數(shù)據(jù)包都帶有序號，當(dāng)序號不是遞增1時(shí)，則推送確認(rèn)重傳報(bào)文，節(jié)點(diǎn)收到后從確認(rèn)序號開始重傳；節(jié)點(diǎn)處理完消息后，處理結(jié)果通過http上報(bào)至服務(wù)器；

通過節(jié)點(diǎn)udp定時(shí)上報(bào)與服務(wù)器維護(hù)LRU列表來獲取有效地址，從而實(shí)現(xiàn)弱推送功能。

2.根據(jù)權(quán)利要求1所述的數(shù)據(jù)采集及弱推送方法，其特征在于：通過登錄服務(wù)器與etcd服務(wù)發(fā)現(xiàn)來實(shí)現(xiàn)負(fù)載均衡。

3.根據(jù)權(quán)利要求1所述的數(shù)據(jù)采集及弱推送方法，其特征在于：UDP服務(wù)器，使用本地緩存，對接收的數(shù)據(jù)包采用批量驗(yàn)證處理的方式。

4.根據(jù)權(quán)利要求1所述的數(shù)據(jù)采集及弱推送方法，其特征在于：節(jié)點(diǎn)處理結(jié)果上報(bào)http服務(wù)器，http服務(wù)器通過消息隊(duì)列，從消息路由服務(wù)器獲取發(fā)送序號并緩存在本地，接收到節(jié)點(diǎn)的結(jié)果后，驗(yàn)證并檢查序號后把結(jié)果發(fā)送到消息路由服務(wù)器。

5.根據(jù)權(quán)利要求1所述的數(shù)據(jù)采集及弱推送方法，其特征在于：消息路由服務(wù)器，包含兩個(gè)方式：其一，訂閱移動端服務(wù)器、web管理系統(tǒng)服務(wù)器、第三方應(yīng)用推送命令，生成格式化消息后保存在記錄數(shù)據(jù)庫，并發(fā)送到消息隊(duì)列供UDP服務(wù)器與上報(bào)HTTP服務(wù)器使用；其二，訂閱上報(bào)HTTP服務(wù)器的結(jié)果，更新記錄數(shù)據(jù)庫，生成結(jié)果列表返回給用戶端，并根據(jù)具體需求重傳推送。