快捷導(dǎo)航

控制Redis的hash的field中的過(guò)期時(shí)間

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

這篇文章主要介紹了控制Redis的hash的field中的過(guò)期時(shí)間問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

需求場(chǎng)景

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

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

撈個(gè)圖

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

然后我們?cè)倜看瓮?code>Agent這個(gè)hash結(jié)構(gòu)存儲(chǔ)數(shù)據(jù)的時(shí)候，同時(shí)向AgentExpire為key的ZSET數(shù)據(jù)結(jié)構(gòu)存儲(chǔ)一份數(shù)據(jù)（在存數(shù)據(jù)的時(shí)候可以在當(dāng)前時(shí)間上增加過(guò)期時(shí)間），這個(gè)數(shù)據(jù)的key是hash結(jié)構(gòu)中的field的值，value是過(guò)期時(shí)間戳（毫秒級(jí)）

如下圖所示：

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

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

long currentTimeMillis = System.currentTimeMillis();

//掃描key為AgentExpire的zset中時(shí)間在 0~currentTimeMillis當(dāng)前時(shí)間范圍內(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延時(shí)隊(duì)列

延時(shí)隊(duì)列的配置可以參考我另一篇文章

http://www.dbjr.com.cn/article/273145.htm

在延時(shí)隊(duì)列消費(fèi)者處增加上述過(guò)期代碼即可

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