重新認識下JVM級別的本地快取框架Guava Cache(3)——探尋實作細節與核心機制

大家好，又見面了，

本文是筆者作為掘金技術社區簽約作者的身份輸出的快取專欄系列內容，將會通過系列專題，講清楚快取的方方面面，如果感興趣，歡迎關注以獲取后續更新，

通過《重新認識下JVM級別的本地快取框架Guava Cache——優秀從何而來》一文，我們知道了Guava Cache作為JVM級別的本地快取組件的諸多暖心特性，也一步步地學習了在專案中集成并使用Guava Cache進行快取相關操作，Guava Cache作為一款優秀的本地快取組件，其內部很多實作機制與設計策略，同樣值得開發人員深入的掌握與借鑒，

作為系列專欄，本篇文章我們將進一步探討下Guava Cache 實作層面的一些邏輯與設計策略，讓我們可以對Guava Cache整體有個更加明朗的認識，

資料回源與回填策略

前面我們介紹過，Guava Cache提供的是一種穿透型快取模式，當快取中沒有獲取到對應記錄的時候，支持自動去源端獲取資料并回填到快取中，這里回源獲取資料的策略有兩種，即CacheLoader方式與Callable方式，兩種方式適用于不同的場景,實際使用中可以按需選擇，

下面一起看下這兩種方式，

CacheLoader

CacheLoader適用于資料加載方式比較固定且統一的場景，在快取容器創建的時候就需要指定此具體的加載邏輯，常見的使用方式如下：

public LoadingCache<String, User> createUserCache() {
    return CacheBuilder.newBuilder()
            .build(new CacheLoader<String, User>() {
                @Override
                public User load(String key) throws Exception {
                    System.out.println(key + "用戶快取不存在，嘗試CacheLoader回源查找并回填...");
                    return userDao.getUser(key);
                }
            });
    }

上述代碼中，在使用CacheBuilder創建快取容器的時候，如果在build()方法中傳入一個CacheLoader實作類的方式，則最終創建出來的是一個LoadingCache具體型別的Cache容器：

默認情況下，我們需要繼承CacheLoader類并實作其load抽象方法即可，

當然，CacheLoader類中還有一些其它的方法，我們也可以選擇性的進行覆寫來實作自己的自定義訴求，比如我們需要設定refreshAfterWrite來支持定時重繪的時候，就推薦覆寫reload方法，提供一個異步資料加載能力，避免資料重繪操作對業務請求造成阻塞，

另外，有一點需要注意下，如果創建快取的時候使用refreshAfterWrite指定了需要定時更新快取資料內容，則必須在創建的時候指定CacheLoader實體，否則執行的時候會報錯，因為在執行refresh操作的時候，必須呼叫CacheLoader物件的reload方法去執行資料的回源操作，

Callable

與CacheLoader不同，Callable的方式在每次資料獲取請求中進行指定，可以在不同的呼叫場景中，分別指定并使用不同的資料獲取策略，更加的靈活，

public static void main(String[] args) {
    try {
        GuavaCacheService cacheService = new GuavaCacheService();
        Cache<String, User> cache = cacheService.createCache();
        String userId = "123";
        // 獲取userId， 獲取不到的時候執行Callable進行回源
        User user = cache.get(userId, () -> cacheService.queryUserFromDb(userId));
        System.out.println("get對應用戶資訊：" + user);
    } catch (Exception e) {
        e.printStackTrace();
    }
}

通過提供Callable實作函式并作為引數傳遞的方式，可以根據業務的需要，在不同業務呼叫場景下，指定使用不同的Callable回源策略，

不回源查詢

前面介紹了基于CacheLoader方式自動回源，或者基于Callable方式顯式回源的兩種策略，但是實際使用快取的時候，并非是快取中獲取不到資料時就一定需要去執行回源操作，

比如下面這個場景：

