裝飾模式、泛型、序列化重構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
  • Timer是什麼 Timer 是一種用於創建定期粒度行為的機制。 與標準的 .NET System.Threading.Timer 類相似,Orleans 的 Timer 允許在一段時間後執行特定的操作,或者在特定的時間間隔內重覆執行操作。 它在分散式系統中具有重要作用,特別是在處理需要周期性執行的 ...
  • 前言 相信很多做WPF開發的小伙伴都遇到過表格類的需求,雖然現有的Grid控制項也能實現,但是使用起來的體驗感並不好,比如要實現一個Excel中的表格效果,估計你能想到的第一個方法就是套Border控制項,用這種方法你需要控制每個Border的邊框,並且在一堆Bordr中找到Grid.Row,Grid. ...
  • .NET C#程式啟動閃退,目錄導致的問題 這是第2次踩這個坑了,很小的編程細節,容易忽略,所以寫個博客,分享給大家。 1.第一次坑:是windows 系統把程式運行成服務,找不到配置文件,原因是以服務運行它的工作目錄是在C:\Windows\System32 2.本次坑:WPF桌面程式通過註冊表設 ...
  • 在分散式系統中,數據的持久化是至關重要的一環。 Orleans 7 引入了強大的持久化功能,使得在分散式環境下管理數據變得更加輕鬆和可靠。 本文將介紹什麼是 Orleans 7 的持久化,如何設置它以及相應的代碼示例。 什麼是 Orleans 7 的持久化? Orleans 7 的持久化是指將 Or ...
  • 前言 .NET Feature Management 是一個用於管理應用程式功能的庫,它可以幫助開發人員在應用程式中輕鬆地添加、移除和管理功能。使用 Feature Management,開發人員可以根據不同用戶、環境或其他條件來動態地控制應用程式中的功能。這使得開發人員可以更靈活地管理應用程式的功 ...
  • 在 WPF 應用程式中,拖放操作是實現用戶交互的重要組成部分。通過拖放操作,用戶可以輕鬆地將數據從一個位置移動到另一個位置,或者將控制項從一個容器移動到另一個容器。然而,WPF 中預設的拖放操作可能並不是那麼好用。為瞭解決這個問題,我們可以自定義一個 Panel 來實現更簡單的拖拽操作。 自定義 Pa ...
  • 在實際使用中,由於涉及到不同編程語言之間互相調用,導致C++ 中的OpenCV與C#中的OpenCvSharp 圖像數據在不同編程語言之間難以有效傳遞。在本文中我們將結合OpenCvSharp源碼實現原理,探究兩種數據之間的通信方式。 ...
  • 一、前言 這是一篇搭建許可權管理系統的系列文章。 隨著網路的發展,信息安全對應任何企業來說都越發的重要,而本系列文章將和大家一起一步一步搭建一個全新的許可權管理系統。 說明:由於搭建一個全新的項目過於繁瑣,所有作者將挑選核心代碼和核心思路進行分享。 二、技術選擇 三、開始設計 1、自主搭建vue前端和. ...
  • Csharper中的表達式樹 這節課來瞭解一下表示式樹是什麼? 在C#中,表達式樹是一種數據結構,它可以表示一些代碼塊,如Lambda表達式或查詢表達式。表達式樹使你能夠查看和操作數據,就像你可以查看和操作代碼一樣。它們通常用於創建動態查詢和解析表達式。 一、認識表達式樹 為什麼要這樣說?它和委托有 ...
  • 在使用Django等框架來操作MySQL時,實際上底層還是通過Python來操作的,首先需要安裝一個驅動程式,在Python3中,驅動程式有多種選擇,比如有pymysql以及mysqlclient等。使用pip命令安裝mysqlclient失敗應如何解決? 安裝的python版本說明 機器同時安裝了 ...