- 当前位置：首页 >探索 >Redis实现延迟队列的方案总结
Redis实现延迟队列的方案总结
发布时间：2025-11-05 15:22:34 来源：码上建站 作者：系统运维
redis是现延我们项目开发中常见的技术中间件，它除了可以实现常见的迟队分布式锁和分布式缓存功能之外，还可以帮助我们实现很多的总结功能，如延迟队列。现延下面介绍几种redis常见的迟队实现延迟队列的方案。
1、总结通过过期key通知实现
图片
实现思路：首先开启redis的现延key过期通知，然后在业务中给key设置过期时间，迟队到了过期时间后redis会自动的总结将过期的key消息推送给监听者，从而实现延迟任务。现延
核心的迟队代码实现：
复制#1、开始redis的总结过期通知 notify-keyspace-events Ex #2、监听redis的现延过期key @Component @Slf4j public class RedisExpireKeyService extends KeyExpirationEventMessageListener { /** * Creates new {@link MessageListener} for {@code __keyevent@*__:expired} messages. * * @param listenerContainer must not be {@literal null}. */ public RedisExpireKeyService(RedisMessageListenerContainer listenerContainer) { super(listenerContainer); } /** * 监听过期的key * */ @Override public void onMessage(Message message, byte[] pattern) { String expireKey = message.toString(); //执行具体的业务 System.out.println("监听到key=" + expireKey + "，已经过期"); } }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.32.33.34.35.36.37.38.生产环境是迟队不推荐使用此方案，原因Redis 的高防服务器总结过期策略采用的是惰性删除和定期删除相结合的方式，redis并不保证 key 在过期时会被立即删除操作，此方案适用于平时自己项目练习的时候使用。
2、通过Zset数据类型+定时任务实现
图片
实现思路：ZSet 是一种有序集合类型，它可以存储不重复的元素，并且给每个元素赋予一个 double 类型的排序权重值(score)，所以可以将元素的过期时间作为分值，通过定时任务扫描的方式判断是否达到过期时间，从而实现延迟队列。
核心的代码实现：
复制#使用xxl-job @JobName("consumerTaskJob") public void consumerTaskJob() { String expireKey = "ExPIRE_KEY"; try { //获取当前时间 double currentTime = System.currentTimeMillis(); //获取超时的数据 Set<String> expiredMemberSet = redisTemplate.opsForZSet().rangeByScore(expireKey, Double.MIN_VALUE, currentTime); //过期key for (String expiredMember : expiredMemberSet) { //todo 做实际的延迟任务 //从ZSet中移除数据 redisTemplate.opsForZSet().remove(expireKey, expiredMember); } } catch (Exception e) { log.error("数据处理失败",e); } }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.Zset+定时任务的实现延迟任务的方式虽然比监听过期key方案合理一些，但是它还是存在一定的服务器租用缺陷，如无重试机制、延迟时间固定化（依赖定时任务的执行时间）、不适用于大规模的延迟任务。
3、Redisson实现延迟队列
Redisson是一个操作Redis的 Java 客户框架，它提供了RDelayedQueue 接口和 RQueue 接口可以实现延迟队列（Redisson 提供的延迟队列底层也是基于 Zset 数据结构实现的）。
核心的代码实现：
复制#1、添加依赖 <dependency> <groupId>org.redisson</groupId> <artifactId>redisson</artifactId> <version>3.16.0</version> </dependency> #2、添加数据到队列中 //创建RedissonClient实例 RedissonClient redissonClient = Redisson.create(); //创建阻塞队列 RBlockingDeque<String> queue = redissonClient.getBlockingDeque("delayQueue"); //创建延迟队列并关联到阻塞队列 RDelayedQueue<String> delayedQueue = redissonClient.getDelayedQueue(queue); //添加延迟任务 delayedQueue.offer("Task1", 5000, TimeUnit.MILLISECONDS); #3、消费数据 while (true) { try { //获取并移除队首元素，如果队列为空，则阻塞等待 String task = queue.take(); System.out.println("Task: " + task); } catch (Exception e) { log.error("消费失败",e); } }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.总结：Redis实现的延迟队列适用于处理一些比较简单的业务，如发送邮件、发送通知等，对于复杂的业务不适用于Redis的延迟任务方案。
b2b供应网- 笔记本电脑AHCI模式教程（了解AHCI模式，提升笔记本电脑性能）
- 使用系统U盘安装XP系统的详细教程（简单易行的步骤，让你轻松装好XP系统）
- u深度装win10系统教程
- 探索MPXT2CHA（分析MPXT2CHA在性能、功能和用户体验方面的优势与亮点）
- 电脑开机后出现错误代码，如何解决？（从错误代码到修复方案，全面解析电脑开机问题）
- 老毛桃Win10装机教程（一站式指南，轻松搭建Win10系统）
- 用U盘PE系统安装系统教程（简单易懂的U盘PE系统安装教程，轻松搞定系统安装！）
- USB启动装系统教程（教你如何通过USB启动装系统，轻松安装操作系统）
- Ubuntu 也是一款娱乐性超强的开源操作系统，舒适的界面配合开源的应用体验，可以给我们不一样的感觉。不过，毕竟是开源操作系统，选对播放软件再重要不过。SMPlayer就是这样一款优异的播放软件，足以满足我们在Ubuntu下的使用体验。小编就来介绍一下如何安装。软件名称：ubuntukylin软件中心 V0.3.2 中文版软件大小：20.5MB更新时间：2014-07-171、首先启动 Ubuntu 软件中心。一般情况下，软件中心可以从系统左侧的导航栏中直接启动，点击即可。假如软件中心图标没有出现，那就轻敲一下Windows徽标键，打开搜索窗口，输入软件中心，即可启动。2、看到软件中心窗口右上方的搜索框，输入smplayer。3、随后，软件中心窗口就会出现我们亲爱的SMPlayer——成功搜索出来了！4、选中列表中的SMPlayer，出现橘黄色选中条后，点击选中条右下方的“安装”按钮，即可自动安装。注意：我已經装好了SMPlayer，所以这里出现的是“卸载”字样。5、稍等片刻，即可安装成功！安装后，软件的图标就会显示在导航栏上，点击即可启动。6、启动成功！这就是SMPlayer的主界面！
- 技嘉主板重置BIOS教程（快速而安全地重置技嘉主板的BIOS设置，解决系统故障和性能问题）
- 以LG对开门冰箱为主题的文章（高科技智能冰箱的首选——LG对开门冰箱）
- 昂达obook10pro评测（强大的处理器、优质的显示屏以及出色的性能）
- 联想V110系统安装教程（轻松安装联想V110系统，让您的电脑焕然一新）
- 使用U盘安装Gost系统的教程（简单易懂的Gost系统安装方法及步骤）
- 创维变频洗衣机的性能源效率（提高生活品质的节能洗涤利器）
- 未来应用（探索未来应用技术，预见生活的变革）
- TCLB55A558U——极致画质体验（细腻逼真的画面，让您沉浸其中）
- 电脑菜鸟也能轻松重装系统（简明教程带你一步步完成重装，告别电脑烦恼）
- 小米6运动拍照效果惊艳拍出动感与细节并存（小米6运动拍照动感十足，细节尽显）
- 自制U盘系统教程（以WindowsPE为基础，轻松定制个人专属U盘系统）
随便看看
香港云服务器益华科技企商汇IT技术网亿华云源码库服务器租用源码下载IT资讯网益强科技IT资讯网亿华云计算码力社云站无忧技术快报益强编程舍益华科技益强资讯优选极客编程码上建站益强数据堂云智核益强前沿资讯亿华云益强IT技术网益强编程堂益强科技科技前瞻多维IT资讯运维纵横全栈开发亿华科技编程之道亿华智慧云益强智未来亿华互联益华科技亿华智造汇智坊益华IT技术论坛亿华灵动益强智囊团极客码头
- Copyright © 2025 Powered by Redis实现延迟队列的方案总结,码上建站 滇ICP备2023006006号-47sitemap