[發(fā)明專利]一種邊緣設(shè)備的數(shù)據(jù)同步方法及系統(tǒng)

有效

• 申請?zhí)枺?/td>: 202110740881.0
• 申請日: 2021-07-01
• 公開（公告）號: CN113194156B
• 公開（公告）日: 2021-09-03
• 發(fā)明（設(shè)計）人: 謝飛;馮振飛
• 申請（專利權(quán)）人: 廣州得一物聯(lián)科技有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 廣州三環(huán)專利商標代理有限公司 44202
• 代理人: 郭浩輝;顏希文

本發(fā)明公開了一種邊緣設(shè)備的數(shù)據(jù)同步方法及系統(tǒng)，所述方法將待發(fā)送數(shù)據(jù)按QoS0的服務(wù)質(zhì)量發(fā)送至云服務(wù)器，云服務(wù)器生成數(shù)據(jù)同步狀態(tài)信息并更新數(shù)據(jù)同步狀態(tài)話題。從數(shù)據(jù)同步狀態(tài)話題中獲取數(shù)據(jù)同步狀態(tài)信息；若成功獲取數(shù)據(jù)同步狀態(tài)信息且判定待發(fā)送數(shù)據(jù)同步成功，則將發(fā)送窗口中的待發(fā)送數(shù)據(jù)移除，重新提取數(shù)據(jù)進行發(fā)送。若成功獲取數(shù)據(jù)同步狀態(tài)信息但判定待發(fā)送數(shù)據(jù)同步失敗，則對待發(fā)送數(shù)據(jù)進行重發(fā)并在重發(fā)次數(shù)或重發(fā)時長超過閾值時，將待發(fā)送數(shù)據(jù)從發(fā)送窗口中移除，重新提取數(shù)據(jù)進行發(fā)送。若不能獲取到同步狀態(tài)信息，則將當前窗口的待發(fā)送數(shù)據(jù)移除，重新提取新的待發(fā)送數(shù)據(jù)進行發(fā)送。通過實施本發(fā)明能夠提高數(shù)據(jù)同步效率及穩(wěn)定性。

技術(shù)領(lǐng)域

本發(fā)明涉及數(shù)據(jù)同步技術(shù)領(lǐng)域，尤其涉及一種邊緣設(shè)備的數(shù)據(jù)同步方法及系統(tǒng)。

背景技術(shù)

在現(xiàn)有物聯(lián)網(wǎng)場景中，各類終端持續(xù)向智能化的方向發(fā)展，海量數(shù)據(jù)在邊緣匯聚。云端物聯(lián)網(wǎng)服務(wù)平臺提供海量數(shù)據(jù)的存儲、分析與價值挖掘。邊緣與云的數(shù)據(jù)協(xié)同，形成完整的數(shù)據(jù)流轉(zhuǎn)路徑，保障高效、低成本地對物聯(lián)數(shù)據(jù)進行全生命周期管理與價值挖掘。而在現(xiàn)有的邊緣設(shè)備與云服務(wù)器的數(shù)據(jù)同步過程中，是直接在邊緣設(shè)備端實時調(diào)用MQTT客戶端，然后按照QoS 1或QoS 2的服務(wù)質(zhì)量發(fā)送設(shè)備數(shù)據(jù)消息到云服務(wù)端，該方法借助MQTT協(xié)議中的消息重發(fā)與確認機制，保障消息數(shù)據(jù)同步到云服務(wù)端。但是若按照QoS1的服務(wù)質(zhì)量進行邊緣設(shè)備與云服務(wù)之間的數(shù)據(jù)同步，QoS1的服務(wù)質(zhì)量為，消息將至少發(fā)送一次給接收者，那么在進行數(shù)據(jù)同步時，邊緣設(shè)備將PUBLISH消息發(fā)送給云服務(wù)器后，會等待云服務(wù)器反饋一個PUBACK應(yīng)答，如果在特定時間沒有接收到PUBACK應(yīng)答的話邊緣設(shè)備就會重新發(fā)送PUBLISH消息，這樣若由于網(wǎng)絡(luò)狀況不佳，邊緣設(shè)備一直沒有接收到PUBACK應(yīng)答的話就會一直發(fā)送重復(fù)的PUBLISH消息，這樣邊緣設(shè)備端就會積攢大量發(fā)送出去但得不到云服務(wù)器確認的消息，進而導(dǎo)致邊緣設(shè)備端的MQTT客戶端發(fā)生奔潰。若按照QoS2的服務(wù)質(zhì)量進行數(shù)據(jù)同步的話，QoS2的服務(wù)質(zhì)量會確保每個消息都只被接收到的一次，這樣在數(shù)據(jù)同步時，邊緣設(shè)備將PUBLISH消息發(fā)送給云服務(wù)器后，會等待云服務(wù)器反饋一個PUBACK應(yīng)答，然后邊緣設(shè)備在接收到PUBACK應(yīng)答，會向云服務(wù)器回復(fù)PUBREL，當云服務(wù)器收到PUBREL會回復(fù)PUBCOMP至邊緣設(shè)備，最終邊緣設(shè)備在接收PUBCOMP后，完成一次數(shù)據(jù)發(fā)送。采用這一方式，一同步數(shù)據(jù)的發(fā)送需要經(jīng)歷三次握手，若網(wǎng)絡(luò)狀況不佳，很容易出現(xiàn)數(shù)據(jù)擁塞，數(shù)據(jù)同步效率較低。

