[發明專利]一種分布式緩存更新方法及緩存更新系統

在審

• 申請號: 201611245664.X
• 申請日: 2016-12-29
• 公開（公告）號: CN106713470A
• 公開（公告）日: 2017-05-24
• 發明（設計）人: 張海
• 申請（專利權）人: 北京奇藝世紀科技有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京柏杉松知識產權代理事務所(普通合伙)11413
• 代理人: 項京,馬敬

1.一種分布式緩存更新方法，其特征在于，應用于緩存更新系統，所述緩存更新系統包括：數據組裝服務器、數據緩存區、緩存更新服務器和緩存存儲服務器；所述方法包括：

所述數據組裝服務器獲得待緩存數據；按照預設規則將所述待緩存數據組裝為緩存包；將所述緩存包發送給所述數據緩存區進行存儲；

所述緩存更新服務器從所述數據緩存區中獲得所述緩存包；根據所述緩存包對與該緩存更新服務器位于同一機房的緩存存儲服務器進行緩存更新。

2.根據權利要求1所述的方法，其特征在于，所述數據緩存區為：

Kafka集群。

3.根據權利要求1所述的方法，其特征在于，所述按照預設規則將所述待緩存數據組裝為緩存包，包括：

對獲得的待緩存數據進行過濾；

按照預設規則將過濾后的待緩存數據組裝為緩存包。

4.根據權利要求1所述的方法，其特征在于，所述按照預設規則將所述待緩存數據組裝為緩存包，包括：

判斷獲得的待緩存數據的大小是否大于預設閾值；

如果是，將所述待緩存數據拆分為均不大于預設閾值的數據；

按照預設規則將拆分后的數據分別組裝為緩存包。

5.根據權利要求1所述的方法，其特征在于，所述緩存更新服務器從所述數據緩存區中獲得所述緩存包，包括：

所述緩存更新服務器從所述數據緩存區中以pull方式獲得所述緩存包。

6.根據權利要求1所述的方法，其特征在于，緩存包中包含有機房標識信息；

所述根據所述緩存包對與該緩存更新服務器位于同一機房的緩存存儲服務器進行緩存更新，包括：

根據所述標識信息判斷所述緩存包是否屬于所述緩存更新服務器所處機房；

如果是，根據所述緩存包對與該緩存更新服務器位于同一機房的緩存存儲服務器進行緩存更新。

7.根據權利要求1所述的方法，其特征在于，所述緩存更新系統還包括：更新檢測服務器；所述方法還包括：

所述更新檢測服務器根據緩存更新日志中各個步驟的處理狀態碼，判斷緩存是否更新成功；

如果否，向所述數據組裝服務器發送緩存更新不成功消息，以重新更新緩存。

8.一種緩存更新系統，其特征在于，所述系統包括：數據組裝服務器、數據緩存區、緩存更新服務器和緩存存儲服務器；所述數據組裝服務器包括：第一獲得模塊、組裝模塊和第一發送模塊；所述緩存更新服務器包括：第二獲得模塊和更新模塊，其中，

所述第一獲得模塊，用于獲得待緩存數據；

所述組裝模塊，用于按照預設規則將所述待緩存數據組裝為緩存包；

所述第一發送模塊，用于將所述緩存包發送給所述數據緩存區進行存儲；

所述第二獲得模塊，用于從所述數據緩存區中獲得所述緩存包；

所述更新模塊，用于根據所述緩存包對與該緩存更新服務器位于同一機房的緩存存儲服務器進行緩存更新。

9.根據權利要求8所述的系統，其特征在于，所述數據緩存區為：

Kafka集群。

10.根據權利要求8所述的系統，其特征在于，所述組裝模塊，包括：

過濾單元，用于對獲得的待緩存數據進行過濾；

第一組裝單元，用于按照預設規則將過濾后的待緩存數據組裝為緩存包。

11.根據權利要求8所述的系統，其特征在于，所述組裝模塊，包括：

第一判斷單元，用于判斷獲得的待緩存數據的大小是否大于預設閾值；

拆分單元，用于在獲得的待緩存數據的大小大于預設閾值的情況下，將所述待緩存數據拆分為均不大于預設閾值的數據；

第二組裝單元，用于按照預設規則將拆分后的數據分別組裝為緩存包。

12.根據權利要求8所述的系統，其特征在于，所述第二獲得模塊，具體用于：

從所述數據緩存區中以pull方式獲得所述緩存包。