快捷導(dǎo)航

控制Redis的hash的field中的過期時間

更新時間：2023年01月19日 08:43:30 作者：好大的月亮

這篇文章主要介紹了控制Redis的hash的field中的過期時間問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教

需求場景

在業(yè)務(wù)中有些數(shù)據(jù)因為歷史原因用的hash結(jié)構(gòu)存儲數(shù)據(jù)，但是后期需求要求其中某個field需要按照一些規(guī)則去過期，這個時候原來的邏輯懶得改，可以利用redis的Zset或者mq的延時隊列去做過期設(shè)置.

方案一使用redis的Zset配置定時任務(wù)

撈個圖

demo需要清緩存的redis的hash結(jié)構(gòu)如下

然后我們再每次往Agent這個hash結(jié)構(gòu)存儲數(shù)據(jù)的時候，同時向AgentExpire為key的ZSET數(shù)據(jù)結(jié)構(gòu)存儲一份數(shù)據(jù)（在存數(shù)據(jù)的時候可以在當(dāng)前時間上增加過期時間），這個數(shù)據(jù)的key是hash結(jié)構(gòu)中的field的值，value是過期時間戳（毫秒級）

如下圖所示：

然后用一個定時任務(wù)（我這里用的xxl-job，大家可以自己選擇）定時去掃描這個ZSET里面score小于當(dāng)前時間的元素，也就是使用ZSET的rangeByScore命令：

上面在向Zset中存數(shù)據(jù)的時候已經(jīng)增加了過期時間，那么當(dāng)時間小于當(dāng)前時間時就過期了，代表hash中對應(yīng)field的數(shù)據(jù)要被delete

long currentTimeMillis = System.currentTimeMillis();

//掃描key為AgentExpire的zset中時間在 0~currentTimeMillis當(dāng)前時間范圍內(nèi)的數(shù)據(jù)
Set<String> keys = redisTemplate.opsForZSet().rangeByScore("AgentExpire", 0, currentTimeMillis);

//然后遍歷刪除即可                            
for (String key : keys) {
    Boolean hashResult = stringRedisTemplate.opsForHash().hasKey("xxxxxx", key);
    if(hashResult){
        stringRedisTemplate.opsForHash().delete(recommenKey, key);
        stringRedisTemplate.opsForZSet().remove(SelectionRecommenAspect.selectionRecommendZset, key);
    }
}

方案二使用mq延時隊列

延時隊列的配置可以參考我另一篇文章

http://m.fzitv.net/article/273145.htm

在延時隊列消費者處增加上述過期代碼即可

long currentTimeMillis = System.currentTimeMillis();
Set<String> expireKeys = 
//掃描key為AgentExpire的zset中時間在 0~currentTimeMillis當(dāng)前時間范圍內(nèi)的數(shù)據(jù)
redisTemplate.opsForZSet().rangeByScore("AgentExpire", 0, currentTimeMillis);