如何使用Redis做异步队列?
1.使用List作为队列,RPUSH生产消息,LPOP消费消息
缺点:没有等待队列里有值就直接消费
弥补:可以通过在应用层引入Sleep机制去调用LPOP重试
如果没有消息的时候,可以使用BLPOP去等待,直到队列里有消息
以上的生产者消费者模式的缺点在于只能供一个消费者消费,消费完了就没了。想要实现生产一次,让多个消费者消费。
2.使用redis的pub/sub主题订阅者模式,实现一对多的消费队列。
发送者(pub)发送消息,订阅者(sub)接收消息。
订阅者可以订阅任意数量的频道。
缺点:消息的发布是无状态的,无法保证可达。对发布者来说,消息即发即失,如果某个消费者在生产者发布消息的时候下线,重新上线后接收不到该消息。
主题订阅者模式:
Publisher发布消息,通过Topic发送给订阅该消息的三个客户端。
实践:
List
BLPOP:
两个客户端模拟生产者和消费者
等待30s
pub/sub:
订阅频道
发布消息:往不同频道发送消息,监听不同频道的 sub接收到不同的消息