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