Guava自動(dòng)加載緩存LoadingCache使用實(shí)戰(zhàn)詳解

更新時(shí)間：2023年12月22日 09:05:50 作者：S

這篇文章主要為大家介紹了Guava自動(dòng)加載緩存LoadingCache使用實(shí)戰(zhàn)詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪

第1章：引言

今天我們來(lái)聊聊緩存。在Java世界里，高效的緩存機(jī)制對(duì)于提升應(yīng)用性能、降低數(shù)據(jù)庫(kù)負(fù)擔(dān)至關(guān)重要。想象一下，如果每次數(shù)據(jù)請(qǐng)求都要跑到數(shù)據(jù)庫(kù)里取，那服務(wù)器豈不是要累趴了？這時(shí)候，緩存就顯得尤為重要了。

那么，怎么實(shí)現(xiàn)一個(gè)既高效又好用的緩存呢？別急，咱們今天的主角——Guava的LoadingCache就是這樣一個(gè)神器。LoadingCache，顧名思義，就是能夠自動(dòng)加載緩存的工具。它不僅能自動(dòng)載入數(shù)據(jù)，還能按需刷新，簡(jiǎn)直是懶人救星！接下來(lái)，小黑就帶大家一起深入探究Guava的這個(gè)強(qiáng)大功能。

第2章：Guava簡(jiǎn)介

Guava是Google開(kāi)源的一款Java庫(kù)，提供了一堆好用的工具類，從集合操作、緩存機(jī)制到函數(shù)式編程，應(yīng)有盡有。使用Guava，咱們可以寫出更簡(jiǎn)潔、更高效、更優(yōu)雅的Java代碼。今天，小黑重點(diǎn)要聊的是Guava中的緩存部分。

首先，讓我們來(lái)看看Guava緩存的一個(gè)基本概念：LoadingCache。LoadingCache是Guava中一個(gè)提供自動(dòng)加載功能的緩存接口。它允許咱們通過(guò)一個(gè)CacheLoader來(lái)指定如何加載緩存。這就意味著，當(dāng)咱們嘗試從緩存中讀取一個(gè)值，如果這個(gè)值不存在，LoadingCache就會(huì)自動(dòng)調(diào)用預(yù)定義的加載機(jī)制去獲取數(shù)據(jù)，然后將其加入到緩存中，非常智能。

來(lái)，小黑先給大家展示一個(gè)簡(jiǎn)單的LoadingCache創(chuàng)建示例：

import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;
public class LoadingCacheExample {
    public static void main(String[] args) {
        LoadingCache<String, String> cache = CacheBuilder.newBuilder()
                .maximumSize(100) // 最大緩存項(xiàng)數(shù)
                .build(new CacheLoader<String, String>() {
                    @Override
                    public String load(String key) throws Exception {
                        return "Hello, " + key; // 定義緩存加載的方式
                    }
                });
        System.out.println(cache.getUnchecked("Guava")); // 輸出：Hello, Guava
    }
}

在這個(gè)例子里，小黑創(chuàng)建了一個(gè)簡(jiǎn)單的LoadingCache實(shí)例。當(dāng)咱們嘗試通過(guò)getUnchecked方法獲取一個(gè)緩存項(xiàng)時(shí)，如果這個(gè)項(xiàng)不存在，CacheLoader會(huì)自動(dòng)加載一個(gè)新值。在這里，它就是簡(jiǎn)單地返回一個(gè)字符串。

第3章：LoadingCache基礎(chǔ)

什么是LoadingCache呢？簡(jiǎn)單來(lái)說(shuō)，它是Guava提供的一個(gè)緩存接口，能夠自動(dòng)加載緩存。當(dāng)你嘗試從緩存中讀取一個(gè)值時(shí)，如果這個(gè)值不存在，LoadingCache會(huì)自動(dòng)調(diào)用預(yù)定義的加載邏輯來(lái)獲取這個(gè)值，然后存儲(chǔ)到緩存中。這個(gè)過(guò)程完全自動(dòng)化，省去了很多手動(dòng)管理緩存的麻煩。