用戶論壇中維護了個黑名單串列，每次用戶登錄的時候，需要先判斷下是否在黑名單中，如果在則禁止登錄，

因為論壇中黑名單用戶占整體用戶量的比重是極少的，也就是幾乎絕大部分登錄的時候去查詢快取都是無法命中黑名單快取的，這種時候如果每次查詢快取中沒有的情況下都去執行回源操作，那幾乎等同于每次請求都需要去訪問一次DB了，這顯然是不合理的，

所以，為了支持這種場景的訪問，Guava cache也提供了一種不會觸發回源操作的訪問方式，如下：

上述兩種介面，執行的時候僅會從當前記憶體中已有的快取資料里面進行查詢，不會觸發回源的操作，

public static void main(String[] args) {
    try {
        GuavaCacheService cacheService = new GuavaCacheService();
        Cache<String, User> cache = cacheService.createCache();
        cache.put("123", new User("123", "123"));
        cache.put("124", new User("124", "124"));
        System.out.println(cache.getIfPresent("125"));
        ImmutableMap<String, User> allPresentUsers =
                cache.getAllPresent(Stream.of("123", "124", "125").collect(Collectors.toList()));
        System.out.println(allPresentUsers);
    } catch (Exception e) {
        e.printStackTrace();
    }
}

執行后，輸入結果如下：

null
{123=User(userName=123, userId=123), 124=User(userName=124, userId=124)}

Guava Cache的資料清理與加載重繪機制

在前面的CacheBuilder類中有提供了幾種expire與refresh的方法，即expireAfterAccess、expireAfterWrite以及refreshAfterWrite，

這里我們對幾個方法進行一些探討，

資料過期

對于資料有過期時效訴求的場景，我們可以通過幾種方式設定快取的過期時間：

• expireAfterAccess

• expireAfterWrite

現在我們思考一個問題：資料過期之后，會立即被洗掉嗎？在前面的文章中，我們自己構建本地快取框架的時候，有介紹過快取資料洗掉的幾種機制：

在Guava Cache中，為了最大限度的保證并發性，采用的是惰性洗掉的策略，而沒有設計獨立清理執行緒，所以這里我們就可以回答前面的問題，也即過期的資料，并非是立即被洗掉的，而是在get等操作訪問快取記錄時觸發過期資料的洗掉操作，

在get執行邏輯中進行資料過期清理以及重新回源加載的執行判斷流程，可以簡化為下圖中的關鍵環節：

在執行get請求的時候，會先判斷下當前查詢的資料是否過期，如果已經過期，則會觸發對當前操作的Segment的過期資料清理操作，

資料重繪

除了上述的2個過期時間設定方法，Guava Cache還提供了個refreshAfterWrite方法，用于設定定時自動refresh操作，專案中可能會有這么個情況：

為了提升性能，將最近訪問系統的用戶資訊快取起來，設定有效期30分鐘，如果用戶的角色出現變更，或者用戶昵稱、個性簽名之類的發生更改，則需要最長等待30分鐘快取失效重新加載后才能夠生效，

這種情況下，我們就可以在設定了過期時間的基礎上，再設定一個每隔1分鐘重新refresh的邏輯，這樣既可以保證資料在快取中的留存時長，又可以盡可能的縮短快取變更生效的時間，這種情況，便該refreshAfterWrite登場了，

與expire清理邏輯相同，refresh操作依舊是采用一種被動觸發的方式來實作，當get操作執行的時候會判斷下如果創建時間已經超過了設定的重繪間隔，則會重新去執行一次資料的加載邏輯（前提是資料并沒有過期），

鑒于快取讀多寫少的特點，Guava Cache在資料refresh操作執行的時候，采用了一種非阻塞式的加載邏輯，盡可能的保證并發場景下對讀取執行緒的性能影響，

看下面的代碼，模擬了兩個并發請求同時請求一個需要重繪的資料的場景：

