SpringBoot 使用redis的key 过期通知

ゝ一世哀愁。 2023-03-14 13:59 8阅读 0赞

1 redis默认key过期通知是关闭的，原因是多少会对cpu性能有影响，要使用redis的key过期通知功能，就的改配置：

config set notify-keyspace-events Ex

![20200518112633509.png][]

人后重启redis生效。

2 添加redis的配置

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;
    
    /**
     * @author :zoboy
     * @Description:
     * @ Date: Created in 2020-05-18 11:00
     */
    @Configuration
    public class RedisListenerConfig {
        @Bean
        RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
    
            RedisMessageListenerContainer container = new RedisMessageListenerContainer();
            container.setConnectionFactory(connectionFactory);
            return container;
        }
    }

3  写一个监听类

import com.alibaba.fastjson.JSON;
    import com.cictec.network.bus.base.order.service.IOrderService;
    import com.cictec.network.bus.busi.sys.model.entity.Order;
    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;
    
    import javax.annotation.Resource;
    
    
    /**
     * @author :zoboy
     * @Description:
     * @ Date: Created in 2020-05-18 10:58
     */
    @Slf4j
    @Component
    public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
        @Resource
        private IOrderService orderService;
    
        public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
            super(listenerContainer);
        }
    
        /**
         * redis key失效，监听
         * message.toString()可以获取失效的key
         * message.getBody 获取key对应的内容
         * @param message
         * @param pattern
         */
        @Override
        public void onMessage(Message message, byte[] pattern) {
            String expiredKey = message.toString();
            log.info(expiredKey + "----动作触发,开始执行");
            try {
               //业务处理
            } catch (Exception e) {
                log.error("key 过期通知处理异常，{}", e);
            }
    
        }
    }

4 测试

![20200518112944435.png][]

往redis加一条数据

然后默认5秒过期，5秒后：

![2020051811302218.png][]

至此springboot使用redis的主键过期通知完毕！

[20200518112633509.png]: /images/20230312/79f6f1c6893540bf9edfdfd5815142f8.png
[20200518112944435.png]: /images/20230312/bf519aa35e6346f58f39fc8773034624.png
[2020051811302218.png]: /images/20230312/f99c1b6570b14e04914238310c4e9406.png