裝飾模式、泛型、序列化重構Caffeine解決緩存不一致的問題

来源:https://www.cnblogs.com/huanongying/archive/2022/09/22/16717718.html
-Advertisement-
Play Games

一、前言 Caffeine是一個高性能的 Java 緩存庫,底層數據存儲採用ConcurrentHashMap 優點:因為Caffeine面向JDK8,在jdk8中ConcurrentHashMap增加了紅黑樹,在hash衝突嚴重時也能有良好的讀性能。多線程環境中,不同的key可以併發寫,相同的ke ...


一、前言

Caffeine是一個高性能的 Java 緩存庫,底層數據存儲採用ConcurrentHashMap

  • 優點:因為Caffeine面向JDK8,在jdk8中ConcurrentHashMap增加了紅黑樹,在hash衝突嚴重時也能有良好的讀性能。多線程環境中,不同的key可以併發寫,相同的key會加鎖,天然的解決了緩存擊穿問題和緩存雪崩問題。

  • 缺點:因為底層數據結構是ConcurrentHashMap,所有不能作為分散式緩存,同時如果使用不當,會帶來數據不一致的問題
    本文主要內容是探討Caffeine使用不當時,數據一致性安全問題

二、問題發生場景

如下圖所示,問題的根源在於A能直接拿到緩存地址的引用,然後通過引用就能隨意修改引用指向的緩存對象,要解決這個問題,可以在步驟三這裡,將緩存對象深拷貝後的副本的引用返回給客戶端,這樣客戶端對緩存的任何操作,改變的只是副本,緩存本身只能由維護者來更新

三、如何進行對象的深拷貝

實現方式:

  1. 緩存實體類本身封裝成不可變類對象,類和屬性全部用final修飾,不提供能改變屬性的方法,屬性的值只能在對象創建過程中設置
  2. 緩存獲取API返回緩存實體後,重新創建一個新對象,對於基本類型的屬性可以用set方法簡單設置,註意對象類型的屬性每一層都要重新創建,特繁瑣,然後set,稍不小心就會出現淺拷貝問題,所有這裡要不建議用BeanUtils等工具類
  3. 使用Jackson將緩存對象先系列化為Json字元串,然後將Json字元串反序列化為對象,這裡一定能得到一個安全的深拷貝對象

因為我們的項目中已經在大量使用Caffeine,方案1和2需要對大量的實體類和緩存獲取介面進行大量的改造,工作量巨大,後面採用方案3

四、怎麼獲取泛型T的Type

後面需要使用Jackson對泛型V進行反序列化,需要用到泛型V的Type屬性,如果是普通對象用class,比如User.class,這裡只有泛型無法知道class,之所以採用泛型,是因為緩存是面向任意數據類型的,定義泛型是為了更強的通用性,下麵是獲取泛型T的Typede代碼,參考了Jackson的TypeReference類的源碼

//拷貝了的緩存對象,原來緩存操作類的裝飾者
public abstract class CopiedCache<K, V> implements Cache<K, V>, LoadingCache<K, V> {

	/**
     * 被裝飾的緩存實例
     */
    private final Cache<K, V> cache;

    /**
     * 泛型V的類型,反序列化時會用到
     */
    protected final Type vType;

    public CopiedCache(Cache<K, V> cache) {
        this.cache = cache;
        //獲取泛型V的類型,參考Jackson的TypeReference類的源碼
        Type superClass = getClass().getGenericSuperclass();
        if (superClass instanceof Class<?>) { // sanity check, should never happen
            throw new IllegalArgumentException("Internal error: TypeReference constructed without actual type information");
        }
        //獲取泛型參數列表,下標0表示K,1表示V,後面的反序列化只用到了V的Type
        vType = ((ParameterizedType) superClass).getActualTypeArguments()[1];
        
        /**
         * json字元串反序列化對象:
         * ObjectMapper om = new ObjectMapper(new JsonFactory());
         *
         * 普通對象
         * OM.readValue(json, XXX.class);
         *
         * 泛型對象
         * OM.readValue(json, OM.getTypeFactory().constructType(vType));
         */
    }
    