那么，LoadingCache的核心特性是什么呢？首先，它提供了自動(dòng)的緩存加載機(jī)制，這意味著咱們不需要自己去寫代碼判斷緩存是否存在或者過(guò)期。其次，它支持多種緩存過(guò)期策略，比如基于時(shí)間的過(guò)期、大小限制等，確保緩存的有效性。再者，LoadingCache還提供了緩存統(tǒng)計(jì)和監(jiān)聽(tīng)的功能，方便咱們監(jiān)控和調(diào)優(yōu)緩存的使用。

來(lái)，讓小黑用一個(gè)例子來(lái)展示一下LoadingCache的基本用法：

import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;
import java.util.concurrent.ExecutionException;
public class LoadingCacheDemo {
    public static void main(String[] args) throws ExecutionException {
        // 創(chuàng)建一個(gè)CacheLoader
        CacheLoader<String, String> loader = new CacheLoader<String, String>() {
            @Override
            public String load(String key) {
                return key.toUpperCase(); // 模擬加載數(shù)據(jù)的過(guò)程
            }
        };
        // 使用CacheBuilder構(gòu)建一個(gè)LoadingCache
        LoadingCache<String, String> cache = CacheBuilder.newBuilder()
                .maximumSize(100) // 設(shè)置最大緩存數(shù)為100
                .build(loader);
        // 使用緩存
        System.out.println(cache.get("hello")); // 輸出: HELLO
        System.out.println(cache.get("guava")); // 輸出: GUAVA
    }
}

在這個(gè)例子中，小黑創(chuàng)建了一個(gè)CacheLoader來(lái)定義加載數(shù)據(jù)的邏輯，這里就是簡(jiǎn)單地將字符串轉(zhuǎn)換為大寫。然后，使用CacheBuilder來(lái)構(gòu)建一個(gè)LoadingCache實(shí)例，設(shè)置了最大緩存數(shù)為100。當(dāng)調(diào)用get方法時(shí)，如果緩存中不存在對(duì)應(yīng)的鍵值，LoadingCache會(huì)自動(dòng)調(diào)用CacheLoader來(lái)加載數(shù)據(jù)，并將結(jié)果存入緩存。

第4章：創(chuàng)建LoadingCache

創(chuàng)建一個(gè)LoadingCache最關(guān)鍵的就是定義一個(gè)CacheLoader。這個(gè)CacheLoader指定了如何加載緩存。它就像是個(gè)工廠，當(dāng)咱們請(qǐng)求的數(shù)據(jù)在緩存中不存在時(shí)，它就會(huì)生產(chǎn)出所需的數(shù)據(jù)。

那么，怎么定義這個(gè)CacheLoader呢？讓小黑給你看個(gè)例子：

import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;
public class UserCache {
    // 假設(shè)有一個(gè)用戶服務(wù)，用于獲取用戶信息
    private static UserService userService = new UserService();
    public static void main(String[] args) throws Exception {
        // 創(chuàng)建CacheLoader
        CacheLoader<String, User> loader = new CacheLoader<String, User>() {
            @Override
            public User load(String userId) {
                // 從用戶服務(wù)獲取用戶信息
                return userService.getUserById(userId);
            }
        };
        // 創(chuàng)建LoadingCache
        LoadingCache<String, User> cache = CacheBuilder.newBuilder()
                .maximumSize(100) // 設(shè)置最大緩存數(shù)
                .build(loader);
        // 使用緩存獲取用戶信息
        User user = cache.get("123"); // 如果緩存中沒(méi)有，會(huì)調(diào)用load方法加載數(shù)據(jù)
        System.out.println(user);
    }
}

在這個(gè)例子中，小黑創(chuàng)建了一個(gè)CacheLoader來(lái)從用戶服務(wù)中獲取用戶信息。然后，使用CacheBuilder來(lái)構(gòu)建一個(gè)LoadingCache，并設(shè)置了最大緩存數(shù)量為100。當(dāng)咱們通過(guò)get方法獲取用戶信息時(shí)，如果緩存中沒(méi)有相應(yīng)的數(shù)據(jù)，CacheLoader就會(huì)自動(dòng)加載數(shù)據(jù)。

這個(gè)過(guò)程聽(tīng)起來(lái)是不是很神奇？實(shí)際上，這背后是一種非常有效的數(shù)據(jù)管理策略。通過(guò)這種方式，咱們可以減少對(duì)數(shù)據(jù)庫(kù)或遠(yuǎn)程服務(wù)的直接訪問(wèn)，提高了應(yīng)用的響應(yīng)速度和效率。