發(fā)明內(nèi)容

本發(fā)明實施例提供一種邊緣設(shè)備的數(shù)據(jù)同步方法及系統(tǒng)，能提高數(shù)據(jù)同步的效率以及穩(wěn)定性。

本發(fā)明一實施例提供了一種邊緣設(shè)備的數(shù)據(jù)同步方法，包括：

采集待同步數(shù)據(jù)并從所述待同步數(shù)據(jù)中提取當前需要發(fā)送的待發(fā)送數(shù)據(jù)，將所述待發(fā)送數(shù)據(jù)加入發(fā)送窗口中并按QoS0的服務(wù)質(zhì)量將所述發(fā)送窗口中的待發(fā)送數(shù)據(jù)發(fā)送至云服務(wù)器；

從訂閱的數(shù)據(jù)同步狀態(tài)話題中獲取所述待發(fā)送數(shù)據(jù)的數(shù)據(jù)同步狀態(tài)信息；其中，所述數(shù)據(jù)同步狀態(tài)話題由所述云服務(wù)器發(fā)布，且所述云服務(wù)器在接收所述待發(fā)送數(shù)據(jù)時，將所述待發(fā)送數(shù)據(jù)進行入庫，根據(jù)入庫情況生成所述待發(fā)送數(shù)據(jù)的數(shù)據(jù)同步狀態(tài)信息并根據(jù)所述數(shù)據(jù)同步狀態(tài)信息更新所述數(shù)據(jù)同步狀態(tài)話題；

在成功獲取所述數(shù)據(jù)同步狀態(tài)信息時，根據(jù)所述數(shù)據(jù)同步狀態(tài)信息判定所述待發(fā)送數(shù)據(jù)是否同步成功，若否，則重新發(fā)送所述待發(fā)送數(shù)據(jù)，在重發(fā)次數(shù)超過預(yù)設(shè)次數(shù)閾值或重發(fā)時長超過預(yù)設(shè)時長時，判定所述待發(fā)送數(shù)據(jù)同步失敗，將所述待發(fā)送數(shù)據(jù)從發(fā)送窗口中移除，從所述待同步數(shù)據(jù)中重新提取待發(fā)送數(shù)據(jù)，將重新提取的待發(fā)送數(shù)據(jù)加入發(fā)送窗口中并發(fā)送至所述云服務(wù)器；若是，則直接將所述待發(fā)送數(shù)據(jù)從發(fā)送窗口中移除，從所述待同步數(shù)據(jù)中重新提取待發(fā)送數(shù)據(jù)，將重新提取的待發(fā)送數(shù)據(jù)加入發(fā)送窗口中并發(fā)送至所述云服務(wù)器；

在無法成功獲取所述數(shù)據(jù)同步狀態(tài)信息時，判定所述待發(fā)送數(shù)據(jù)同步失敗，繼而將所述待發(fā)送數(shù)據(jù)從發(fā)送窗口中移除，從所述待同步數(shù)據(jù)重新提取待發(fā)送數(shù)據(jù)，將重新提取的待發(fā)送數(shù)據(jù)加入發(fā)送窗口中并發(fā)送至所述云服務(wù)器。