[發明專利]本地服務器和云服務器的數據同步方法和裝置

在審

• 申請號: 202110320101.7
• 申請日: 2021-03-25
• 公開（公告）號: CN112911022A
• 公開（公告）日: 2021-06-04
• 發明（設計）人: 李學健;陳浩然;陳亮
• 申請（專利權）人: 北京數字磐石科技有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京維正專利代理有限公司 11508
• 代理人: 趙萬凱

1.一種本地服務器和云服務器的數據同步方法，其特征在于，包括：

本地服務器向云服務器上傳數據：本地服務器將數據上傳至Kafka集群，云服務器從Kafka集群抓取數據；

云服務器向本地服務器下發控制指令：在本地服務器和云服務器之間建立Websocket通道，云服務器通過Websocket通道向本地服務器下發控制指令。

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

所述本地服務器根據定時任務將數據上傳至Kafka集群。

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

所述本地服務器對數據進行清洗、整理及加工處理；

將處理后的數據根據定時任務將數據上傳至Kafka集群。

4.根據權利要求1所述的方法，其特征在于，所述控制指令包括頭部和數據；

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

所述數據包括對應操作類型的具體操作內容、是否需要返回操作的結構以及標識信息。

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

數據上傳裝置，用于使得本地服務器將數據上傳至Kafka集群；

數據抓取裝置，用于使得云服務器從Kafka集群抓取數據；

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

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

6.根據權利要求5所述的裝置，其特征在于，所述數據上傳裝置具體用于：

所述本地服務器根據定時任務將數據上傳至Kafka集群。

7.根據權利要求6所述的裝置，其特征在于，所述數據上傳裝置具體用于：

所述本地服務器對數據進行清洗、整理及加工處理；

將處理后的數據根據定時任務將數據上傳至Kafka集群。

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

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

所述數據信息包括對應操作類型的具體操作內容、是否需要返回操作的結構以及標識信息。

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

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