Redis基于Stream的消息队列 - 消费者组模式

Posted 2023-03-03 世界尽头与你

Redis基于Stream的消息队列 - 消费者组模式

• 1.消费者组
• 2.使用说明
• 3.Java使用

1.消费者组

消费者组（Consumer Group)：将多个消费者划分到一个组中，监听同一个队列。具备下列特点：

消息分流：

队列中的消息会分流给组内的不同消费者，而不是重复消费，从而加快消息处理的速度

消息标识：

消费者组会维护一个标示，记录最后一个被处理的消息，哪怕消费者宕机重启，还会从标示之后读取消息。确保每一个消息都会被消费

消息确认：

消费者获取消息后，消息处于pending状态，并存入一个pending-list。当处理完成后需要通过XACK来确认消息，标记消息为已处理，才会从pending-list移除。

---

2.使用说明

创建消费者组：

常见其他命令：

从消费者组读取消息：

---

3.Java使用

Java消费者监听消息的基本思路：