栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

Redis异步队列/延迟队列

Redis异步队列/延迟队列

Redis 除了呗广泛认知为 缓存外,还可以 作为 消息队列

为什么能够作为消息队列?

因为redis 的数据结构 list / zset 的存在,支持

list结构 入队出队 的表现形式,搭配 rpush 生产消息,lpop 消费消息,可以实现 消息队列
zset 结构 可以有过期时间的表现形式,可以实现 延迟队列

怎么作为异步消息队列?
    1:1 生产一个 消费一个
    rpush 生产消息,lpop 消费消息.
    如果没有消息,没办法消费,就会一直空轮询导致性能下降,需要 sleep来到达保持性能,但是一旦多了就会影响性能
    所以 最好使用 blpop/brpop 替代前面的 lpop/rpop,这个命令在有消息工作,没消息阻塞等到有消息在工作,很好的保证性能前提又能完成任务。
    但是 长时间的不工作,可能会被认为闲置功能被服务器回收。编写时注意异常捕获,以免被回收。1:N 发布订阅模式
    pub/sub 实现生产一次,消费多次给订阅者
    缺点:如果在还没发送到消费者信息,消费者下线那这个生产的消息就消失了,因为不是专业的消息队列,如果想做到完美消息管控,就使用专业消息Kafka/RocketMQ。
怎么作为延迟消息队列?

延迟的前提,是知道延迟多久去发送消息,这个就需要一个参数来代表时间延迟表现。
所以延时队列可以通过 Redis 的 zset(有序列表) 来实现。我们将消息序列化成一个字符串作为 zset 的 value,这个消息的到期处理时间作为 score,然后用多个线程轮询 zset 获取到期的任务进行处理,多个线程是为了保障可用性,万一挂了一个线程还有其它线程可以继续处理。保证延迟发送的可靠性。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/742378.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号