第5章：LoadingCache的高級(jí)特性

自動(dòng)加載和刷新機(jī)制

首先，LoadingCache的一個(gè)很棒的功能就是自動(dòng)加載和刷新。這意味著當(dāng)咱們請(qǐng)求某個(gè)鍵的值時(shí)，如果這個(gè)值不存在或者需要刷新，LoadingCache會(huì)自動(dòng)調(diào)用CacheLoader去加載或刷新數(shù)據(jù)。

import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;
import java.util.concurrent.TimeUnit;
public class AutoRefreshCache {
    public static void main(String[] args) throws Exception {
        LoadingCache<String, String> cache = CacheBuilder.newBuilder()
                .refreshAfterWrite(1, TimeUnit.MINUTES) // 設(shè)置1分鐘后刷新
                .build(new CacheLoader<String, String>() {
                    @Override
                    public String load(String key) {
                        return fetchDataFromDatabase(key); // 模擬從數(shù)據(jù)庫(kù)加載數(shù)據(jù)
                    }
                });
        // 使用緩存
        System.out.println(cache.get("key1")); // 第一次加載
        // 1分鐘后，嘗試再次獲取，將觸發(fā)刷新操作
    }
    private static String fetchDataFromDatabase(String key) {
        // 模擬數(shù)據(jù)庫(kù)操作
        return "Data for " + key;
    }
}

在這個(gè)例子中，咱們?cè)O(shè)置了refreshAfterWrite，這意味著每當(dāng)一個(gè)鍵值對(duì)寫入一分鐘后，它就會(huì)被自動(dòng)刷新。

處理異常值

有時(shí)候，加載數(shù)據(jù)可能會(huì)出現(xiàn)異常。LoadingCache提供了優(yōu)雅的處理異常的機(jī)制。

public class ExceptionHandlingCache {
    public static void main(String[] args) throws Exception {
        LoadingCache<String, String> cache = CacheBuilder.newBuilder()
                .build(new CacheLoader<String, String>() {
                    @Override
                    public String load(String key) throws Exception {
                        if ("errorKey".equals(key)) {
                            throw new Exception("Loading error");
                        }
                        return "Data for " + key;
                    }
                });

        try {
            System.out.println(cache.get("errorKey"));
        } catch (Exception e) {
            System.out.println("Error during cache load: " + e.getMessage());
        }
    }
}

這里，如果加載過(guò)程中出現(xiàn)異常，咱們可以捕獲這個(gè)異常，并做適當(dāng)?shù)奶幚怼?/p>

統(tǒng)計(jì)和監(jiān)聽(tīng)功能

LoadingCache還提供了緩存統(tǒng)計(jì)和監(jiān)聽(tīng)功能，這對(duì)于監(jiān)控緩存性能和行為非常有用。

import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;
import com.google.common.cache.RemovalListener;
import com.google.common.cache.RemovalNotification;
public class CacheMonitoring {
    public static void main(String[] args) throws Exception {
        RemovalListener<String, String> removalListener = new RemovalListener<String, String>() {
            @Override
            public void onRemoval(RemovalNotification<String, String> notification) {
                System.out.println("Removed: " + notification.getKey() + ", Cause: " + notification.getCause());
            }
        };
        LoadingCache<String, String> cache = CacheBuilder.newBuilder()
                .maximumSize(100)
                .removalListener(removalListener)
                .build(new CacheLoader<String, String>() {
                    // ...
                });
        // 使用緩存
        // ...
    }
}

在這個(gè)例子中，小黑設(shè)置了一個(gè)RemovalListener，用于監(jiān)聽(tīng)緩存項(xiàng)的移除事件。

第6章：LoadingCache的最佳實(shí)踐

配置緩存大小

合理配置緩存大小非常關(guān)鍵。如果緩存太小，就會(huì)頻繁地加載數(shù)據(jù)，影響性能；如果太大，又可能消耗過(guò)多內(nèi)存。

LoadingCache<String, String> cache = CacheBuilder.newBuilder()
        .maximumSize(1000) // 設(shè)置最大緩存項(xiàng)為1000
        .build(new CacheLoader<String, String>() {
            // ...
        });

在這個(gè)例子中，小黑設(shè)置了最大緩存項(xiàng)為1000。這個(gè)值需要根據(jù)實(shí)際情況和資源限制來(lái)調(diào)整。