public static void main(String[] args) {
    try {
        LoadingCache<String, User> cache =
                CacheBuilder.newBuilder().refreshAfterWrite(1L, TimeUnit.SECONDS).build(new MyCacheLoader());
        cache.put("123", new User("123", "ertyu"));
        Thread.sleep(1100L);
        Runnable task = () -> {
            try {
                System.out.println(Thread.currentThread().getId() + "執行緒開始執行查詢操作");
                User user = cache.get("123");
                System.out.println(Thread.currentThread().getId() + "執行緒查詢結果：" + user);
            } catch (Exception e) {
                e.printStackTrace();
            }
        };
        CompletableFuture.allOf(
                CompletableFuture.runAsync(task), CompletableFuture.runAsync(task)
        ).thenRunAsync(task).join();
    } catch (Exception e) {
        e.printStackTrace();
    }
}

執行后，結果如下：

14執行緒開始執行查詢操作
13執行緒開始執行查詢操作
13執行緒查詢結果：User(userName=ertyu, userId=123)
14執行緒執行CacheLoader.reload()，oldValue=https://www.cnblogs.com/softwarearch/p/User(userName=ertyu, userId=123)
14執行緒執行CacheLoader.load()...
14執行緒執行CacheLoader.load()結束...
14執行緒查詢結果：User(userName=97qx6, userId=123)
15執行緒開始執行查詢操作
15執行緒查詢結果：User(userName=97qx6, userId=123)

從執行結果可以看出，兩個并發同時請求的執行緒只有1個執行了load資料操作，且兩個執行緒所獲取到的結果是不一樣的，具體而言，可以概括為如下幾點：

• 同一時刻僅允許一個執行緒執行資料重新加載操作，并阻塞等待重新加載完成之后該執行緒的查詢請求才會回傳對應的新值作為結果，

• 當一個執行緒正在阻塞執行refresh資料重繪操作的時候，其它執行緒此時來執行get請求的時候，會判斷下資料需要refresh操作，但是因為沒有獲取到refresh執行鎖，這些其它執行緒的請求不會被阻塞等待refresh完成，而是立刻回傳當前refresh前的舊值，

• 當執行refresh的執行緒操作完成后，此時另一個執行緒再去執行get請求的時候，會判斷無需refresh，直接回傳當前記憶體中的當前值即可，

上述的程序，按照時間軸的維度來看，可以囊括成如下的執行程序：

資料expire與refresh關系

expire與refresh在某些實作邏輯上有一定的相似度，很多的文章中介紹的時候甚至很直白的說refresh比expire更好，因為其不會阻塞業務端的請求，個人認為這種看法有點片面，從單純的字面含義上也可以看出這兩種機制不是互斥的、而是一種相互補充的存在，并不存在誰比誰更好這一說，關鍵要看具體是應用場景，

expire操作就是采用的一種嚴苛的更新鎖定機制，當一個執行緒執行資料重新加載的時候，其余的執行緒則阻塞等待，refresh操作執行程序中不會阻塞其余執行緒的get查詢操作，會直接回傳舊值，這樣的設計各有利弊：

Guava Cache中的expire與fefresh兩種機制，給人的另一個困惑點在于：兩者都是被動觸發的資料加載邏輯，不管是expire還是refresh，只要超過指定的時間間隔，其實都是依舊存在與記憶體中，等有新的請求查詢的時候，都會執行自動的最新資料加載操作，那這兩個實際使用而言，僅僅只需要依據是否需要阻塞加載這個維度來抉擇？

并非如此，

expire存在的意義更多的是一種資料生命周期終結的意味，超過了expire有效期的資料，雖然依舊會存在于記憶體中，但是在一些觸發了cleanUp操作的情況下，是會被釋放掉以減少記憶體占用的，而refresh則僅僅只是執行資料更新，框架無法判斷是否需要從記憶體釋放掉，會始終占據記憶體，

所以在具體使用時，需要根據場景綜合判斷：

