redis失效key监听器_redismessagelistenercontainer

1、有这个需求一般都是集成了redis的，没有集成的，在pom.xml中加上就行

2、配置监听容器

 
    @Bean
    public RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory connectionFactory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        return container;
    }

3、设置redis过期时间

// 这里的id是唯一值  过期时间2小时
redisTemplate.opsForValue().setIfAbsent(id, "1", 2, TimeUnit.HOURS);

4、添加监听器

package com.zhifeng.sale.business.config;
 
import com.zhifeng.common.SaleConstant;
import com.zhifeng.common.mybatis.ExampleBuilder;
import com.zhifeng.sale.business.mapper.OpenDemandMapper;
import com.zhifeng.sale.business.model.OpenDemand;
import com.zhifeng.sale.business.service.OpenDemandService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
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 java.util.Objects;
 
@Component
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
 
    private final static Logger logger = LoggerFactory.getLogger(RedisKeyExpirationListener.class);
 
    public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
        super(listenerContainer);
    }
 
    @Override
    public void onMessage(Message message, byte[] pattern) {
        try {
            // 获取失效的key
            String key = message.toString();
            //从失效key中筛选代表订单失效的key
            if (key != null && key.startsWith(SaleConstant.KAIPING_ORDER)) {
                String openDemandId = key.substring(14);
                //业务逻辑
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
 
 
}