設(shè)置合適的過(guò)期策略

LoadingCache支持基于時(shí)間的過(guò)期策略，比如訪問(wèn)后過(guò)期和寫入后過(guò)期。

LoadingCache<String, String> cache = CacheBuilder.newBuilder()
        .expireAfterWrite(10, TimeUnit.MINUTES) // 寫入后10分鐘過(guò)期
        .expireAfterAccess(5, TimeUnit.MINUTES) // 訪問(wèn)后5分鐘過(guò)期
        .build(new CacheLoader<String, String>() {
            // ...
        });

選擇合適的過(guò)期策略可以確保緩存中的數(shù)據(jù)既不會(huì)過(guò)時(shí)，又能有效利用內(nèi)存。

異常處理策略

在加載數(shù)據(jù)時(shí)可能會(huì)遇到各種異常。咱們可以設(shè)置一個(gè)合理的異常處理策略，比如記錄日志、返回默認(rèn)值或者重新拋出異常。

LoadingCache<String, String> cache = CacheBuilder.newBuilder()
        .build(new CacheLoader<String, String>() {
            @Override
            public String load(String key) throws Exception {
                try {
                    return fetchData(key);
                } catch (Exception e) {
                    // 處理異常
                }
            }
        });

使用軟引用或弱引用

為了防止緩存占用過(guò)多內(nèi)存，可以使用軟引用或弱引用。

LoadingCache<String, String> cache = CacheBuilder.newBuilder()
        .softValues() // 使用軟引用存儲(chǔ)值
        .weakKeys() // 使用弱引用存儲(chǔ)鍵
        .build(new CacheLoader<String, String>() {
            // ...
        });

使用軟引用和弱引用可以幫助Java垃圾收集器在需要時(shí)回收緩存項(xiàng)，防止內(nèi)存泄露。

監(jiān)聽(tīng)移除通知

設(shè)置移除監(jiān)聽(tīng)器可以幫助咱們了解緩存的行為，比如為什么某個(gè)項(xiàng)被移除。

LoadingCache<String, String> cache = CacheBuilder.newBuilder()
        .removalListener(notification -> {
            // 處理移除通知
        })
        .build(new CacheLoader<String, String>() {
            // ...
        });

通過(guò)這些最佳實(shí)踐，咱們可以確保LoadingCache的高效運(yùn)行，同時(shí)避免一些常見(jiàn)的問(wèn)題。這樣，咱們的Java應(yīng)用就能更加穩(wěn)定和高效地運(yùn)行啦！

第7章：LoadingCache與Java 8的結(jié)合

好的，咱們接下來(lái)聊聊怎樣把LoadingCache和Java 8的特性結(jié)合起來(lái)，用起來(lái)更順手。

Java 8引入了很多強(qiáng)大的新特性，像Lambda表達(dá)式、Stream API等，這些都可以和LoadingCache搭配使用，讓代碼更簡(jiǎn)潔、更易讀。

使用Lambda表達(dá)式簡(jiǎn)化CacheLoader

首先，咱們可以用Lambda表達(dá)式來(lái)簡(jiǎn)化CacheLoader的創(chuàng)建。這樣代碼看起來(lái)更干凈，更直觀。

LoadingCache<String, String> cache = CacheBuilder.newBuilder()
        .build(key -> fetchDataFromDatabase(key)); // 使用Lambda表達(dá)式
private static String fetchDataFromDatabase(String key) {
    // 數(shù)據(jù)庫(kù)操作
    return "Data for " + key;
}

在這個(gè)例子里，小黑用Lambda表達(dá)式替代了傳統(tǒng)的匿名內(nèi)部類，使代碼更加簡(jiǎn)潔。

結(jié)合Stream API處理緩存數(shù)據(jù)

接下來(lái)，咱們看看如何用Java 8的Stream API來(lái)處理LoadingCache中的數(shù)據(jù)。

LoadingCache<String, User> userCache = //... 緩存初始化
List<String> userIds = //... 用戶ID列表
// 使用Stream API獲取用戶信息列表
List<User> users = userIds.stream()
        .map(userId -> userCache.getUnchecked(userId))
        .collect(Collectors.toList());

在這個(gè)例子中，小黑用Stream API來(lái)處理一系列用戶ID，然后用map方法從緩存中獲取對(duì)應(yīng)的用戶信息。