    /**
     *其餘部分省略,這裡主要說明如何獲取泛型的class
     * 
     * 1.這個類最初設計時不是抽象類,創建對象的代碼:
     *      LoadingCache<Long, UserDetails> userCache = new CopiedCache<>(cache);
     * 如果這麼做,構造方法中使用類似TypeReference的方法,無法獲取泛型V的class
     *
     * 2.經測試分析,在泛型類中,只能通過子類來獲取泛型類型,為了強制使用此類,CopiedCache設計成了泛型,初始化時可以用
     * 匿名內部類來代替子類,創建該類對象的代碼:
     *      LoadingCache<Long, UserDetails> userCache = new CopiedCache<Long, UserDetails>(cache) {};
     *
     */
    
}

五、裝飾模式

使用裝飾模式是為了對Caffeine中緩存查詢方法做增強處理(主要是對緩存對象進行深拷貝),對目標類的某些方法進行增強的實現方式:

  1. 直接在目標類的方法上修改,這裡Caffeine是三方庫,根本沒法改,硬要改的話,只能是改它的源代碼重新生成jar包,這個包會成為野包,個人感覺此法不妥,這麼做了面向對象的開閉原則(對擴展開放,對修改關閉)
  2. Spring AOP,這樣額外引入了Spring框架,而且Caffeine中涉及查詢方法太多,可能需要定義特別多的切點,比較麻煩
  3. 裝飾模式,Cache和LoadingCache是Caffeine中的緩存操作介面,充當被裝飾者的角色,CopiedCache充當裝飾者,CopiedCache持有被裝飾者的引用,對象創建時需傳入被裝飾者引用,同時實現了被裝飾者的介面。通過繼承重寫需要增強的方法,對於不需要增強的方法,直接委托給被裝飾者調用,最後可以依據里氏替換原則,只需將緩存操作介面的引用指向CopiedCache,原來緩存查詢相關的代碼不用作任何改變,極大降低耦合度

裝飾模式類圖:

六、代碼實現

改造前,緩存初始化及緩存查詢的實現代碼

//緩存初始化
LoadingCache<Long, UserDetails> userCache = Caffeine.newBuilder()
                .maximumSize(1024L)
                .expireAfterWrite(Duration.ofMinutes(15))
                .build(delegate::getUserDetails);

//這裡userDetails就是緩存,客戶端拿到後執行userDetails.setXXX,將會破壞緩存一致性
UserDetails userDetails = userCache.get(userId);

改造後,緩存初始化及緩存查詢的實現代碼

//緩存初始化
LoadingCache<Long, UserDetails> cache = Caffeine.newBuilder()
                .maximumSize(1024L)
                .expireAfterWrite(Duration.ofMinutes(15))
                .build(delegate::getUserDetails);
//對原生的緩存類進行裝飾,註意後面的小括弧,CopiedCache是抽象類,這裡創建了匿名子類,可以將泛型類型傳給父類         
LoadingCache<Long, UserDetails> userCache = new CopiedCache<Long, UserDetails>(cache) {};

//這裡userDetails是緩存的拷貝,類似的調用邏輯不需要做任何的修改,自動實現了增強效果
UserDetails userDetails = userCache.get(userId);

裝飾類的代碼

@ThreadSafe
public abstract class CopiedCache<K, V> implements Cache<K, V>, LoadingCache<K, V> {

    /**
     * 被裝飾的緩存實例
     */
    private final Cache<K, V> cache;

    /**
     * 泛型V的類型,反序列化時會用到
     */
    protected final Type vType;

    public CopiedCache(Cache<K, V> cache) {
        this.cache = cache;
        //獲取泛型V的類型
        Type superClass = getClass().getGenericSuperclass();
        if (superClass instanceof Class<?>) { // sanity check, should never happen
            throw new IllegalArgumentException("Internal error: TypeReference constructed without actual type information");
        }
        vType = ((ParameterizedType) superClass).getActualTypeArguments()[1];
    }

