监听Redis键过期的事件以及发布订阅
2021/11/8 2:12:04
本文主要是介绍监听Redis键过期的事件以及发布订阅,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
springboot使用Redis,监听Redis键过期的事件设置与使用代码
- 1、修改Redis中的配置文件
- 2、在springboot项目中配置Redis配置
1、修改Redis中的配置文件
将notify-keyspace-events 修改为 notify-keyspace-events Ex
2、在springboot项目中配置Redis配置
两种方式实现:
第一种:监听指定的db键的过期事件
- 配置Redis
/** * @author * reids 相关bean的配置 */ @Configuration @EnableCaching public class RedisConfig extends CachingConfigurerSupport { /** * retemplate相关配置 * * @param factory * @return */ @Bean public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) { RedisTemplate<String, Object> 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; } }
- 实现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第一步
/** * @author * reids 相关bean的配置 */ @Configuration @EnableCaching public class RedisConfig extends CachingConfigurerSupport { /** * retemplate相关配置 * * @param factory * @return */ @Bean public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) { RedisTemplate<String, Object> 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); } /** * 针对redis数据失效事件,进行数据处理 * * @param message * @param pattern */ @Override public void onMessage(Message message, byte[] pattern) { String value = message.toString(); System.out.println(value ); } }
这篇关于监听Redis键过期的事件以及发布订阅的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-11-18Redis安装入门:新手必读指南
- 2024-11-08阿里云Redis项目实战入门教程
- 2024-11-08阿里云Redis资料:新手入门与初级使用指南
- 2024-11-08阿里云Redis教程:新手入门及实用指南
- 2024-11-07阿里云Redis学习入门:新手必读指南
- 2024-11-07阿里云Redis学习入门:从零开始的操作指南
- 2024-11-07阿里云Redis学习:初学者指南
- 2024-11-06阿里云Redis入门教程:轻松搭建与使用指南
- 2024-11-02Redis项目实战:新手入门教程
- 2024-10-22Redis入门教程:轻松掌握数据存储与操作