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

void test1() {
    Cache<Object, Object> cache = Caffeine.newBuilder()
            // 初始數(shù)量
            .initialCapacity(10)
            // 最大條數(shù)
            .maximumSize(10)
            // expireAfterWrite和expireAfterAccess同時(shí)存在時(shí)，以expireAfterWrite為準(zhǔn)
            // 最后一次寫操作后經(jīng)過(guò)指定時(shí)間過(guò)期
            .expireAfterWrite(1, TimeUnit.SECONDS)
            // 最后一次讀或?qū)懖僮骱蠼?jīng)過(guò)指定時(shí)間過(guò)期
            .expireAfterAccess(1, TimeUnit.SECONDS)
            // 監(jiān)聽(tīng)緩存被移除
            .removalListener((key, value, cause) -> {})
            // 記錄命中
            .recordStats()
            .build();
    cache.put("1", "張三");
    System.out.println(cache.asMap());
    System.out.println(cache.getIfPresent("1"));
    System.out.println(cache.get("2", o -> "默認(rèn)值"));
}

@Test
void test2() {
    AsyncLoadingCache<String, String> asyncLoadingCache = Caffeine.newBuilder()
            // 創(chuàng)建緩存或者最近一次更新緩存后經(jīng)過(guò)指定時(shí)間間隔刷新緩存：僅支持LoadingCache
            .refreshAfterWrite(1, TimeUnit.SECONDS)
            .expireAfterWrite(1, TimeUnit.SECONDS)
            .expireAfterAccess(1, TimeUnit.SECONDS)
            .maximumSize(10)
            // 根據(jù)key查詢數(shù)據(jù)庫(kù)里面的值
            .buildAsync(key -> {
                Thread.sleep(1000);
                return new Date().toString();
            });
    // 異步緩存返回的是CompletableFuture
    CompletableFuture<String> future = asyncLoadingCache.get("1");
    future.thenAccept(System.out::println);
}

@Test
void test3() {
? ? LoadingCache<String, String> cache = Caffeine.newBuilder()
? ? ? ? ? ? // 創(chuàng)建緩存或者最近一次更新緩存后經(jīng)過(guò)指定時(shí)間間隔，刷新緩存：refreshAfterWrite僅支持LoadingCache
? ? ? ? ? ? .refreshAfterWrite(1, TimeUnit.SECONDS)
? ? ? ? ? ? .expireAfterWrite(1, TimeUnit.SECONDS)
? ? ? ? ? ? .expireAfterAccess(1, TimeUnit.SECONDS)
? ? ? ? ? ? .maximumSize(10)
? ? ? ? ? ? // 開啟記錄緩存命中率等信息
? ? ? ? ? ? .recordStats()
? ? ? ? ? ? // 根據(jù)key查詢數(shù)據(jù)庫(kù)里面的值
? ? ? ? ? ? .build(key -> {
? ? ? ? ? ? ? ? TimeUnit.MILLISECONDS.sleep(1000);
? ? ? ? ? ? ? ? return new Date().toString();
? ? ? ? ? ? });

? ? cache.put("1", "小明");
? ? cache.get("1");

? ? /*
? ? ?* hitCount :命中的次數(shù)
? ? ?* missCount:未命中次數(shù)
? ? ?* requestCount:請(qǐng)求次數(shù)
? ? ?* hitRate:命中率
? ? ?* missRate:丟失率
? ? ?* loadSuccessCount:成功加載新值的次數(shù)
? ? ?* loadExceptionCount:失敗加載新值的次數(shù)
? ? ?* totalLoadCount:總條數(shù)
? ? ?* loadExceptionRate:失敗加載新值的比率
? ? ?* totalLoadTime:全部加載時(shí)間
? ? ?* evictionCount:丟失的條數(shù)
? ? ?*/
? ? System.out.println(cache.stats());
}

// 緩存大小淘汰
@Test
public void maximumSizeTest() throws InterruptedException {
? ? Cache<Object, Object> cache = Caffeine.newBuilder()
? ? ? ? ? ? // 超過(guò)10個(gè)后會(huì)使用W-TinyLFU算法進(jìn)行淘汰
? ? ? ? ? ? .maximumSize(10)
? ? ? ? ? ? .build();
? ? for (int i = 1; i <= 10; i++) {
? ? ? ? cache.put(i, i);
? ? }
? ? // 緩存淘汰是異步的
? ? TimeUnit.MILLISECONDS.sleep(500);
? ? // 打印還沒(méi)有被淘汰的緩存
? ? System.out.println(cache.asMap());
}

