前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >如何实现异步队列&&延时队列

如何实现异步队列&&延时队列

作者头像
名字是乱打的
发布2022-05-13 11:14:19
7860
发布2022-05-13 11:14:19
举报
文章被收录于专栏:软件工程

redis异步队列依赖双向链表List有三种方式实现

1.利用rpush queue value1 rpush queue value2生产消息 lpop key消费
  • 缺点:lpop不会等待rpush生产后,队列中有值再进行再消费
  • 弥补:可以通过在应用层引入Sleep机制去调用LPOP重试
  • 比较麻烦
2.BLPOP key timeout:阻塞直到队列有消息或者超时
  • 用blpop改善后如果有值会直接取出,如果没有值会进行一个等待,超过自己设置的时间会返回nil退出
  • 缺点: 只能让一个消费者消费,如果向要发送的消息被多个消费者消费可以用pub/sub
3.pub/sub:主题订阅者模式
  • 发送者(pub)发送消息,订阅者(sub)接收消息
  • 订阅者可以订阅任意数量的频道
  • 缺点:pub/sub的缺点消息的发布是无状态的,无法保证可达,如果想更安全只有使用一些完善的消息中间件如RabbitMQ

Redis如何实现延时队列

使用sortedset,拿时间戳作为score,消息内容作为key调用zadd来生产消息,这样就可以根据时间戳来进行一个排序了,消费者用zrangebyscore指令获取N秒之前的数据轮询进行处理。

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2022-05-13,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • Redis如何实现延时队列
相关产品与服务
云数据库 Redis
腾讯云数据库 Redis(TencentDB for Redis)是腾讯云打造的兼容 Redis 协议的缓存和存储服务。丰富的数据结构能帮助您完成不同类型的业务场景开发。支持主从热备,提供自动容灾切换、数据备份、故障迁移、实例监控、在线扩容、数据回档等全套的数据库服务。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档