redis基于Stream类型实现消息队列，命令操作，术语概念，个人总结等

news2025/4/5 13:29:15

个人大白话总结

1 在Redis Stream中，即使消息被消费者确认（acknowledged, ACK），消息也不会自动从Stream数据结构中删除。这与Kafka或RabbitMQ等传统消息队列系统的做法不同，在那些系统中，一旦消息被消费并确认，通常会被从队列中移除以释放存储空间。

2 若一个Stream中有5条消息，并且存在两个消费者组，这两个消费者组可以各自独立地消费这些消息，即所有消息对于不同消费者组来说是“广播”的，这一点类似于Kafka中的逻辑，每个消费者组都会按照其自身的消费进度处理消息。

3 在同一个消费者组内部如果有两个消费者A和B，若A已消费了3条消息，则剩余的2条消息将可供B或其他消费者消费。这意味着同一个消费者组内的多个消费者之间遵循竞争消费模式（Competitive Consumer Pattern），确保消息仅被组内一个消费者消费一次。

4 当消费者从Stream中读取消息并开始处理时，它们会在本地维护一个Pending（待处理）列表，并将接收到的消息存入其中。当消费者完成对某条消息的处理并成功提交确认（acknowledge, ACK）后，该条消息会在消费者本地的Pending列表中被移除或者被标记为已处理状态。这种设计确保了消息的有序消费、状态跟踪以及防止消息被重复消费，因为只有当消息被确认处理完成后，才会从本地Pending列表中清除，从而允许消费者获取并处理新的消息。