在云服務中，緩存是極其重要的一點。所謂緩存，其實是一個高速數據存儲層。當緩存存在后，日后再次請求該數據就會直接訪問緩存，提升數據訪問的速度。

但是緩存存儲的數據通常是短暫性的，這就需要經常對緩存進行更新。而我們操作緩存和數據庫，分為讀操作和寫操作。

讀操作的詳細流程為，請求數據，如緩存中存在數據則直接讀取并返回，如不存在則從數據庫中讀取，成功之后將數據放到緩存中。 寫操作則又分為以下 4 種：

先更新緩存，再更新數據庫

先更新數據庫，再更新緩存

先刪除緩存，再更新數據庫

先更新數據庫，再刪除緩存

一些一致性要求不高的數據，如點贊數等，可以先更新緩存，然后再定時同步到數據庫。而在其它情況下，我們通常會等數據庫操作成功，再操作緩存。

下面主要介紹更新數據庫成功后，更新緩存和刪除緩存這兩個操作的區別和改進方案。

先更新數據庫，再刪除緩存

先更新數據庫，再刪除緩存，這種模式也叫 cache aside，是目前比較流行的處理緩存數據庫一致性的方法。它的優點是：

出現數據不一致的概率極低，實現簡單

由于不更新緩存，而是刪除緩存，在并發寫寫情況下，不會出現數據不一致的情況

出現數據不一致的情況出現在并發讀寫的場景下，詳情可見下圖：



這種情況發生的概率比較低，必須要在某?時間區間同時存在兩個或多個寫?和多個讀取，所以大部分業務都容忍了這種小概率的不一致。

雖然發生的概率較低，但還是有一些方案可以讓影響降到更低。

優化方案

第一種方案為：采用較短的過期時間來減少影響。這種方法有兩個缺點：

刪除后，讀請求會 miss

如果緩存不一致，不一致的時間取決于過期時間設置

第二種方案則是采用延遲雙刪的策略，比如：1分鐘以后刪除緩存。這種做法也存在兩個缺點：

刪除緩存之前的時間里可能會有不一致

刪除后，讀請求會 miss

第三種方案為雙更新策略，思路與延遲雙刪策略差不多。不同的點是，此方案不刪除緩存而是更新緩存，所以讀請求就不會發生 miss。但是另一個缺點還是存在。

先更新數據庫，再更新緩存

相比先更新數據庫再刪除緩存的操作，先更新數據庫再更新緩存的操作可以避免用戶請求直接打到數據庫，進而導致緩存穿透的問題。

此方案是更新緩存，我們需要關注并發讀寫和并發寫寫兩個場景下導致的數據不一致。 先來看看并發讀寫的情況，步驟如下圖所示：



可以看到由于 4 和 5 操作步驟都設置了緩存，如果步驟4發生在步驟5之前，那么會出現舊值覆蓋新值的情況，也就是緩存不一致的情況。這種情況只需要修改一下步驟5，便可解決。

優化方案

可以通過在第五步不要 set cache，改用 add cache，redis 中使用 setnx 命令來進行優化。修改后步驟示意圖如下：



解決完了并發讀寫場景導致的數據不一致，再來看看并發寫寫情況導致的數據不一致問題。

出現不一致的情況如下圖所示，Thread A 比 Thread B 先更新完 DB，但是 Thread B 卻先更新完緩存，這就導致緩存會被 Thread A 的舊值所覆蓋。



這種情況也是有方法可以優化的，下面介紹兩個主流方法：

使用分布式鎖

使用版本號

使用分布式鎖

要解決并發讀寫的問題，第一個思路就是消滅并發寫。而使用分布式鎖，讓寫操作排隊執行，理論上就可以解決并發寫的問題，但現在并沒有可靠的分布式鎖實現方案。



不管是基于 Zookeeper，etcd 還是 redis 實現分布式鎖，為了防止程序掛掉而鎖不能釋放，我們都會給鎖設置租約/過期時間，想象一種場景：如果進程卡頓幾分鐘（雖然概率較低），導致鎖失效，而其它線程獲取到鎖，此時就又出現了并發讀寫的場景了，還是有可能會造成數據不一致。

使用版本號

并發寫導致的數據不一致，是因為低版本覆蓋了高版本。那么我們可以想辦法不讓這種情況發生，一種可行的方案是引入版本號，如果寫入的數據低于現版本號，則放棄覆蓋。 缺點：

應用層維護版本的代價很大，大規模落地很難

需修改數據模型，添加版本

每次需要修改，讓版本自增

不管是更新緩存還是刪除緩存，優化以后都將出現數據不一致的概率降到最低了。但是有沒有一種辦法既簡單，又不會出現數據不一致的場景呢。下面就介紹一下 Rockscache。

Rockscache

簡介

Rockscache 也是一種保持緩存一致性的方法，它采用的緩存管理策略是：更新數據庫后，將緩存標記為刪除。主要通過以下兩個方法來實現：

Fetch 函數實現了前面的查詢緩存

TagAsDeleted 函數實現了標記刪除的邏輯

在運行時只要讀數據時調用 Fetch，并且確保更新數據庫之后調用 TagAsDeleted，就能夠確保緩存最終一致。這一策略有 4 個特點：

不需要引入版本，幾乎可以適用于所有緩存場景

架構上與"更新 DB 后刪除緩存”一樣，無額外負擔

性能高：變化只是將原來的 GET/SET/DELETE，替換為 Lua 腳本

強一致方案的性能也很高，與普通的防緩存擊穿方案一樣

在 Rockscache 策略中，緩存中的數據是包含幾個字段的 hash：

value：數據本身

lockUtil：數據鎖定到期時間，當某個進程查詢緩存無數據，那么先鎖定緩存一小段時間，然后查詢 DB，然后更新緩存

owner：數據鎖定者 uuid

證明

因為 Rockscache 方案并不更新緩存，所以只要確保并發讀寫數據一致性即可。

下面來看看 Rockscache 是怎么解決數據不一致的問題，先回憶一遍 cache aside 模式導致的數據不一致的原因 結合 cache aside 模式出現數據不一致的場景，來講講 Rockscache 是怎么解決的。



我們要解決的核心問題是，防止舊值寫入到緩存中。Rockscache 的解決方案是這樣的：

查詢請求，如果緩存中讀不到數據，還要做一個操作：鎖定緩存，為key設置一個uuid

寫請求在刪除緩存的時候，需要把鎖刪了

讀請求在設置緩存的時候，通過uuid比對，發現上鎖的不是自己，說明有寫請求把數據更新了，則放棄修改緩存

至此我們已經完成了 rockscache 策略下的緩存更新。不過和其他緩存更新策略一樣，我們都默認操作數據庫成功后，操作緩存肯定成功。

但是這是不對的，在實際操作過程即便操作數據庫成功，也可能出現緩存操作失敗的情況，因此可以通過以下 3 種方式來保證緩存更新成功：

本地消息表

監聽 binlog

dtm 的二階段消息

除了緩存更新，Rockscache 還有以下兩種功能：

防止緩存擊穿

防止防止穿透和緩存雪崩

這都是非常實用的功能，推薦大家實際使用操作試試看。

審核編輯：劉清