Redis與本地快取的結合實現

// 虛擬碼範例 Xx代表你的的業務物件 如User Goods等等
public class XxLazyCache {

    @Autowired
    private RedisTemplate<String, Xx> redisTemplate;
    
    @Autowired
    private XxService xxService;// 你的業務service
    
    /**
     * 查詢 通過查詢快取是否存在驅動快取載入 建議在前置業務保證id對應資料是絕對存在於資料庫中的
     */
    public Xx getXx(int id) {
        // 1.查詢快取裡面有沒有資料
        Xx xxCache = getXxFromCache(id);
        if(xxCache != null) {
            return xxCache;// 衛語句使程式碼更有利於閱讀
        }
        // 2.查詢資料庫獲取資料 我們假定到業務這一步，傳過來的id都在資料庫中有對應資料
        Xx xx = xxService.getXxById(id);
        // 3.設定快取、這一步相當於Redis快取懶載入，下次再查詢此id，則會走快取
        setXxFromCache(xx);
        return xx;
        }
    }
    
    /**
     * 對xx資料進行修改或者刪除操作 運算元據庫成功後 刪除快取
     * 刪除請求 - 刪除資料庫資料 刪除快取
     * 修改請求 - 更新資料庫資料 刪除快取 下次在查詢時候就會從資料庫拉取新的資料到快取中
     */
    public void deleteXxFromCache(long id) {
        String key = "Xx:" + xx.getId();
        redisTemplate.delete(key);
    }
    
    private void setXxFromCache(Xx xx) {
        String key = "Xx:" + xx.getId();
        redisTemplate.opsForValue().set(key, xx);
    }
    
    private Xx getXxFromCache(int id) {
        // 通過快取字首拼裝唯一主鍵作為快取Key 如Xxx資訊 就是Xxx:id
        String key = "Xx:" + id;
        return redisTemplate.opsForValue().get(key);
    }
    
}
// 業務類
public class XxServie {
    @Autowired
    private XxLazyCache xxLazyCache;
    // 查詢資料庫
    public Xx getXxById(long id) {
        // 省略實現
        return xx;
    }
    
    public void updateXx(Xx xx) {
        // 更新MySQL資料 省略
        // 刪除快取
        xxLazyCache.deleteXxFromCache(xx.getId());
    }
    
    public void deleteXx(long id) {
        // 刪除MySQL資料 省略
        // 刪除快取
        xxLazyCache.deleteXxFromCache(xx.getId());
    }
}
// 實體類
@Data
public class Xx {
    // 業務主鍵
    private Long id;
    // ...省略
}
複製程式碼

/**
 * 此快取演示如何結合redis自增數 hash 本地快取使用進行裝置自增數的生成、快取、本地快取
 * 本地快取使用Guava Cache
 */
public class DeviceIncCache {

    /**
     * 本地快取
     */
    private Cache<String, Integer> localCache = CacheBuilder.newBuilder()
        .concurrencyLevel(16) // 並行級別
        .initialCapacity(1000) // 初始容量
        .maximumSize(10000) // 快取最大長度
        .expireAfterAccess(1, TimeUnit.HOURS) // 快取1小時沒被使用就過期
        .build();

    @Autowired
    private RedisTemplate<String, Integer> redisTemplate;
    
    /**
     * redis自增數快取的key
     */
    private static final String DEVICE_INC_COUNT = "device_inc_count";
    
    /**
     * redis裝置編碼對應自增數的hash快取key
     */
    private static final String DEVICE_INC_VALUE = "device_inc_value";
    
    /**
     * 獲取裝置自增數
     */
    public int getInc(String deviceCode){
        // 1.從本地快取獲取
        Integer inc = localCache.get(deviceCode);
        if(inc != null) {
            return inc;
        }
        // 2.本地快取未命中，從redis的hash快取獲取
        inc = (Integer)redisTemplate.opsForHash().get(DEVICE_INC_VALUE, deviceCode);
        // 3. redis的hash快取中沒有，說明是新裝置，先為裝置生成一個自增號
        if(inc == null) {
            inc = redisTemplate.opsForValue().increment(DEVICE_INC_COUNT).intValue;
            // 新增到redis hash快取
            redisTemplate.opsForHash().put(DEVICE_INC_VALUE, deviceCode, inc);
        }
        // 4.新增到本地快取
        localCache.put(deviceCode, inc);
        // 4.返回自增數
        return inc;
    }
    
}