    @Nullable
    @Override
    public V get(@Nonnull K key) {
    	//委托裝飾類去調用
        V v = (V) ((LoadingCache) cache).get(key);
        //下麵的copy方法就是增強的邏輯
        return copy(v);
    }

    @Nonnull
    @Override
    public Map<K, V> getAll(@Nonnull Iterable<? extends K> keys) {
        //委托給裝飾類去調用
        Map<K, V> map = ((LoadingCache) cache).getAll(keys);
        return copyMap(map);
    }
    
    @Override
    public void put(@Nonnull K key, @Nonnull V value) {
    	//不需要增強,直接委托給被裝飾類來調用
        cache.put(key, value);
    }

    /**
     * 普通對象的深拷貝,實現方式:序列化+反序列化
     * @param v
     * @return V
     */
    private V copy(V v) {
        return JSON.parse(JSON.stringify(v), vType);
    }
    
    //這裡省略了其他方法...

    /**
     * Map對象的深拷貝,實現方式:序列化+反序列化
     * @param map
     * @return java.util.Map<K,V>
     */
    private Map<K,V> copyMap(Map<K,V> map) {
        Map copiedMap = new LinkedHashMap();
        Maps.each(map, (k, v) -> copiedMap.put(k, copy(v)));
        return copiedMap;
    }
}

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 1. 安裝sass 較新的版本不需要配置sass-loader等一系列插件,安裝即用。 npm install --save-dev sass 2. 編寫App.tsx中的基本DOM 更改app.css為app.scss,並刪除其中全部內容 使用如下代碼替換app.tsx中的內容 import ". ...
  • 1 微信小程式原生推拉流組件功能簡介 本文將介紹如何使用微信小程式原生推拉流組件 <live-pusher> 和 <live-player> 進行推拉流,快速實現一個簡單的實時音視頻通話。 由於微信小程式原生推拉流組件使用起來比較複雜,推薦開發者使用即構封裝的音視頻SDK <zego-push> 和 ...
  • 1.HTTP和HTTPS的基本概念 http:是一個客戶端和服務端請求和應答的標準(TCP),用於從www伺服器傳輸超文本到本地瀏覽器的超文本傳輸協議。 https:是以安全為目標的HTTP通道,即HTTP下加入SSL層進行加密。其作用是:建立一個信息安全通道,確保數據的傳輸,確保網站的真實性。 補 ...
  • 原因 項目每次打包後都需要改動項目版本號,這個改動每次都需要在package.json中修改version,比較麻煩,到底有沒有一種打包後版本號自加的辦法。 方案 版本號自加其實可以使用fs修改文件來實現的。 具體思路是:在執行打包命令npm run build時,同時執行一段js代碼,該代碼通過調 ...
  • 在我們基於UniApp的H5項目中,需要生成一些二維碼進行展示,另外也需要讓用戶可以掃碼進行一定的快捷操作,本篇隨筆介紹一下二維碼的生成處理和基於H5的掃碼進行操作。二維碼的生成,使用了JS文件weapp-qrcode.js進行處理,而二維碼掃碼則是基於一個第三方組件的方式進行支持的,最後通過統一入... ...
  • 一.起步 1.1 配置uni-app開發環境 什麼是uni-app,就是基於vue的一個開發框架,可以將我們寫的一套代碼,同時發佈到ios、安卓、小程式等多個平臺 ==官方推薦使用Hbuilderx來寫uni-app項目== 下載之後可以將預設改為vscode 進入hbuilder插件市場下載scs ...
  • 蒼穹之邊,浩瀚之摯,眰恦之美; 悟心悟性,善始善終,惟善惟道! —— 朝槿《朝槿兮年說》 寫在開頭 在併發編程領域,有兩大核心問題:一個是互斥,即同一時刻只允許一個線程訪問共用資源;另一個是同步,即線程之間如何通信、協作。主要原因是,對於多線程實現實現併發,一直以來,多線程都存在2個問題: 線程之間 ...
  • 蒼穹之邊,浩瀚之摯,眰恦之美; 悟心悟性,善始善終,惟善惟道! —— 朝槿《朝槿兮年說》 寫在開頭 在併發編程領域,有兩大核心問題:一個是互斥,即同一時刻只允許一個線程訪問共用資源;另一個是同步,即線程之間如何通信、協作。主要原因是,對於多線程實現實現併發,一直以來,多線程都存在2個問題: 線程之間 ...
