redisKey过期监听,适用于redis jedis的key过期监听,可以实现订单到期关闭或其他功能,也是在网上找了很多文章发现没有一个写的清楚的

首先需要一个类继承KeyExpirationEventMessageListener,重写父类onMessage方法以及生成一个构造方法,不生成构造是要报错的,当监听到Key过期时,会自动调用该方法,还有需要装配一个RedisMessageListenerContainer对象到spring容器里面,redis配置一下
notify-keyspace-events “Ex”
下面会附上代码

// 需要装配该对象
    @Bean
    public RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory factory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(factory);
        return container;
    }

监听类

@Component
@Slf4j
public class RedisKeyExpireListener extends KeyExpirationEventMessageListener {


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

    @Override
    public void onMessage(Message message, byte[] pattern) {
        String key = message.toString().replace("\"", "");
        log.info("监听到Key过期:{}", key);

    }
}

添加redis
在这里插入图片描述
设置过期时间
在这里插入图片描述

运行后
在这里插入图片描述

Logo

权威|前沿|技术|干货|国内首个API全生命周期开发者社区

更多推荐