[發明專利]一種基于文件監控和消息推送的實時同步系統

有效

• 申請號: 201610065684.2
• 申請日: 2016-01-29
• 公開（公告）號: CN105740418B
• 公開（公告）日: 2019-09-24
• 發明（設計）人: 林人俊;程遠;賴興榮;肖佳濤;楊倩嫻
• 申請（專利權）人: 杭州億方云網絡科技有限公司
• 主分類號: G06F16/17
• 分類號: G06F16/17;G06F16/178;G06F16/16;G06F16/13
• 代理公司: 北京科億知識產權代理事務所(普通合伙) 11350
• 代理人: 湯東鳳

本發明公開了一種基于文件監控和消息推送的實時同步系統，包括本地文件監控組件：適配Windows、MAC、Linux操作系統，實時捕獲用戶對本地文件系統的操作；推送服務組件：維護云端與本地客戶端之間的長連接，將云端的數據變動實時推送到本地；內核數據庫組件：記錄云端文件和本地文件的基本元數據，用于文件當前狀態和歷史版本的比較，從而計算出文件差異；同步組件：根據本地與云端的文件系統的差異，自動將本地修改上傳到云端，并且將云端的變動同步到本地。本發明可以全自動運行，并且能實時同步百萬級別文件數量，免去了人工下載和上傳文件的麻煩，從而極大地方便用戶使用云服務來管理文件數據。

技術領域

本發明涉及文件同步技術領域，尤其涉及一種基于文件監控和消息推送的實時同步系統。

背景技術

隨著計算機技術和互聯網技術的不斷發展，個人用戶或者企業用戶需要管理的文件數據越來越多，種類越來越豐富；同時用戶對數據安全性越來越敏感。傳統的U盤、硬盤等方式保存數據逐漸不能滿足需求。云存儲在近幾年迅猛發展，逐漸成為互聯網用戶主流的數據存儲方式，并且實現了隨時隨地數據訪問。

然而，目前的云存儲技術還存在以下幾個問題。第一、無論是通過瀏覽器、桌面應用程序還是手機APP來上傳下載文件都需要復雜的拖拽、點擊操作。用戶需要消耗大量的時間和精力在文件操作上；第二、在多人協作場景之下，用戶本地保存的并不一定是文件的最新版本，導致每次使用文件之前都需要到云端下載最新版本；第三、當文件數目急劇增加的時候，用戶無法通過手工操作，保證成千上萬文件的實時同步。

因此，同步網盤應運而生。所謂同步網盤，只是保持本地文件系統中某個或者某幾個文件夾與云端的文件系統保持實時同步。本地的文件修改能及時上傳到云端；云端的變動也能實時反映到本地文件上，無需認為干涉，自動完成。目前已有的一些同步算法存在同步錯誤、實時性不強等缺點。

發明內容

針對現有技術中的不足，本發明提供了方便用戶使用、準確度高、實時性強的一種基于文件監控和消息推送的實時同步系統。

本發明的目的是提供一種基于文件監控和消息推送的實時同步系統。在無人工干預的情況下，自動檢測本地文件系統中的內容變化并同步到云端；將云端的內容變動以消息推送的方式發送到本地，并將實際內容同步到本地。

為了實現上述目的，本發明所采取的技術方案是包括：

一種基于文件監控和消息推送的實時同步系統，其特征在于，包括，

本地文件監控組件，所述本地文件監控組件適配不同的操作系統，用于實時捕獲用戶在本地操作系統中的用戶操作；

推送服務組件，所述推送服務組件用以維護云端與本地客戶端之間的長連接，以及將云端的數據變動實時推送到本地；

內核數據庫組件，所述內核數據庫組件用以記錄云端文件和本地文件的基本元數據，以及對文件進行當前狀態和歷史版本的比較，計算出本地與云端文件的差異；

同步組件，所述同步組件用以根據本地與云端的文件的差異，自動將本地修改上傳到云端，并且將云端的變動同步到本地。

更進一步，所述推送服務組件包括：

Rabbit MQ消息隊列，所述Rabbit MQ消息隊列中創建兩個先進先出FIFO隊列：Action Queue操作隊列和Failed Action Queue操作失敗隊列，所述Action Queue用于保存用戶需要推送的操作消息；所述Failed Action Queue用于保存在異步處理過程中推送失敗的消息；

異步消息處理器，所述異步消息處理器用以從Action Queue中提取用戶的操作消息，并且獲取推送對象和消息主體；

HBase集群，所述HBase集群用以根據用戶ID為索引值，存儲需要推送給每個用戶的消息，以及持久化推送消息；