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

2022-05-13 11:14:19 浏览数 (1)

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秒之前的数据轮询进行处理。

0 人点赞