监听Redis键过期的事件以及发布订阅

• 1、修改Redis中的配置文件
• 2、在springboot项目中配置Redis配置

将notify-keyspace-events 修改为 notify-keyspace-events Ex

两种方式实现：
第一种：监听指定的db键的过期事件

1. 配置Redis

@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {

    
    @Bean
    public RedisTemplate redisTemplate(RedisConnectionFactory factory) {
        RedisTemplate template = new RedisTemplate<>();
        // 配置连接工厂
        template.setConnectionFactory(factory);

        //使用Jackson2JsonRedisSerializer来序列化和反序列化redis的value值（默认使用JDK的序列化方式）
        Jackson2JsonRedisSerializer jacksonSeial = new Jackson2JsonRedisSerializer(Object.class);

        ObjectMapper om = new ObjectMapper();
        // 指定要序列化的域，field,get和set,以及修饰符范围，ANY是都有包括private和public
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        // 指定序列化输入的类型，类必须是非final修饰的，final修饰的类，比如String,Integer等会跑出异常
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jacksonSeial.setObjectMapper(om);

        // 值采用json序列化
        template.setValueSerializer(jacksonSeial);
        //使用StringRedisSerializer来序列化和反序列化redis的key值
        template.setKeySerializer(new StringRedisSerializer());

        // 设置hash key 和value序列化模式
        template.setHashKeySerializer(new StringRedisSerializer());
        template.setHashValueSerializer(jacksonSeial);
        template.afterPropertiesSet();

        return template;
    }

    @Bean
    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        //监控指定key也可以消费到指定的发布订阅的消息
        container.addMessageListener(listenerAdapter, new PatternTopic("webScoket_message"));
        return container;
    }
}

2. 实现MessageListenerj接口

// 发布消息代码  只监听指定key的话 不需要注意这段代码
JSONObject jsonObject = new JSONObject();
jsonObject.put("examId",examId);
jsonObject.put("message",message);
stringRedisTemplate.convertAndSend("webScoket_message",jsonObject.toJSONString());


public class RedisExpiredListener implements MessageListener {
    @Override
    public void onMessage(Message message, byte[] bytes) {//消费发布到频道中的消息
        //消息内容
            byte[] body=msgs.getBody();
            //订阅房间
            String topic=new String(pattern);
            //获取存在的房间中的用户
            String result= new String(body,"utf-8");
            JSONObject js= JSON.parseObject(result);
            String examId=js.getString("examId");
            String msg=js.getString("message");
            System.out.println(examId );
            System.out.println(msg );
    }
}

第二种：监听所有的db键的过期事件。
配置Redis第一步

@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {

    
    @Bean
    public RedisTemplate redisTemplate(RedisConnectionFactory factory) {
        RedisTemplate template = new RedisTemplate<>();
        // 配置连接工厂
        template.setConnectionFactory(factory);

        //使用Jackson2JsonRedisSerializer来序列化和反序列化redis的value值（默认使用JDK的序列化方式）
        Jackson2JsonRedisSerializer jacksonSeial = new Jackson2JsonRedisSerializer(Object.class);

        ObjectMapper om = new ObjectMapper();
        // 指定要序列化的域，field,get和set,以及修饰符范围，ANY是都有包括private和public
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        // 指定序列化输入的类型，类必须是非final修饰的，final修饰的类，比如String,Integer等会跑出异常
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jacksonSeial.setObjectMapper(om);

        // 值采用json序列化
        template.setValueSerializer(jacksonSeial);
        //使用StringRedisSerializer来序列化和反序列化redis的key值
        template.setKeySerializer(new StringRedisSerializer());

        // 设置hash key 和value序列化模式
        template.setHashKeySerializer(new StringRedisSerializer());
        template.setHashValueSerializer(jacksonSeial);
        template.afterPropertiesSet();

        return template;
    }

    @Bean
    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        //监控指定key也可以消费到指定的发布订阅的消息
        //container.addMessageListener(listenerAdapter, new PatternTopic("webScoket_message"));
        return container;
    }
}

配置Redis第二步

@Component
@Slf4j
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {

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

    
    @Override
    public void onMessage(Message message, byte[] pattern) {
    			String value = message.toString();
        	System.out.println(value );
    }
}