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

在審

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

1.一種本地服務(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ā)控制指令。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述本地服務(wù)器將數(shù)據(jù)上傳至Kafka集群，包括：

所述本地服務(wù)器根據(jù)定時任務(wù)將數(shù)據(jù)上傳至Kafka集群。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述本地服務(wù)器根據(jù)定時任務(wù)將數(shù)據(jù)上傳至Kafka集群，包括：

所述本地服務(wù)器對數(shù)據(jù)進行清洗、整理及加工處理；

將處理后的數(shù)據(jù)根據(jù)定時任務(wù)將數(shù)據(jù)上傳至Kafka集群。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述控制指令包括頭部和數(shù)據(jù)；

所述頭部用于指示一個控制指令需要執(zhí)行的操作類型；

所述數(shù)據(jù)包括對應(yīng)操作類型的具體操作內(nèi)容、是否需要返回操作的結(jié)構(gòu)以及標識信息。

5.一種本地服務(wù)器和云服務(wù)器的數(shù)據(jù)同步裝置，其特征在于，包括：

數(shù)據(jù)上傳裝置，用于使得本地服務(wù)器將數(shù)據(jù)上傳至Kafka集群；

數(shù)據(jù)抓取裝置，用于使得云服務(wù)器從Kafka集群抓取數(shù)據(jù)；

通道建立模塊，用于在本地服務(wù)器和云服務(wù)器之間建立Websocket通道；

指令下發(fā)模塊，用于使得云服務(wù)器通過Websocket通道向本地服務(wù)器下發(fā)控制指令。

6.根據(jù)權(quán)利要求5所述的裝置，其特征在于，所述數(shù)據(jù)上傳裝置具體用于：

所述本地服務(wù)器根據(jù)定時任務(wù)將數(shù)據(jù)上傳至Kafka集群。

7.根據(jù)權(quán)利要求6所述的裝置，其特征在于，所述數(shù)據(jù)上傳裝置具體用于：

所述本地服務(wù)器對數(shù)據(jù)進行清洗、整理及加工處理；

將處理后的數(shù)據(jù)根據(jù)定時任務(wù)將數(shù)據(jù)上傳至Kafka集群。

8.根據(jù)權(quán)利要求5所述的裝置，其特征在于，所述控制指令包括頭部和數(shù)據(jù)信息；

所述頭部用于指示一個控制指令需要執(zhí)行的操作類型；

所述數(shù)據(jù)信息包括對應(yīng)操作類型的具體操作內(nèi)容、是否需要返回操作的結(jié)構(gòu)以及標識信息。

9.一種電子設(shè)備，包括存儲器和處理器，所述存儲器上存儲有計算機程序，其特征在于，所述處理器執(zhí)行所述程序時實現(xiàn)如權(quán)利要求1至4中任一項所述的方法。

10.一種計算機可讀存儲介質(zhì)，其上存儲有計算機程序，其特征在于，所述程序被處理器執(zhí)行時實現(xiàn)如權(quán)利要求1至4中任一項所述的方法。