溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

如何通過(guò)springboot+redis實(shí)現(xiàn)過(guò)期事件監(jiān)聽(tīng)?

發(fā)布時(shí)間:2020-06-23 18:21:42 來(lái)源:億速云 閱讀:237 作者:清晨 欄目:編程語(yǔ)言

不懂如何通過(guò)springboot+redis實(shí)現(xiàn)過(guò)期事件監(jiān)聽(tīng)??其實(shí)想解決這個(gè)問(wèn)題也不難,下面讓小編帶著大家一起學(xué)習(xí)怎么去解決,希望大家閱讀完這篇文章后大所收獲。

1 修改 redis.conf配置文件:

K Keyspace events, published with keyspace@ prefix事件
E Keyevent events, published with keyevent@ prefix
g Generic commands (non-type specific) like DEL, EXPIRE, RENAME, …
$ String commands
l List commands
s Set commands
h Hash commands
z Sorted set commands
x 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ò)期事件:

@Configuration
public class RedisListenerConfig {
  @Bean
  RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {

    RedisMessageListenerContainer container = new RedisMessageListenerContainer();
    container.setConnectionFactory(connectionFactory);
    return container;
  }
}

3.書(shū)寫(xiě)一個(gè)監(jiān)聽(tīng)器

@Slf4j
@Component
public 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ò)springboot+redis實(shí)現(xiàn)過(guò)期事件監(jiān)聽(tīng)?

需要注意的是:

過(guò)期監(jiān)聽(tīng)消息中返回的是,過(guò)期的鍵的key值,是沒(méi)有返回value的

感謝你能夠認(rèn)真閱讀完這篇文章,希望小編分享如何通過(guò)springboot+redis實(shí)現(xiàn)過(guò)期事件監(jiān)聽(tīng)??jī)?nèi)容對(duì)大家有幫助,同時(shí)也希望大家多多支持億速云,關(guān)注億速云行業(yè)資訊頻道,遇到問(wèn)題就找億速云,詳細(xì)的解決方法等著你來(lái)學(xué)習(xí)!

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI