Redis 发布订阅模式（7）

列表的局限

前面我们说通过队列的rpush和lpop可以实现消息队列（队尾进队头出），但是消费者需要不停地调用lpop查看List中是否有等待处理的消息（比如写一个while循环）。为了减少通信的消耗，可以sleep()一段时间再消费，但是会有两个问题：

1、如果生产者生产消息的速度远大于消费者消费消息的速度，List会占用大量的内存。

2、消息的实时性降低。list还提供了一个阻塞的命令：blpop，没有任何元素可以弹出的时候，连接会被阻塞。

基于list实现的消息队列，不支持一对多的消息分发。

发布订阅模式

除了通过list实现消息队列之外，Redis还提供了一组命令实现发布/订阅模式。

这种方式，发送者和接收者没有直接关联（实现了解耦），接收者也不需要持续尝试获取消息。

订阅频道

首先，我们有很多的频道（channel），我们也可以把这个频道理解成queue。订阅者可以订阅一个或者多个频道。消息的发布者（生产者）可以给指定的频道发布消息。只要有消息到达了频道，所有订阅了这个频道的订阅者都会收到这条消息。

需要注意的注意是，发出去的消息不会被持久化，因为它已经从队列里面移除了，所以消费者只能收到它开始订阅这个频道之后发布的消息。

下面我们来看一下发布订阅命令的使用方法。

订阅者订阅频道：可以一次订阅多个，比如这个客户端订阅了3个频道。

127.0.0.1:6379> subscribe topic1 topic2 topic3
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "topic1"
3) (integer) 1
1) "subscribe"
2) "topic2"
3) (integer) 2
1) "subscribe"
2) "topic3"
3) (integer) 3

发布者可以向指定频道发布消息（并不支持一次向多个频道发送消息）：

127.0.0.1:6379> publish topic1 222222
(integer) 1

### 消息订阅方收到的信息

1) "message"
2) "topic1"
3) "222222"

取消订阅（不能在订阅状态下使用）：

unsubscribe topic1

按规则（Pattern）订阅频道

支持?和*占位符。?代表一个字符，*代表0个或者多个字符。

消费端（订阅方）
psubscribe news* 
psubscribe news-word 
psubscribe *message

生产者（发布方）
publish news-word1 111111
publish news-message 1111
publish sms-message 1111

注意：Redis无法保证消息的可靠投递，当发送的消息没有接收方时，会造成数据丢失。正式环境建议使用专业MQ。