性爱有声小说在线收听,殿上欢

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案

阿里二面：怎么實現(xiàn)兩級緩存

??JSR107??定義了緩存使用規(guī)范，spring中提供了基于這個規(guī)范的接口，所以我們可以直接使用spring中的接口進行??Caffeine??和??Redis??兩級緩存的整合改造
在分布式環(huán)境下，如果一臺主機的本地緩存進行修改，需要通知其他主機修改本地緩存，解決分布式環(huán)境下本地緩存一致性問題

好了，在明確了需要的改進問題后，下面我們開始正式修改。

改造

在上篇文章的v3版本中，我們使用自定義注解的方式實現(xiàn)了兩級緩存通過一個注解管理的功能。本文我們換一種方式，直接通過擴展spring提供的接口來實現(xiàn)這個功能，在進行整合之前，我們需要簡單了解一下JSR107緩存規(guī)范。

JSR107 規(guī)范

在JSR107?緩存規(guī)范中定義了5個核心接口，分別是CachingProvider,CacheManager,Cache, Entry和Expiry?，參考下面這張圖，可以看到除了Entry和Expiry以外，從上到下都是一對多的包含關(guān)系。

從上面這張圖我們可以看出，一個應用可以創(chuàng)建并管理多個CachingProvider，同樣一個CachingProvider也可以管理多個CacheManager，緩存管理器CacheManager中則維護了多個Cache。

Cache是一個類似Map的數(shù)據(jù)結(jié)構(gòu)，Entry就是其中存儲的每一個key-value數(shù)據(jù)對，并且每個Entry都有一個過期時間Expiry。而我們在使用spring集成第三方的緩存時，只需要實現(xiàn)Cache和CacheManager這兩個接口就可以了，下面分別具體來看一下。

Cache

spring中的Cache接口規(guī)范了緩存組件的定義，包含了緩存的各種操作，實現(xiàn)具體緩存操作的管理。例如我們熟悉的RedisCache、EhCacheCache等，都實現(xiàn)了這個接口。

在Cache接口中，定義了get、put、evict、clear等方法，分別對應緩存的存入、取出、刪除、清空操作。不過我們這里不直接使用Cache接口，上面這張圖中的AbstractValueAdaptingCache是一個抽象類，它已經(jīng)實現(xiàn)了Cache接口，是spring在Cache接口的基礎(chǔ)上幫助我們進行了一層封裝，所以我們直接繼承這個類就可以。

繼承AbstractValueAdaptingCache抽象類后，除了創(chuàng)建Cache的構(gòu)造方法外，還需要實現(xiàn)下面的幾個方法：

// 在緩存中實際執(zhí)行查找的操作，父類的get()方法會調(diào)用這個方法
protected abstract Object lookup(Object key);

// 通過key獲取緩存值，如果沒有找到，會調(diào)用valueLoader的call()方法
public  T get(Object key, Callable valueLoader);

// 將數(shù)據(jù)放入緩存中
public void put(Object key, Object value);

// 刪除緩存
public void evict(Object key);

// 清空緩存中所有數(shù)據(jù)
public void clear();

// 獲取緩存名稱，一般在CacheManager創(chuàng)建時指定
String getName();

// 獲取實際使用的緩存
Object getNativeCache();

因為要整合RedisTemplate和Caffeine的Cache，所以這些都需要在緩存的構(gòu)造方法中傳入，除此之外構(gòu)造方法中還需要再傳出緩存名稱cacheName，以及在配置文件中實際配置的一些緩存參數(shù)。先看一下構(gòu)造方法的實現(xiàn)：

public class DoubleCache extends AbstractValueAdaptingCache {
    private String cacheName;
    private RedisTemplate redisTemplate;
    private Cache caffeineCache;
    private DoubleCacheConfig doubleCacheConfig;

    protected DoubleCache(boolean allowNullValues) {
        super(allowNullValues);
    }

