Redis高级--延迟队列

已于 2023-05-31 20:16:10 修改
阅读量1.2k 收藏
点赞数 2
文章标签： redis 数据库
于 2021-05-08 00:01:49 首次发布
版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://blog.csdn.net/feiying0canglang/article/details/116505534
版权

原文网址：Redis高级--延迟队列_IT利刃出鞘的博客-CSDN博客

简介

Redis实现延迟队列的方案：用zset保存队列信息，按照时间戳存放，再启动一个任务，一直扫这个zset，判断当前时间和队列中的时间大小信息，执行后，删除数据。

注意：有赞在用这种方案。本人建议直接用MQ（RabbitMQ或者RocketMQ或Kafka）的延迟队列功能。RocketMQ缺点：目前RocketMQ只支持特定的延时时间段，1s,5s,10s,...2h，不能支持任意时间段的延时设置。

IT利刃出鞘
关注
  • 2
    点赞
  • 踩
  • 0
    收藏
    觉得还不错? 一键收藏
  • 打赏
    打赏
  • 0
    评论
专栏目录
idoit:具有高级任务控制和最终一致性的Redis支持的任务队列引擎
05-09
偶像 具有高级任务控制和最终一致性的Redis支持的任务队列引擎。 任务分组，链接，范围广泛的迭代器。 推迟和计划的任务运行。 负载分配+工作池。 易于嵌入。 详细功能 idoit提供了先进的控制来实施 分组。 特殊group任务执行子任务并等待所有任务完成。 对于映射/减少逻辑很有用。 链接。 特殊的chain任务一对一地执行孩子。 对于将地图简化或将非常复杂的任务拆分为更简单的步骤，也很有用。 映射迭代器。 巨大的有效载荷的特殊功能，可按需生产块。 好处： 映射阶段没有延迟，块处理立即开始。 易于优化的数据库查询以构建大小相等的块（跳过+限制查询在处理大数据时非常慢）。 进步。 当您使用组/链/地图方案时，可以很容易地通过顶级父级监视总进度。 长时间的独立任务还可以通知用户进度变化。 工人池。 您可以按不同的流程拆分任务。 例如，如果您不希望繁重的任务阻止较轻的任
NewLife.Redis:高性能Redis客户端，支持.NETCore.NET4.0.NET4.5，为大数据与消息队列而特别优化，线上单应用日均100亿调用量
04-29
新生命Redis组件 NewLife.Redis 是一个Redis客户端组件，以高性能处理大数据实时计算为目标。 Redis协议基础实现Redis/RedisClient位于，本库为扩展实现，主要增加列表结构、哈希结构、队列等高级功能。 源码： Nuget：NewLife.Redis 特性 在ZTO大数据实时计算广泛应用，200多个Redis实例稳定工作一年多，每天处理近1亿包裹数据，日均调用量80亿次 低延迟，Get/Set操作平均耗时200~600us（含往返网络通信） 大吞吐，自带连接池，最大支持1000并发 高性能，支持二进制序列化 Redis经验分享 在Linux上多实例部署，实例个数等于处理器个数，各实例最大内存直接为本机物理内存，避免单个实例内存撑爆 把海量数据（10亿+）根据key哈希（Crc16/Crc32）存放在多个实例上，读写性能成倍增长 采用二进制序列化，而非常见
黑马头条项目总结之文章发布
weixin_65627952的博客
11-11 1494
黑马头条文章发布功能总结
黑马头条知识点总结
JJpZh的博客
11-14 5908
本人跟着黑马的视频做了近一个月，过程有些仓促，所以来复盘一下重要知识点。主要就是java的spring cloud项目。追求可用性：Kafka、 RocketMQ 、RabbitMQ追求可靠性：RabbitMQ、RocketMQ追求吞吐能力：RocketMQ、Kafka追求消息低延迟：RabbitMQ、Kafka运用Redis缓存技术，实现热数据的计算，提升系统性能指标使用Mysql存储用户数据，以保证上层数据查询的高性能使用Mongo存储用户热数据，以保证用户热数据高扩展和高性能指标使用freemarke
redis学习笔记六之事物、排序、队列及键值对生失效时间
JonyBang的专栏
04-20 1646
一、事物：保持要执行的命令事务一致性，要执行都执行，有一个出错，就都不执行。 1、命令格式： multi [commands] exec 2、如果命令编译成功，由于数据类型问题等原因执行是报错，则不影响其他已经编译完成的语句的执行！ 以上执行显示第二条语句执行失败，但是第一条语句执行成功！ 3、watch  : 执行事务命令之前锁定一个变量。当exec命令
延时队列的设计：定时任务轮询、DelayQueue、时间轮算法、消息中间件、Redis
qq_38667268的博客
12-13 2463
首先它要具有队列的特性，再给它附加一个延迟消费队列消息的功能，延迟队列相对比普通队列，区别就在延时的特性上，普通队列先进先出，按入队顺序进行处理，而延时队列中的元素在入队时会指定一个延时时间，希望能够在指定时间到了以后处理。时间轮算法，参考的时钟，从时钟中得到的一些启发设计出来的，简单的讲它是一个存储定时任务的环形队列，底层采用数组实现，数组中的每个元素可以存放一个延时任务列表。缺点∶缺乏队列顺序消息特性，相同score的任务无法顺序执行，缺乏ack特性，若任务执行失败，而队列的任务被删除了，就丢失了。
Redis之延时队列
Torres-Ye的博客
02-09 694
Redis实现队列 Redis通过自带的数据结构list实现队列。 使用rpush和lpush进行入队操作，rpop和lpop进行出队列操作，不过要注意的是，redis实现的队列并没有ack确认机制，所以在数据的安全与稳定性上有个劣势。 127.0.0.1:6379> rpush queue a b c (integer) 3 127.0.0.1:6379> rpush queue d (integer) 4 127.0.0.1:6379> llen queue (integer) 4 1
Redis异步队列与延时队列
hudeyong926的专栏
10-22 1123
异步消息队列 说道消息队列，你肯定会想到Kafka、Rabbitmq等消息中间件，这些专业的消息中间件提供了很多功能特性，当然他的部署使用维护都是比较麻烦的。如果你对消息队列没那么高要求，想要轻量级的，使用Redis就没错啦。 Redis通过list数据结构来实现消息队列.主要使用到如下命令： lpush和rpush入队列 lpop和rpop出队列 blpop和brpop阻塞式出队列 废话补不多说上代码： <?php $redis = new Redis()
用PHP+Redis实现延迟任务 实现自动取消订单（详细教程）
weixin_43814458的博客
04-09 819
简单定时任务解决方案：使用redis的keyspace notifications（键失效后通知事件） 需要注意此功能是在redis 2.8版本以后推出的，因此你服务器上的reids最少要是2.8版本以上； 我的官方群点击此处。 (A)业务场景： 1、当一个业务触发以后需要启动一个定时任务，在指定时间内再去执行一个任务（如自动取消订单，自动完成订单等功能） 2、redis的keyspace...
redis 设置过期时间的问题、以及过期策略、订单取消，延迟队列+微信红包，发布订阅
FREEDOM
12-09 5831
设置过期时间 redis有四种命令可以用于设置键的生存时间和过期时间： EXPIRE <KEY> <TTL> : 将键的生存时间设为 ttl 秒 PEXPIRE <KEY> <TTL> :将键的生存时间设为 ttl 毫秒 EXPIREAT <KEY> <timestamp> :将键的过期时间设为 timestamp 所指定的秒数时间戳 PEXPIREAT <KEY> <t.
asynq：Asynq：Go中简单，可靠，高效的分布式任务队列
02-03
由于Redis中的写入速度很快，因此添加任务的延迟很短 使用对任务进行重复数据删除 允许 以停止处理队列中的任务 以实现自动分片和高可用性 以实现高可用性 用于检查和远程控制队列和任务 检查和远程控制队列和任务 ...
python入门到高级全栈工程师培训 第3期 附课件代码
06-07
13 自定制property实现延迟计算功能 14 property补充 15 元类介绍 16 自定义元类 17 函数复习 18 文件操作复习 第29章 01 上节课复习 02 什么是异常处理及异常处理的两种方式对比 03 多分支与万能异常 04 异常处理...
java开源包1
06-28
使用redis作缓存时，支持list类型的高级数据结构，更适合论坛帖子列表这种类型的数据 5. 支持混合使用redis缓存和memcached缓存。可以将列表数据缓存到redis中，其他kv结构数据继续缓存到memcached 6. 支持redis的...
RabbitMQ
weixin_45980070的博客
09-20 223
一，引言 为什么引入rabbitMQ： 模块之间的耦合度多高，导致一个模块宕机后，全部功能都不能用了，（同步操作存在问题） 并且同步通讯的成本过高，用户体验差。（多浪费时间） 上图的解释：1》我们每一个通知都是同步操作的，就是说你在通知缓存模块是就要等他回复你后才能进行下一步的操作。同样就会出现这样一个问题就是你在通知缓存模块时他宕机了，客户端就要等待你好了给我一个结果才能静一步操作。2》就算你每一个都成功了你本来要0.1秒就能通知三个模块，而上面的springboot模式就要每一个都话费0.2秒，
用 Redis 做一个可靠的延迟队列
HollisChuang's Blog
07-21 410
Hollis的新书限时折扣中，一本深入讲解Java基础的干货笔记！我们先看看以下业务场景：当订单一直处于未支付状态时，如何及时的关闭订单，并退还库存？新创建店铺，N天内没有上传商品，系统如何知道该信息，并发送激活短信？上述场景最简单直接的解决方案是定时扫表。我们假设 10 分钟未支付则关闭订单、定时任务设置为 5 分钟一次，那么一个订单最晚会在 15 分钟关闭。高达 5 ...
Redis从入门到精通（2）：事务、过期时间、sort以及队列
春水上行的博客
02-21 774
Redis事务 Redis中的事务是一组命令的集合，事务最基本的特性就是原子性。一个事务中的命令要么全都执行，要么全部不执行。银行转账是理解事务最常见的一个例子，我已经在以前的文章中讲过很多次事务，这里就不再细讲，我们直接来看Redis的事务怎样来使用。 Redis事务的原理是先将属于一个事务的命令发送给Redis，然后再让Redis依次执行这些命令。 例如： MULTI SADD te...
redis延迟队列,处理正常订单超时自动关闭
zhangshengqiang168的博客
08-29 6998
demo代码地址 链接：https://pan.baidu.com/s/1yY_84ANvwh78gE6G0HXnBg 提取码：gzvu <dependency> <groupId>org.redisson</groupId> <artifactId>redisson</...
redis数据库队列（list），集合（set）元素设置类似过期（expire）功能
热门推荐
尤里安龙卷风
11-29 6万+
问题：项目需要为每个用户维护一个列表，存放一些数据。列表中的值有过期时间，过期的值查询可以找到也可以找不到，还会有一个验证，所以无所谓。但是redis队列只有一个整体的过期功能，没有每个元素的单独过期功能，所以如果用户一直不停向队列塞东西，队列就会变的越来越大。这显然不合理。资料：https://stackoverflow.com/questions/16545321/how-to-expire-t
为什么Redis6.0引入了多线程
最新发布
IT深耕十余载，大道之简
05-11 467
总的来说，Redis 6.0引入多线程是为了提高性能、降低延迟、更好地利用CPU资源，并保持Redis的简单性和高性能特点。这些改进有助于Redis更好地应对不断增长的数据量和并发量需求，同时保持其稳定性和可靠性。Redis 6.0引入多线程的决策是基于其性能优化和适应现代硬件架构的考虑。
redis-x64-5.0.10.zip
07-12
Redis是一个开源的、基于内存的数据结构存储系统，广泛应用于缓存、消息队列、排行榜、实时数据分析等场景。 这个安装包适用于64位操作系统，版本号是5.0.10。通过下载并解压这个.zip文件，我们可以获得Redis数据库...

“相关推荐”对你有帮助么？

  • 非常没帮助
  • 没帮助
  • 一般
  • 有帮助
  • 非常有帮助
提交
评论
添加红包

请填写红包祝福语或标题

个

红包个数最小为10个

元

红包金额最低5元

当前余额3.43元 前往充值 >
需支付：10.00元
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包

打赏作者

IT利刃出鞘

你的鼓励将是我创作的最大动力

¥1 ¥2 ¥4 ¥6 ¥10 ¥20
扫码支付：¥1
获取中
扫码支付

您的余额不足，请更换扫码支付或充值

打赏作者

实付元
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明：

1.余额是钱包充值的虚拟货币，按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载，可以购买VIP、付费专栏及课程。

余额充值