Redis消息队列 – 小飞侠

Redis提供了三种不同的方式来实现消息队列：

1. 基于List结构模拟消息队列

LPUSH

结合

RPOP

、或者

RPUSH

结合

LPOP

来实现。

不过要注意的是，当队列中没有消息时RPOP或LPOP操作会返回null，并不像JVM的阻塞队列那样会阻塞并等待消息。因此这里应该使用

BRPOP

或者

BLPOP

来实现阻塞效果。

优点

：

缺点

：

2. 基于PubSub的消息队列

PubSub（发布订阅）是Redis2.0版本引入的消息传递模型。顾名思义，消费者可以订阅一个或多个channel，生产者向对应channel发送消息后，所有订阅者都能收到相关消息。

命令：

pattern：

优点：

缺点：

3. 基于Stream的消息队列

Stream 是 Redis 5.0 引入的一种新数据类型，可以实现一个功能非常完善的消息队列。

发送消息的命令：

读取消息的方式之一：XREAD

STREAM类型消息队列的XREAD命令特点：

4. 基于Stream的消息队列-消费者组

消费者组（Consumer Group）：将多个消费者划分到一个组中，监听同一个队列。

特点：

消息分流	消息标示	消息确认
队列中的消息会分流给组内的不同消费者，而不是重复消费，从而加快消息处理的速度	消费者组会维护一个标示，记录最后一个被处理的消息，哪怕消费者宕机重启，还会从标示之后读取消息。确保每一个消息都会被消费	消费者获取消息后，消息处于pending状态，并存入一个pending-list。当处理完成后需要通过 XACK 来确认消息，标记消息为已处理，才会从pending-list移除。

创建消费者组：

给指定的消费者组添加消费者：

GROUP CREATECONSUMER key groupname consumername

删除指定的消费者组：

XGROUP DESTORY key gruopName

删除消费者组中的指定消费者：

GROUP DELCONSUMER key groupname consumername

从消费者组读取消息：

group：消费组名称
consumer：消费者名称，如果消费者不存在，会自动创建一个消费者
count：本次查询的最大数量
BLOCK milliseconds：当没有消息时最长等待时间
NOACK：无需手动ACK，获取到消息后自动确认
STREAMS key：指定队列名称
ID：获取消息的起始ID：
- “>”：从下一个未消费的消息开始
- 其它：根据指定id从pending-list中获取已消费但未确认的消息，例如0，是从pending-list中的第一个消息开始

STREAM类型消息队列的XREADGROUP命令特点：

	List	PubSub	Stream
消息持久化	支持	不支持	支持
阻塞读取	支持	支持	支持
消息堆积处理	受限于内存空间，可以利用多消费者加快处理	受限于消费者缓冲区	受限于队列长度，可以利用消费者组提高消费速度，减少堆积
消息确认机制	不支持	不支持	支持
消息回溯	不支持	不支持	支持