[發(fā)明專利]一種基于mqtt協(xié)議的物聯(lián)網(wǎng)文件傳輸方法

在審

• 申請?zhí)枺?/td>: 202010891292.8
• 申請日: 2020-08-30
• 公開（公告）號: CN112118296A
• 公開（公告）日: 2020-12-22
• 發(fā)明（設(shè)計）人: 胡焱;李建飛;牛鵬
• 申請（專利權(quán)）人: 浪潮金融信息技術(shù)有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京權(quán)智天下知識產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11638
• 代理人: 王新愛

本發(fā)明公開了一種基于mqtt協(xié)議的物聯(lián)網(wǎng)文件傳輸方法，云端將文件轉(zhuǎn)化為字節(jié)數(shù)組形式；創(chuàng)建第一個信息包的下發(fā)表單；從第一步中得到的字節(jié)數(shù)組中取出第一個數(shù)組，放于表單生成的json字符串之后，通過mqtt協(xié)議發(fā)送至設(shè)備端topic；云端將第一步中得到的字節(jié)數(shù)組存儲起來；設(shè)備端訂閱相同topic，接收信息并校驗(yàn)；驗(yàn)證信息準(zhǔn)確性后，反饋響應(yīng)信息至云端；云端接收到響應(yīng)信息后，進(jìn)行驗(yàn)證，根據(jù)文件順序，取出下一個文件分包字節(jié)數(shù)組，并組合下一個信息表單，下發(fā)至設(shè)備。通過上述方式，本發(fā)明能夠避免因處理機(jī)緩存區(qū)過小導(dǎo)致無法成功接收的問題，具有通信流程可控、傳輸安全、運(yùn)行穩(wěn)定等特點(diǎn)。

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

本發(fā)明涉及物聯(lián)網(wǎng)數(shù)據(jù)傳輸技術(shù)領(lǐng)域，特別是涉及一種基于mqtt協(xié)議的物聯(lián)網(wǎng)文件傳輸方法，實(shí)現(xiàn)基于物聯(lián)網(wǎng)通訊的云端及單片機(jī)之間的文件傳輸。

背景技術(shù)

隨著物聯(lián)網(wǎng)技術(shù)的發(fā)展，遠(yuǎn)程設(shè)備與云端的通訊水平得到了顯著的提高，mqtt等基于tcp協(xié)議的產(chǎn)品支持逐漸走向視野，它們對信息傳輸之間的準(zhǔn)確性和穩(wěn)定性提供了更加有力的保障。

然而對于文件性質(zhì)傳輸工作來說，目前仍未存在通用的流程方法，對于部署在設(shè)備上的大部分輕量級通訊組件，如單片機(jī)，對信息包的定量傳輸、處理時間、并行機(jī)制、信息校驗(yàn)、編碼轉(zhuǎn)換，都存在著一定量的技術(shù)限制，具體包括以下缺陷：

1、文件包直接通過mqtt協(xié)議一次性全量發(fā)送，對于單片機(jī)這種輕量級處理機(jī)存在文件信息緩存導(dǎo)致內(nèi)存不足問題；

2、文件包下發(fā)之后，需要整包解析完成后，才能響應(yīng)信息準(zhǔn)確性與可行性，響應(yīng)機(jī)制不夠靈敏；

3、當(dāng)多次下發(fā)并行處理時，單片機(jī)對于當(dāng)前執(zhí)行動作的判斷將受到影響，各個進(jìn)程之間產(chǎn)生混亂的可能性提高；

4、文件整包的下發(fā)，不能快速的定位下發(fā)信息的準(zhǔn)確性。

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

本發(fā)明主要解決的技術(shù)問題是提供一種基于mqtt協(xié)議的物聯(lián)網(wǎng)文件傳輸方法，能夠?yàn)檩p量級設(shè)備組件的遠(yuǎn)程版本升級等功能提供了實(shí)現(xiàn)上的流程建議，為單片機(jī)等設(shè)備處理機(jī)處理文件接收及緩存工作等提供了有效的解決方案，一定程度上避免了因處理機(jī)緩存區(qū)過小導(dǎo)致無法成功接收的問題，具有通信流程可控、傳輸安全、運(yùn)行穩(wěn)定等特點(diǎn)。

為解決上述技術(shù)問題，本發(fā)明采用的一個技術(shù)方案是：提供一種基于mqtt協(xié)議的物聯(lián)網(wǎng)文件傳輸方法，包括以下步驟：

S1、云端將文件轉(zhuǎn)化為字節(jié)數(shù)組形式，并按照指定分包大小拆分?jǐn)?shù)組；

S2、云端創(chuàng)建第一個信息包的下發(fā)表單；

S3、創(chuàng)建好信息下發(fā)表單后，從S1中得到的字節(jié)數(shù)組中取出第一個數(shù)組，將該信息放于表單生成的json字符串之后，生成最后的字符串

S4、將這段信息通過mqtt協(xié)議發(fā)送至設(shè)備端topic，并對該發(fā)送方法添加設(shè)備級別的邏輯鎖；

S5、云端將S1中得到的字節(jié)數(shù)組存儲起來；

S6、設(shè)備端訂閱相同topic，接收信息并校驗(yàn)；

S7、驗(yàn)證信息準(zhǔn)確性后，反饋響應(yīng)信息至云端；

S8、云端接收到響應(yīng)信息后，驗(yàn)證通過，則取出保存的文件字節(jié)形式數(shù)組，根據(jù)當(dāng)前文件順序，取出下一個文件分包字節(jié)數(shù)組，并組合下一個信息表單，下發(fā)至設(shè)備；

S9、如此至設(shè)備完全接收信息包后，信息反饋無誤，則單片機(jī)端即可組合下發(fā)字節(jié)信息數(shù)組并處理；

S10、云端接收到最后一個信息反饋包后，如驗(yàn)證無誤，則判定文件傳輸成功，對該發(fā)送方法取消設(shè)備級別的邏輯鎖；

S11、進(jìn)程結(jié)束。