• 資料需要永久存盤，且不會變更，這種情況下expire和refresh都并不需要設定

• 資料極少變更，或者對變更的感知訴求不強，且并發請求同一個key的競爭壓力不大，直接使用expire即可

• 資料無需過期，但是可能會被修改，需要及時感知并更新快取資料，直接使用refresh

• 資料需要過期（避免不再使用的資料始終留在記憶體中）、也需要在有效期內盡可能保證資料的更新一致性，則采用expire與refresh兩者結合，

對于expire與refresh結合使用的場景，兩者的時間間隔設定，需要注意：

expire時間設定要大于refresh時間，否則的話refresh將永遠沒有機會執行

Guava Cache并發能力支持

采用分段鎖降低鎖爭奪

前面我們提過Guava Cache支持多執行緒環境下的安全訪問，我們知道鎖的粒度越大，多執行緒請求的時候對鎖的競爭壓力越大，對性能的影響越大，而如果將鎖的粒度拆分小一些，這樣同時請求到同一把鎖的概率就會降低，這樣執行緒間爭奪鎖的競爭壓力就會降低，

Guava Cache中采用的也就是這種分段鎖策略來降低鎖的粒度，可以在創建快取容器的時候使用concurrencyLevel來指定允許的最大并發執行緒數，使得執行緒安全的前提下盡可能的減少鎖爭奪，而concurrencyLevel值與分段Segment的數量之間也存在一定的關系，這個關系相對來說會比較復雜、且受是否限制總容量等因素的影響，原始碼中這部分的計算邏輯可以看下：

    int segmentShift = 0;
    int segmentCount = 1;
    while (segmentCount < concurrencyLevel && (!evictsBySize() || segmentCount * 20 <= maxWeight)) {
        ++segmentShift;
        segmentCount <<= 1;
    }

根據上述的控制邏輯代碼，可以將segmentCount的取值約束概括為下面幾點：

• segmentCount 是 2 的整數倍

• segmentCount 最大可能為(concurrencyLevel -1)*2

• 如果有按照權重設定容量，則segmentCount不得超過總權重值的1/20

從原始碼中可以比較清晰的看出這一點，Guava Cache在put寫操作的時候，會首先計算出key對應的hash值，然后根據hash值來確定資料應該寫入到哪個Segment中，進而對該Segment加鎖執行寫入操作，

@Override
public V put(K key, V value) {
    // ... 省略部分邏輯
    int hash = hash(key);
    return segmentFor(hash).put(key, hash, value, false);
}
@Nullable
V put(K key, int hash, V value, boolean onlyIfAbsent) {
  lock();
    try {
        // ... 省略具體邏輯
    } finally {
        unlock();
        postWriteCleanup();
    }
}

根據上述原始碼也可以得出一個結論，concurrencyLevel只是一個理想狀態下的最大同時并發數，也取決于同一時間的操作請求是否會平均的分散在各個不同的Segment中，極端情況下，如果多個執行緒操作的目標物件都在同一個分片中時，那么只有1個執行緒可以持鎖執行，其余執行緒都會阻塞等待，

實際使用中，比較推薦的是將concurrencyLevel設定為CPU核數的2倍，以獲得較優的并發性能，當然，concurrencyLevel也不是可以隨意設定的，從其原始碼設定里面可以看出，允許的最大值為65536，

static final int MAX_SEGMENTS = 1 << 16; // 65536
LocalCache(CacheBuilder<? super K, ? super V> builder, @Nullable CacheLoader<? super K, V> loader) {
    concurrencyLevel = Math.min(builder.getConcurrencyLevel(), MAX_SEGMENTS);
    // ... 省略其余邏輯
}

佛系搶鎖策略