利用Optional處理緩存返回值

最后，Java 8引入的Optional也可以用來(lái)優(yōu)雅地處理可能為空的緩存返回值。

public Optional&lt;User&gt; getUser(String userId) {
    try {
        return Optional.ofNullable(userCache.get(userId));
    } catch (Exception e) {
        return Optional.empty();
    }
}

在這里，小黑用Optional包裝了緩存的返回值。這樣一來(lái)，就能優(yōu)雅地處理緩存可能返回的空值情況。

通過(guò)這些方式，結(jié)合Java 8的特性，咱們可以讓LoadingCache的使用更加高效和優(yōu)雅。這不僅提高了代碼的可讀性，還讓咱們的編程體驗(yàn)更加流暢。

實(shí)戰(zhàn)案例

小黑將通過(guò)一個(gè)具體的例子，展示如何在實(shí)際項(xiàng)目中使用LoadingCache。這個(gè)例子會(huì)模擬一個(gè)簡(jiǎn)單的場(chǎng)景，比如說(shuō)，使用LoadingCache來(lái)緩存用戶的登錄次數(shù)。

假設(shè)咱們有一個(gè)應(yīng)用，需要跟蹤用戶的登錄次數(shù)。每次用戶登錄時(shí)，程序會(huì)增加其登錄次數(shù)。為了提高性能，咱們用LoadingCache來(lái)緩存這些數(shù)據(jù)，避免每次都查詢數(shù)據(jù)庫(kù)。

首先，小黑定義了一個(gè)模擬的用戶登錄服務(wù)：

public class UserService {
    private final Map&lt;String, Integer&gt; loginCount = new ConcurrentHashMap&lt;&gt;();

    public int addLoginCount(String userId) {
        return loginCount.merge(userId, 1, Integer::sum);
    }
}

UserService userService = new UserService();

這個(gè)UserService類有一個(gè)addLoginCount方法，用于增加特定用戶的登錄次數(shù)。

接下來(lái)，小黑將展示如何使用LoadingCache來(lái)緩存登錄次數(shù)：

LoadingCache<String, Integer> loginCache = CacheBuilder.newBuilder()
        .expireAfterAccess(30, TimeUnit.MINUTES) // 設(shè)置緩存30分鐘后過(guò)期
        .build(new CacheLoader<String, Integer>() {
            @Override
            public Integer load(String userId) {
                return userService.addLoginCount(userId);
            }
        });

public void userLogin(String userId) {
    int count = loginCache.getUnchecked(userId);
    System.out.println("User " + userId + " login count: " + count);
}

在這個(gè)例子中，每當(dāng)有用戶登錄，userLogin方法就會(huì)被調(diào)用。這個(gè)方法會(huì)從loginCache中獲取用戶的登錄次數(shù)，如果緩存中沒(méi)有，CacheLoader會(huì)調(diào)用UserService的addLoginCount來(lái)獲取最新的計(jì)數(shù)，然后將其存儲(chǔ)在緩存中。

總結(jié)

通過(guò)這些章節(jié)，咱們了解了LoadingCache的基本原理和用法，包括如何創(chuàng)建和配置緩存，以及如何結(jié)合Java 8的特性來(lái)優(yōu)化代碼。LoadingCache不僅提供了自動(dòng)加載和刷新的強(qiáng)大功能，還有異常處理、緩存統(tǒng)計(jì)和監(jiān)聽(tīng)等高級(jí)特性。

實(shí)戰(zhàn)案例給咱們展示了LoadingCache在現(xiàn)實(shí)場(chǎng)景中的應(yīng)用。不管是緩存用戶信息還是統(tǒng)計(jì)數(shù)據(jù)，LoadingCache都能大大提高性能和用戶體驗(yàn)。

技術(shù)總是在不斷進(jìn)步的，學(xué)習(xí)和掌握這些工具，能讓咱們更好地適應(yīng)未來(lái)的技術(shù)挑戰(zhàn)。希望這些內(nèi)容能激發(fā)你對(duì)Guava以及Java編程的更多探索！

以上就是Guava自加載緩存LoadingCache使用實(shí)戰(zhàn)詳解的詳細(xì)內(nèi)容，更多關(guān)于Guava自加載緩存LoadingCache的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: