redis 过期键监听 demo

• redis监听器容器:

package com.dgis.tis.master.util.redis;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;


@Configuration
public class RedisListenerConfig {
    @Bean
    @Primary
    public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        return container;
    }
}

• key 过期监听器:

package com.dgis.tis.master.util.redis;

import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.stereotype.Component;



@Component
@Slf4j
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {

    private final RedisUtil redisUtil;
    public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer, RedisUtil redisUtil) {
        super(listenerContainer);
        this.redisUtil = redisUtil;
    }

    @Override
    public void onMessage(Message message, byte[] pattern) {
//        String key = new String(message.getBody());
        String expiredKey = message.toString();
        log.info("expiredKey:{}", expiredKey);
        if(expiredKey.startsWith("wxToken")){
            log.info("wxToken已过期");
            // 删除该key
            redisUtil.removeValue("wxToken");
        }
    }
}

redis 配置修改conf：

notify-keyspace-events Ex

注：只能获取到失效的 key 而获取不到 value，在设计 key 的时候可以考虑把 value 一并放到 key，然后根据规则取出 value