在put等寫操作場景下，Guava Cache采用的是上述分段鎖的策略，通過優化鎖的粒度，來提升并發的性能，但是加鎖畢竟還是對性能有一定的影響的，為了追求更加極致的性能表現，在get等讀操作自身并沒有發現加鎖操作 —— 但是Guava Cache的get等處理邏輯也并非是純粹的只讀操作，它還兼具觸發資料淘汰清理操作的洗掉邏輯，所以只在判斷需要執行清理的時候才會嘗試去佛系搶鎖，

那么它是如何減少搶鎖的幾率的呢？從原始碼中可以看出，并非是每次請求都會去觸發cleanUp操作，而是會嘗試積攢一定次數之后再去嘗試清理：

static final int DRAIN_THRESHOLD = 0x3F;
void postReadCleanup() {
  if ((readCount.incrementAndGet() & DRAIN_THRESHOLD) == 0) {
    cleanUp();
  }
}

在高并發場景下，如果查詢請求量巨大的情況下，即使按照上述的情況限制每次達到一定請求數量之后才去執行清理操作，依舊可能會出現多個get操作執行緒同時去搶鎖執行清理操作的情況，這樣豈不是依舊會阻塞這些讀取請求的處理嗎？

繼續看下原始碼：

void cleanUp() {
  long now = map.ticker.read();
  runLockedCleanup(now);
  runUnlockedCleanup();
}
void runLockedCleanup(long now) {
    // 嘗試請求鎖，請求到就處理，請求不到就放棄
  if (tryLock()) {
    try {
      // ... 省略部分邏輯
      readCount.set(0);
    } finally {
      unlock();
    }
  }
}

可以看到原始碼中采用的是tryLock方法來嘗試去搶鎖，如果搶到鎖就繼續后續的操作，如果沒搶到鎖就不做任何清理操作，直接回傳 —— 這也是為什么前面將其形容為“佛系搶鎖”的緣由，這樣的小細節中也可以看出Google碼農們還是有點內功修為的，

承前啟后 —— Caffeine Cache

技術的更新迭代始終沒有停歇的時候，Guava工具包作為Google家族的優秀成員，在很多方面提供了非常優秀的能力支持，隨著JAVA8的普及，Google也基于語言的新特性，對Guava Cache部分進行了重新實作，形成了后來的Caffeine Cache，并在SpringBoot2.x中取代了Guava Cache，

下一篇文章中，我們將一起再聊一聊令人上癮的Caffeine Cache，

小結回顧

好啦，關于Guava Cache中的典型實作機制與核心設計策略，就介紹到這里了，至此，我們完成了Guava Cache從簡單會用到深度剖析的全程序，不知道小伙伴們是否對Guava Cache有了全新的認識了呢？關于Guava Cache，你是否有自己的一些想法與見解呢？歡迎評論區一起交流下，期待和各位小伙伴們一起切磋、共同成長，

?? 補充說明1 ：

本文屬于《深入理解快取原理與實戰設計》系列專欄的內容之一，該專欄圍繞快取這個宏大命題進行展開闡述，全方位、系統性地深度剖析各種快取實作策略與原理、以及快取的各種用法、各種問題應對策略，并一起探討下快取設計的哲學，

如果有興趣，也歡迎關注此專欄，

?? 補充說明2 ：

• 關于本文中涉及的演示代碼的完整示例，我已經整理并提交到github中，如果您有需要，可以自取：https://github.com/veezean/JavaBasicSkills

我是悟道，聊技術、又不僅僅聊技術~

如果覺得有用，請點贊 + 關注讓我感受到您的支持，也可以關注下我的公眾號【架構悟道】，獲取更及時的更新，

期待與你一起探討，一起成長為更好的自己，

本文來自博客園，作者：架構悟道，歡迎關注公眾號[架構悟道]持續獲取更多干貨，轉載請注明原文鏈接：https://www.cnblogs.com/softwarearch/p/16927939.html

標籤：Java

上一篇：使用Apache PDFBox實作拆分、合并PDF

下一篇：每日演算法之矩陣中的路徑