redis：延迟队列

àì夳堔傛蜴生んèń 2022-09-14 14:21 134阅读 0赞

# 异步消息队列 #

redis的list数据结构常用作异步消息队列使用，用rpush、lpop、lpush、rpop操作  
![在这里插入图片描述][09ed7bc5365440ceabda86ce24f69278.png]  
可以支持多个生产者和多个消费者并发进出消息，每个消费者拿到的消息都是不同的列表元素  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAT2NlYW4mJlN0YXI_size_20_color_FFFFFF_t_70_g_se_x_16]

7.0.0.1:6379> rpush notify-queue apple banana pear
    (integer) 3
    127.0.0.1:6379> llen notify-queue
    (integer) 3
    127.0.0.1:6379> lpop notify-queue
    "apple"
    127.0.0.1:6379> lpop notify-queue
    "banana"
    127.0.0.1:6379> lpop notify-queue
    "pear"
    127.0.0.1:6379> lpop notify-queue
    (nil)

> 队列空了怎么办

客户端通过队列的pop操作来换取消息，然后进行处理。处理完了再接着换取消息，再进行处理。

可以如果队列空了，客户端就会陷入pop的死循环，不停的pop，没有数据。。。空轮询不仅拉高了客户端的CPU消耗，redis的QPS也会被拉高，如果这样空轮询的客户端有几十个，redis的慢查询可能会显著增多

解决：通过通过sleep来解决这个问题，让线程睡一会。

sleep(1);

> 阻塞读

用上面睡眠的方法可以解决问题，但是又出现了了问题，那就是睡眠会导致消息的延迟增大。

除了缩短睡眠时间外，还有什么好的解决方法吗？ 有，那就是 **blpop/brpop**

b就是blocking，也就是阻塞读。

阻塞读在队列没有数据的时候，会立即进入休眠状态，一旦数据来了，则立即醒过来

127.0.0.1:6379> blpop notify-queue 100
    1) "notify-queue"
    2) "banana"

在以上实例中，操作会被阻塞，如果指定的列表 key notify-queue存在数据则会返回第一个元素，否则在等待100秒后会返回 nil 。

> 空闲连接自动断开

上面的方案还是有缺陷：

*  如果线程一直阻塞在那里，redis的客户端连接就成了闲置连接，闲置过久，服务端一般会断开连接（？？？？？？待验证），减少闲置资源占用。这个时候blpop和brpop会抛出异常
 *  所以客户端消费者必须小心，如果捕获道异常，还要重试

# 延迟队列的实现 #

*  延迟队列可以通过redis的zset（有序列表）实现。我们将消息序列化成一个字符串作为zset的value，这个消息的到期处理时间作为score，然后用多个线程轮询zset获取到期的任务进行处理
 *  多个线程是为了保障可用性，万一挂了一个线程还有其他线程可以继续处理
 *  因为有多个线程，所以需要考虑并非争抢任务，确保任务不会被多次执行

[09ed7bc5365440ceabda86ce24f69278.png]: /images/20220828/d7fc3a7e8ac141f2b95aefec4f232991.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAT2NlYW4mJlN0YXI_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/163d030c3d8146ac8247c206050564e8.png