[發(fā)明專利]本地服務(wù)器和云服務(wù)器的數(shù)據(jù)同步方法和裝置

在審

• 申請?zhí)枺?/td>: 202110320101.7
• 申請日: 2021-03-25
• 公開（公告）號: CN112911022A
• 公開（公告）日: 2021-06-04
• 發(fā)明（設(shè)計(jì)）人: 李學(xué)健;陳浩然;陳亮
• 申請（專利權(quán)）人: 北京數(shù)字磐石科技有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京維正專利代理有限公司 11508
• 代理人: 趙萬凱

本申請的實(shí)施例提供了一種本地服務(wù)器和云服務(wù)器的數(shù)據(jù)同步方法和裝置，該方法包括本地服務(wù)器向云服務(wù)器上傳數(shù)據(jù)：本地服務(wù)器將數(shù)據(jù)上傳至Kafka集群，云服務(wù)器從Kafka集群抓取數(shù)據(jù)；云服務(wù)器向本地服務(wù)器下發(fā)控制指令：在本地服務(wù)器和云服務(wù)器之間建立Websocket通道，云服務(wù)器通過Websocket通道向本地服務(wù)器下發(fā)控制指令。本申請能夠改善數(shù)據(jù)上傳時(shí)的網(wǎng)絡(luò)擁堵，同時(shí)能夠確保云服務(wù)器能夠單獨(dú)對本地服務(wù)器進(jìn)行控制。

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

本申請涉及區(qū)塊鏈技術(shù)領(lǐng)域，尤其是涉及一種本地服務(wù)器和云服務(wù)器的數(shù)據(jù)同步方法和裝置。

背景技術(shù)

本地服務(wù)器和云服務(wù)器之間的數(shù)據(jù)需要同步時(shí)，由于數(shù)據(jù)量較大，數(shù)據(jù)傳輸會出現(xiàn)較大的波峰波谷，從而造成網(wǎng)絡(luò)擁堵，影響數(shù)據(jù)的傳輸，同時(shí)在云服務(wù)器控制本地服務(wù)器時(shí)，不能達(dá)到精準(zhǔn)控制。

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

為了改善本地服務(wù)器和云服務(wù)器之間數(shù)據(jù)同步時(shí)網(wǎng)絡(luò)擁堵的情況并實(shí)現(xiàn)云服務(wù)器精準(zhǔn)控制本地服務(wù)器，本申請實(shí)施例提供了一種本地服務(wù)器和云服務(wù)器的數(shù)據(jù)同步方法和裝置。

第一方面，本申請?zhí)峁┝艘环N本地服務(wù)器和云服務(wù)器的數(shù)據(jù)同步方法，包括：本地服務(wù)器向云服務(wù)器上傳數(shù)據(jù)：本地服務(wù)器將數(shù)據(jù)上傳至Kafka集群，云服務(wù)器從Kafka集群抓取數(shù)據(jù)；云服務(wù)器向本地服務(wù)器下發(fā)控制指令：在本地服務(wù)器和云服務(wù)器之間建立Websocket通道，云服務(wù)器通過Websocket通道向本地服務(wù)器下發(fā)控制指令。

優(yōu)選的，所述本地服務(wù)器將數(shù)據(jù)上傳至Kafka集群，包括：所述本地服務(wù)器根據(jù)定時(shí)任務(wù)將數(shù)據(jù)上傳至Kafka集群。

優(yōu)選的，所述本地服務(wù)器根據(jù)定時(shí)任務(wù)將數(shù)據(jù)上傳至Kafka集群，包括：所述本地服務(wù)器對數(shù)據(jù)進(jìn)行清洗、整理及加工處理；將處理后的數(shù)據(jù)根據(jù)定時(shí)任務(wù)將數(shù)據(jù)上傳至Kafka集群。

優(yōu)選的，所述控制指令包括頭部和數(shù)據(jù)；所述頭部用于指示一個(gè)控制指令需要執(zhí)行的操作類型；所述數(shù)據(jù)包括對應(yīng)操作類型的具體操作內(nèi)容、是否需要返回操作的結(jié)構(gòu)以及標(biāo)識信息。

第二方面，本申請?zhí)峁┝艘环N本地服務(wù)器和云服務(wù)器的數(shù)據(jù)同步裝置，包括：數(shù)據(jù)上傳裝置，用于使得本地服務(wù)器將數(shù)據(jù)上傳至Kafka集群；數(shù)據(jù)抓取裝置，用于使得云服務(wù)器從Kafka集群抓取數(shù)據(jù)；通道建立模塊，用于在本地服務(wù)器和云服務(wù)器之間建立Websocket通道；指令下發(fā)模塊，用于使得云服務(wù)器通過Websocket通道向本地服務(wù)器下發(fā)控制指令。

優(yōu)選的，所述數(shù)據(jù)上傳裝置具體用于：所述本地服務(wù)器根據(jù)定時(shí)任務(wù)將數(shù)據(jù)上傳至Kafka集群。

優(yōu)選的，所述數(shù)據(jù)上傳裝置具體用于：所述本地服務(wù)器對數(shù)據(jù)進(jìn)行清洗、整理及加工處理；將處理后的數(shù)據(jù)根據(jù)定時(shí)任務(wù)將數(shù)據(jù)上傳至Kafka集群。

優(yōu)選的，所述控制指令包括頭部和數(shù)據(jù)；所述頭部用于指示一個(gè)控制指令需要執(zhí)行的操作類型；所述數(shù)據(jù)包括對應(yīng)操作類型的具體操作內(nèi)容、是否需要返回操作的結(jié)構(gòu)以及標(biāo)識信息。

第三方面，本申請?zhí)峁┝艘环N電子設(shè)備，包括存儲器和處理器，所述存儲器上存儲有計(jì)算機(jī)程序，所述處理器執(zhí)行所述程序時(shí)實(shí)現(xiàn)如第一方面中任一項(xiàng)所述的方法。

第四方面，本申請?zhí)峁┝艘环N計(jì)算機(jī)可讀存儲介質(zhì)，其上存儲有計(jì)算機(jī)程序，所述程序被處理器執(zhí)行時(shí)實(shí)現(xiàn)如第一方面中任一項(xiàng)所述的方法。

在本申請實(shí)施例中，通過本地服務(wù)器將數(shù)據(jù)上傳至Kafka集群，云服務(wù)器從Kafka集群抓取數(shù)據(jù)；云服務(wù)器向本地服務(wù)器下發(fā)控制指令：在本地服務(wù)器和云服務(wù)器之間建立Websocket通道，云服務(wù)器通過Websocket通道向本地服務(wù)器下發(fā)控制指令，從而能夠改善數(shù)據(jù)上傳時(shí)的網(wǎng)絡(luò)擁堵，同時(shí)能夠確保云服務(wù)器能夠單獨(dú)對本地服務(wù)器進(jìn)行控制。

應(yīng)當(dāng)理解，發(fā)明內(nèi)容部分中所描述的內(nèi)容并非旨在限定本申請的實(shí)施例的關(guān)鍵或重要特征，亦非用于限制本申請的范圍。本申請的其它特征將通過以下的描述變得容易理解。