一周排行
    -Advertisement-
    Play Games
  • 記錄一下Winform程式打包過程 參考文章:VS2017 WinFrom打包設置與教程 下載 Visual Studio Installer 拓展插件 從VS2017開始VS已預設不再集成Installer拓展,所以需要手動下載安裝,在 工具 - 插件和更新 裡面的插件商店裡面搜索"install ...
  • 先下載一個gif圖片,這裡提供一個gif圖片示例 線上GIF圖片幀拆分工具 - UU線上工具 (uutool.cn) 使用這個網站將gif切成單張圖片 創建一個Avalonia MVVM的項目,將圖片copy進去 在項目文件中添加一下代碼: <ItemGroup> <None Update="gif ...
  • 1 簡介 Dapr是一個可移植的、事件驅動的運行時,它使任何開發人員能夠輕鬆構建出彈性的、無狀態和有狀態的應用程式,並可運行在雲平臺或邊緣計算中,它同時也支持多種編程語言和開發框架。Dapr支持的語言很多,包括C++/Go/Java/JavaScript/Python/Rust/.NET/PHP等。 ...
  • 作者:大眼睛圖圖 鏈接:https://juejin.cn/post/7156483709338648613 前言 還有誰?剛上三天班就被公司公司的工作不適合我,叫我先提升一下。 後面我也向公司那邊討要了一個說法,我只能說他們那邊的說辭讓我有些不服氣。 現在之所以把這件事在掘金上記錄一下,一是記錄一 ...
  • 雲原生下的流水線是通過啟動容器來運行具體的功能步驟,每次運行流水線可能會被調度到不同的計算節點上。這會導致一個問題:容器運行完是不會保存數據的,每當流水線重新運行時,又會重新拉取代碼、編譯代碼、下載依賴包等等。在雲原生場景下,不存在本地宿主機編譯代碼、構建鏡像時緩存的作用,大大延長了流水線運行時間,... ...
  • 本文介紹基於Python語言中TensorFlow的tf.estimator介面,實現深度學習神經網路回歸的具體方法。 () 1 寫在前面 1. 本文介紹的是基於TensorFlow tf.estimator介面的深度學習網路,而非TensorFlow 2.0中常用的Keras介面;關於Keras接 ...
  • 基礎 我是在ruoyi-vue已經安裝了mybatis-plus的基礎上進行的修改 關於SQLite SQLite 是一個軟體庫,實現了自給自足的、無伺服器的、零配置的、事務性的 SQL 資料庫引擎。 SQLite主頁:https://www.sqlite.org/index.html 1. pom ...
  • 1. 服務監控三要素^1 服務監控需要滿足的三要素分別如下: 日誌監控 指標監控 請求鏈路追蹤 服務監控只要能滿足這三個要素,基本就能實現我們想要的監控效果。 1.1.主流APM系統^1 APM 系統(Application Performance Management,即應用性能管理)是對企業的應 ...
  • 雙重檢查鎖定與延遲初始化 在 java 程式中,有時候可能需要推遲一些高開銷的對象初始化操作,並且只有在使用這些對象時才進行初始化。此時程式員可能會採用延遲初始化。但要正確實現線程安全的延遲初始化需要一些技巧,否則很容易出現問題。比如,下麵是非線程安全的延遲初始化對象的示例代碼: COPYpubli ...
  • 顧名思義單調棧就是具有單調性的棧 ==常見模型:找出每個數左邊離它最近的比它大/小的數== 【演算法】 int stk[N],tt = 0; // 棧中存數據 for (int i = 1; i <= n; i ++){ int x; cin >> x; while (tt && stk[tt] >= ...