Caffeine快取框架入門學習

引入依賴

<dependency>
    <groupId>com.github.ben-manes.caffeine</groupId>
    <artifactId>caffeine</artifactId>
    <version>2.5.5</version>
</dependency>

基礎創建方式

Cache<String, Integer> cache = Caffeine.newBuilder().build();

常用創建模板

private static final Cache<String, String> CONFIG_VALUE =
            https://www.cnblogs.com/MorningBell/archive/2022/09/05/Caffeine.newBuilder()
                    //初始容量
                    .initialCapacity(100)
                    //最大容量
                    .maximumSize(1000)
                    //過期時間
                    .expireAfterWrite(10, TimeUnit.MINUTES)
                    //快取元素洗掉監聽器，引數分別為快取的key，value，驅逐原因
                    .removalListener((Key key, Object value, RemovalCause cause) ->
                            System.out.printf("Key %s was removed (%s)%n", key, cause))
                    .build();

填充策略

填充策略分為手動填充，自動填充，異步手動填充和異步自動填充四種

• 手動填充

Cache<Key, MyObject> cache = Caffeine.newBuilder().build();

// 查找一個快取元素， 沒有查找到的時候回傳null
MyObject graph = cache.getIfPresent(key);
// 查找快取，如果快取不存在則生成快取元素,  如果無法生成則回傳null
graph = cache.get(key, k -> createObject(key));
// 添加或者更新一個快取元素
cache.put(key, graph);
// 移除一個快取元素
cache.invalidate(key);

• 自動填充

LoadingCache<Key, Graph> cache = Caffeine.newBuilder()
    //自動填充即在初始化的時候就指定自動填充函式，當快取中沒有命中資料的時候自動執行填充函式
    .build(key -> createExpensiveGraph(key));

// 查找快取，如果快取不存在則生成快取元素,  如果無法生成則回傳null
Graph graph = cache.get(key);
// 批量查找快取，如果快取不存在則生成快取元素
Map<Key, Graph> graphs = cache.getAll(keys);

• 異步手動填充

AsyncCache<Key, Graph> cache = Caffeine.newBuilder()
    .buildAsync();

// 查找快取元素，如果不存在，則異步生成
CompletableFuture<Graph> graph = cache.get(key, k -> createExpensiveGraph(key));

• 異步自動填充

AsyncLoadingCache<Key, Graph> cache = Caffeine.newBuilder()
    // 你可以選擇: 去異步的封裝一段同步操作來生成快取元素
    .buildAsync(key -> createExpensiveGraph(key));
    // 你也可以選擇: 構建一個異步快取元素操作并回傳一個future
    .buildAsync((key, executor) -> createExpensiveGraphAsync(key, executor));

// 查找快取元素，如果其不存在，將會異步進行生成
CompletableFuture<Graph> graph = cache.get(key);
// 批量查找快取元素，如果其不存在，將會異步進行生成
CompletableFuture<Map<Key, Graph>> graphs = cache.getAll(keys);

驅逐策略

驅逐策略有三種：基于大小驅逐，基于時間驅逐，基于參考驅逐

• 基于大小分為基于快取大小，和基于權重大小兩種

// 根據快取的計數進行驅逐
LoadingCache<Key, Graph> graphs = Caffeine.newBuilder()
    .maximumSize(10_000)
    .build(key -> createExpensiveGraph(key));

// 根據快取的權重來進行驅逐（權重只是用于確定快取大小，不會用于決定該快取是否被驅逐）
LoadingCache<Key, Graph> graphs = Caffeine.newBuilder()
    .maximumWeight(10_000)
    .weigher((Key key, Graph graph) -> graph.vertices().size())
    .build(key -> createExpensiveGraph(key));

• 基于時間驅逐

LoadingCache<Key, Graph> graphs = Caffeine.newBuilder()
    //當指定時間內沒有被讀寫則被清除
    .expireAfterAccess(5, TimeUnit.MINUTES)
    .build(key -> createExpensiveGraph(key));

LoadingCache<Key, Graph> graphs = Caffeine.newBuilder()
    //最后一次寫入固定時間后被清除
    .expireAfterWrite(10, TimeUnit.MINUTES)
    .build(key -> createExpensiveGraph(key));

//還可以使用exoureAfter（）來自定義到期驅逐策略，詳見文章末尾參考鏈接

• 基于參考驅逐

LoadingCache<Key, Graph> graphs = Caffeine.newBuilder()
    //弱參考鍵值
    .weakKeys()
    .weakValues()
    .build(key -> createExpensiveGraph(key));

// 當垃圾收集器需要釋放記憶體時驅逐
LoadingCache<Key, Graph> graphs = Caffeine.newBuilder()
    //軟參考值
    .softValues()
    .build(key -> createExpensiveGraph(key));

注意：AsyncLoadingCache不支持弱參考和軟參考，

以上僅為基礎部分內容，詳細學習參考文末鏈接，

參考：
https://blog.csdn.net/crazymakercircle/article/details/113751575
https://zhuanlan.zhihu.com/p/329684099

標籤：其他

上一篇：用Python做一個中秋搶購月餅的腳本

下一篇：Rust 如何實作 async/await