springboot+redis過(guò)期事件監(jiān)聽(tīng)實(shí)現(xiàn)過(guò)程解析
1 修改 redis.conf配置文件:
K Keyspace events, published with keyspace@ prefix事件E Keyevent events, published with keyevent@ prefixg Generic commands (non-type specific) like DEL, EXPIRE, RENAME, …$ String commandsl List commandss Set commandsh Hash commandsz Sorted set commandsx Expired events (events generated every time a key expires)e Evicted events (events generated when a key is evicted for maxmemory)A Alias for g$lshzxe, so that the “AKE” string means all the events.redis.conf 的默認(rèn)的配置是:notify-keyspace-events ''我們需要改為:notify-keyspace-events Ex即對(duì)應(yīng)上面的鍵的過(guò)期事件。修改玩這個(gè)重啟一下redis
2 客戶端來(lái)監(jiān)聽(tīng)redis的過(guò)期事件:
@Configurationpublic class RedisListenerConfig { @Bean RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) { RedisMessageListenerContainer container = new RedisMessageListenerContainer(); container.setConnectionFactory(connectionFactory); return container; }}
3.書寫一個(gè)監(jiān)聽(tīng)器
@Slf4j@Componentpublic class RedisKeyExpirationListener extends KeyExpirationEventMessageListener { public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) { super(listenerContainer); } @Override public void onMessage(Message message, byte[] pattern) { String expiredKey = message.toString(); log.info('expiredKey========='+expiredKey); }
4.查詢方法中隨便加了兩個(gè)表中的不同id,一個(gè)30s,一個(gè)27s。
redisUtil.set('UserId'+user.get(0).getId(),user.get(0).getId(),30);redisUtil.set('UserInfoId'+userInfo.get(0).getId(),userInfo.get(0).getId(),27);
控制臺(tái)輸出:

需要注意的是:
過(guò)期監(jiān)聽(tīng)消息中返回的是,過(guò)期的鍵的key值,是沒(méi)有返回value的
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持好吧啦網(wǎng)。
相關(guān)文章:
1. idea刪除項(xiàng)目的操作方法2. IntelliJ IDEA設(shè)置條件斷點(diǎn)的方法步驟3. IntelliJ IDEA設(shè)置編碼格式的方法4. IntelliJ IDEA創(chuàng)建web項(xiàng)目的方法5. 淺談JavaScript宏任務(wù)和微任務(wù)執(zhí)行順序6. Docker 容器健康檢查機(jī)制7. Docker 部署 Prometheus的安裝詳細(xì)教程8. vue+elementUI下拉框回顯問(wèn)題及解決方式9. idea環(huán)境下Maven無(wú)法正常下載pom中配置的包問(wèn)題10. Django中如何使用Channels功能

網(wǎng)公網(wǎng)安備