服务器之家

服务器之家 > 正文

使用redis实现延迟通知功能(Redis过期键通知)

时间:2021-09-29 16:22     来源/作者:爪哇_克劳德

Redis 过期监听场景

业务中有类似等待一定时间之后执行某种行为的需求 , 比如 30 分钟之后关闭订单 . 网上有很多使用 Redis 过期监听的 Demo

redis配置

把notify-keyspace-events Ex 这一行的注释打开

使用redis实现延迟通知功能(Redis过期键通知)

项目demo工程

项目结构如下图

使用redis实现延迟通知功能(Redis过期键通知)

maven依赖

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5. <parent>
  6. <artifactId>kim-redis</artifactId>
  7. <groupId>com.kim</groupId>
  8. <version>1.0.0</version>
  9. </parent>
  10. <modelVersion>4.0.0</modelVersion>
  11.  
  12. <artifactId>kim-redis-expiration-notice</artifactId>
  13.  
  14. <dependencies>
  15. <dependency>
  16. <groupId>org.springframework.boot</groupId>
  17. <artifactId>spring-boot-starter-web</artifactId>
  18. </dependency>
  19. <dependency>
  20. <groupId>org.springframework.boot</groupId>
  21. <artifactId>spring-boot-starter-data-redis</artifactId>
  22. </dependency>
  23.  
  24. <dependency>
  25. <groupId>org.projectlombok</groupId>
  26. <artifactId>lombok</artifactId>
  27. </dependency>
  28. <dependency>
  29. <groupId>org.apache.commons</groupId>
  30. <artifactId>commons-pool2</artifactId>
  31. </dependency>
  32.  
  33. </dependencies>
  34. </project>

配置文件

  1. server:
  2. port: 20103
  3.  
  4. spring:
  5. redis:
  6. #数据库索引
  7. database: 0
  8. host: 127.0.0.1
  9. port: 6379
  10. password: 123456
  11. lettuce:
  12. pool:
  13. #最大连接数
  14. max-active: 8
  15. #最大阻塞等待时间(负数表示没限制)
  16. max-wait: -1
  17. #最大空闲
  18. max-idle: 8
  19. #最小空闲
  20. min-idle: 0
  21. #连接超时时间
  22. timeout: 10000

启动类

  1. /**
  2. * @Project: kim-redis
  3. * @PackageName: com.kim.redis.expiration.notice
  4. * @FileName: NoticeApplication.java
  5. * @Description: The NoticeApplication is...
  6. * @Author: kimwu
  7. * @Time: 2020-12-19 14:01:56
  8. */
  9. @SpringBootApplication
  10. public class NoticeApplication {
  11.  
  12. public static void main(String[] args) {
  13. SpringApplication.run(NoticeApplication.class, args);
  14. }
  15.  
  16. }

配置类

  1. @Configuration
  2. public class RedisTimeoutConfiguration {
  3.  
  4. @Autowired
  5. private RedisConnectionFactory redisConnectionFactory;
  6.  
  7. @Bean
  8. public RedisMessageListenerContainer redisMessageListenerContainer() {
  9. RedisMessageListenerContainer redisMessageListenerContainer = new RedisMessageListenerContainer();
  10. redisMessageListenerContainer.setConnectionFactory(redisConnectionFactory);
  11. return redisMessageListenerContainer;
  12. }
  13.  
  14. @Bean
  15. public KeyExpiredListener keyExpiredListener() {
  16. return new KeyExpiredListener(this.redisMessageListenerContainer());
  17. }
  18. }

监听类

  1. @Slf4j
  2. public class KeyExpiredListener extends KeyExpirationEventMessageListener {
  3.  
  4. public KeyExpiredListener(RedisMessageListenerContainer listenerContainer) {
  5. super(listenerContainer);
  6. }
  7.  
  8. @Override
  9. public void onMessage(Message message, byte[] pattern) {
  10. String channel = new String(message.getChannel(), StandardCharsets.UTF_8);
  11. //过期的key
  12. String key = new String(message.getBody(), StandardCharsets.UTF_8);
  13. log.info("redis key 过期:pattern={},channel={},key={}", new String(pattern), channel, key);
  14. }
  15. }

异常情况测试

当key过期时,项目宕机了
①写入redis的key
②手动关停服务,等待redis的key过期
③确认redis的key过期后,重启服务。服务不会收到通知

当key过期时,redis服务宕机了
①写入redis的key
②关停redis服务,等待redis的key过期
③启动redis服务,发现redis的过期key已经不存在了,服务没有收到通知

结论

redis的键过期本身不可靠,并不像rabbitmq一样保证了可靠性。
当服务本身宕机或者redis宕机时,将无法保证过期的key能够被消费。

当使用场景对数据完整性不那么精确时,可以使用redis的键过期策略。否则不太建议使用redis的键过期策略。

到此这篇关于使用redis实现延迟通知功能(Redis过期键通知)的文章就介绍到这了,更多相关Redis过期键通知内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家!

原文链接:https://blog.csdn.net/JavaTeachers/article/details/120039231

相关文章

热门资讯

yue是什么意思 网络流行语yue了是什么梗
yue是什么意思 网络流行语yue了是什么梗 2020-10-11
2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全
2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全 2019-12-26
背刺什么意思 网络词语背刺是什么梗
背刺什么意思 网络词语背刺是什么梗 2020-05-22
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总 2020-11-13
2021年耽改剧名单 2021要播出的59部耽改剧列表
2021年耽改剧名单 2021要播出的59部耽改剧列表 2021-03-05
返回顶部