// 權(quán)重淘汰
@Test
public void maximumWeightTest() throws InterruptedException {
? ? Cache<Integer, Integer> cache = Caffeine.newBuilder()
? ? ? ? ? ? // 限制總權(quán)值，若所有緩存的權(quán)重加起來(lái)>總權(quán)重就會(huì)淘汰權(quán)重小的緩存
? ? ? ? ? ? .maximumWeight(100)
? ? ? ? ? ? .weigher((Weigher<Integer, Integer>) (key, value) -> key)
? ? ? ? ? ? .build();
? ? // 總權(quán)重其實(shí)是=所有緩存的權(quán)重加起來(lái)
? ? int maximumWeight = 0;
? ? for (int i = 1; i < 20; i++) {
? ? ? ? cache.put(i, i);
? ? ? ? maximumWeight += i;
? ? ? ? System.out.println("i = " + i + ", maximumWeight = " + maximumWeight);
? ? }
? ? System.out.println("總權(quán)重 = " + maximumWeight);
? ? // 緩存淘汰是異步的
? ? TimeUnit.MILLISECONDS.sleep(500);
? ? // 打印還沒(méi)有被淘汰的緩存
? ? System.out.println(cache.asMap());
}

// 訪問(wèn)后到期（每次訪問(wèn)都會(huì)重置時(shí)間，也就是說(shuō)如果一直被訪問(wèn)就不會(huì)被淘汰）
@Test
void expireAfterAccessTest() throws InterruptedException {
? ? Cache<Object, Object> cache = Caffeine.newBuilder()
? ? ? ? ? ? .expireAfterAccess(1, TimeUnit.SECONDS)
? ? ? ? ? ? // 可以指定調(diào)度程序來(lái)及時(shí)刪除過(guò)期緩存項(xiàng)，而不是等待Caffeine觸發(fā)定期維護(hù)
? ? ? ? ? ? // 若不設(shè)置scheduler,則緩存會(huì)在下一次調(diào)用get的時(shí)候才會(huì)被動(dòng)刪除
? ? ? ? ? ? .scheduler(Scheduler.systemScheduler())
? ? ? ? ? ? .build();
? ? cache.put(1, 2);
? ? System.out.println(cache.getIfPresent(1));
? ? Thread.sleep(3000);
? ? System.out.println(cache.getIfPresent(1));
}

// 寫入后到期
@Test
void expireAfterWriteTest() throws InterruptedException {
? ? Cache<Object, Object> cache = Caffeine.newBuilder()
? ? ? ? ? ? .expireAfterWrite(1, TimeUnit.SECONDS)
? ? ? ? ? ? // 可以指定調(diào)度程序來(lái)及時(shí)刪除過(guò)期緩存項(xiàng)，而不是等待Caffeine觸發(fā)定期維護(hù)
? ? ? ? ? ? // 若不設(shè)置scheduler，則緩存會(huì)在下一次調(diào)用get的時(shí)候才會(huì)被動(dòng)刪除
? ? ? ? ? ? .scheduler(Scheduler.systemScheduler())
? ? ? ? ? ? .build();
? ? cache.put(1, 2);
? ? TimeUnit.MILLISECONDS.sleep(3000);
? ? System.out.println(cache.getIfPresent(1));
}

// 另外還有一個(gè)refreshAfterWrite()表示x秒后自動(dòng)刷新緩存可以配合以上的策略使用
? ? private static int num = 0;
@Test
void refreshAfterWriteTest() throws InterruptedException {
? ? LoadingCache<Object, Integer> cache = Caffeine.newBuilder()
? ? ? ? ? ? .refreshAfterWrite(1, TimeUnit.SECONDS)
? ? ? ? ? ? .build(integer -> ++num);

? ? // 獲取ID=1的值，由于緩存里還沒(méi)有，所以會(huì)自動(dòng)放入緩存
? ? System.out.println(cache.get(1));

? ? // 延遲2秒后，理論上自動(dòng)刷新緩存后取到的值是2
? ? // 但其實(shí)不是，值還是1，因?yàn)閞efreshAfterWrite并不是設(shè)置了n秒后重新獲取就會(huì)自動(dòng)刷新
? ? // 而是x秒后&&第二次調(diào)用getIfPresent的時(shí)候才會(huì)被動(dòng)刷新
? ? Thread.sleep(2000);
? ? System.out.println(cache.getIfPresent(1));// 1

? ? //此時(shí)才會(huì)刷新緩存，而第一次拿到的還是舊值
? ? System.out.println(cache.getIfPresent(1));// 2
}