SpringBoot实现Redis失效监听事件—KeyExpirationEventMessageListener

学习记录

在可以正常连接Redis存取数据之后，创建监听类KeyExpiredListener，集成KeyExpirationEventMessageListener类，重写onMessage方法。
这说明一下：在key失效之后，会出发onMessage方法。
在这里，我只是获取redis中失效的key值。
注意：只能获取失效的key值，不能获取key对应的value值。代码中的输出语句为null，可以证明。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.stereotype.Component;

import java.nio.charset.StandardCharsets;

@Component
public class KeyExpiredListener extends KeyExpirationEventMessageListener {

    @Autowired
    public RedisTemplate<String,String> redisTemplate;

    public KeyExpiredListener(RedisMessageListenerContainer listenerContainer) {
        super(listenerContainer);
    }

    @Override
    public void onMessage(Message message, byte[] bytes) {
        String key = new String(message.getBody(), StandardCharsets.UTF_8);
        String myKey = redisTemplate.opsForValue().get("myKey");
        System.out.println(myKey);
        //根据自身业务 书写逻辑
    }
}

 创建一个配置类RedisListenerConfig

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

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

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