    public DoubleCache(String cacheName,RedisTemplate redisTemplate,
                       Cache caffeineCache,
                       DoubleCacheConfig doubleCacheConfig){
        super(doubleCacheConfig.getAllowNull());
        this.cacheName=cacheName;
        this.redisTemplate=redisTemplate;
        this.caffeineCache=caffeineCache;
        this.doubleCacheConfig=doubleCacheConfig;
    }
    //...
}

抽象父類的構(gòu)造方法中只有一個boolean類型的參數(shù)allowNullValues，表示是否允許緩存對象為null。除此之外，AbstractValueAdaptingCache中還定義了兩個包裝方法來配合這個參數(shù)進行使用，分別是toStoreValue和fromStoreValue，特殊用途是用于在緩存null對象時進行包裝、以及在獲取時進行解析并返回。

我們之后會在CacheManager中調(diào)用后面這個自己實現(xiàn)的構(gòu)造方法，來實例化Cache對象，參數(shù)中DoubleCacheConfig是使用@ConfigurationProperties讀取的yml配置文件封裝的數(shù)據(jù)對象，會在后面使用。

當一個方法添加了@Cacheable注解時，執(zhí)行時會先調(diào)用父類AbstractValueAdaptingCache中的get(key)方法，它會再調(diào)用我們自己實現(xiàn)的lookup方法。在實際執(zhí)行查找操作的lookup方法中，我們的邏輯仍然是先查找Caffeine、沒有找到時再查找Redis：

@Override
protected Object lookup(Object key) {
    // 先從caffeine中查找
    Object obj = caffeineCache.getIfPresent(key);
    if (Objects.nonNull(obj)){
        log.info("get data from caffeine");
        return obj;
    }

    //再從redis中查找
    String redisKey=this.name+":"+ key;
    obj = redisTemplate.opsForValue().get(redisKey);
    if (Objects.nonNull(obj)){
        log.info("get data from redis");
        caffeineCache.put(key,obj);
    }
    return obj;
}

如果lookup方法的返回結(jié)果不為null，那么就會直接返回結(jié)果給調(diào)用方。如果返回為null時，就會執(zhí)行原方法，執(zhí)行完成后調(diào)用put方法，將數(shù)據(jù)放入緩存中。接下來我們實現(xiàn)put方法：

@Override
public void put(Object key, Object value) {
    if(!isAllowNullValues() && Objects.isNull(value)){
        log.error("the value NULL will not be cached");
        return;
    }

    //使用 toStoreValue(value) 包裝，解決caffeine不能存null的問題
    caffeineCache.put(key,toStoreValue(value));

    // null對象只存在caffeine中一份就夠了，不用存redis了
    if (Objects.isNull(value))
        return;

    String redisKey=this.cacheName +":"+ key;
    Optional expireOpt = Optional.ofNullable(doubleCacheConfig)
            .map(DoubleCacheConfig::getRedisExpire);
    if (expireOpt.isPresent()){
        redisTemplate.opsForValue().set(redisKey,toStoreValue(value),
                expireOpt.get(), TimeUnit.SECONDS);
    }else{
        redisTemplate.opsForValue().set(redisKey,toStoreValue(value));
    }
}

上面我們對于是否允許緩存空對象進行了判斷，能夠緩存空對象的好處之一就是可以避免緩存穿透。需要注意的是，Caffeine中是不能直接緩存null的，因此可以使用父類提供的toStoreValue()方法，將它包裝成一個NullValue類型。在取出對象時，如果是NullValue，也不用我們自己再去調(diào)用fromStoreValue()將這個包裝類型還原，父類的get方法中已經(jīng)幫我們做好了。

另外，上面在put方法中緩存空對象時，只在Caffeine緩存中一份即可，可以不用在Redis中再存一份。

緩存的刪除方法evict()和清空方法clear()的實現(xiàn)就比較簡單了，直接刪除一跳或全部數(shù)據(jù)即可：

@Override
public void evict(Object key) {
    redisTemplate.delete(this.cacheName +":"+ key);
    caffeineCache.invalidate(key);
}

@Override
public void clear() {
    Set

新聞中心

改造

JSR107 規(guī)范

Cache

CacheManager

配置&使用

分布式環(huán)境改造

定義消息體

Redis消息配置

其他資訊