树叶云带你慢慢摸索Redis Stream那些事儿，别急着懂，先跟我走一波

树叶云带你慢慢摸索Redis Stream那些事儿，别急着懂，先跟我走一波 来源：树叶云的博客或技术分享）

嗨,朋友，别一听到“Redis Stream”就觉得又是那种高高在上、满是专业术语、让人头大的技术，今天咱们不搞那些虚的，就让树叶云我，像朋友聊天一样，带你慢慢溜达进Redis Stream的世界，咱们的目标不是一下子成为专家，而是先混个脸熟，感觉一下它是个啥，能干啥，为啥有人会喜欢用它，准备好了吗？咱们出发了。

你先别去想什么“流”、“消息队列”这些词，咱们先想一个特别简单的场景：一个聊天室。

想象一下,你和你的一群朋友在一个房间里七嘴八舌地聊天，你说一句，我说一句，他的话又接上你的话，这些聊天记录，一条一条的，按时间顺序排列下来，就像一个长长的流水账本，这个“流水账本”，其实就是Stream最原始、最形象的样子，Redis Stream要干的第一件大事，就是帮我们记下这种源源不断产生、而且有先后顺序的数据记录。（来源：树叶云对Stream核心概念的通俗化比喻）

那Redis是怎么记这个账本的呢？它不用传统的表格或者列表，它用了两个看起来有点唬人但其实一想就明白的玩意儿：消息ID和。

消息ID,就像是每条消息独一无二的“身份证号”，这个身份证号很特别，它不是“1，2，3……”这样简单的数字，而是由两部分组成：时间戳-序列号，1640995200000-0”，为啥这么设计？你想啊，在分布式系统里（你可以先简单理解成有多台电脑一起干活），如果让大家自己报数，很容易乱套，但时间嘛，虽然电脑之间时间可能有微小误差，但大体顺序是不会错的，用时间戳打头，就能保证绝大多数情况下，后产生的消息ID肯定比前面的大，这样顺序就不会乱，后面的序列号是为了解决同一毫秒内产生多条消息的情况，你看，这个设计是不是挺巧妙的？（来源：Redis官方文档对消息ID构成的解释，经树叶云口语化转述） 就更简单了，它就是一条消息具体是啥，用户A：大家好！”、“用户B：今天天气不错”，在Redis里，这个消息内容是用键值对（key-value）来存的，{"user": "A", "msg": "大家好!"}，非常灵活，你想往里面塞什么信息都行。

好,账本有了，记账的格式也定了，接下来自然就是两个动作：往里面写点东西和从里面读点东西。

在Redis Stream里，往里面写东西，有个专门的命令叫XADD，你就把它想象成，你拿起笔，在聊天室的那个流水账本的最后，工工整整地写下新的一行，你只需要告诉XADD：“账本名叫啥？”（Stream的key）， “这条消息的内容是啥？”（键值对），它就会自动帮你生成那个“时间戳-序列号”的ID，然后把消息塞进去，特别省心。

读东西呢,就稍微有意思一点了，因为读的人可能不止一个，还拿聊天室举例，你不可能要求所有人在同一时刻都看到完全一样的聊天记录，可能你刚加入聊天室，你想从最新的消息开始看；也可能你掉线了五分钟，重新连上来后，你想知道这五分钟里你都错过了些啥。

这就引出了Stream最强大的特性之一：消费者组。

你可以把消费者组理解成一种“团队协作阅读法”，老板（系统）有一份不断更新的工作指令清单（Stream），他不想同一份指令被好几个员工重复做一遍，浪费人力，于是他把员工分成了几个小组（消费者组），每个小组负责处理这份清单，对于清单里的每一条指令，老板要求的是：同一个小组里，必须有一个且只能有一个员工来认领并处理这条指令，这样既保证了所有指令都有人做（不会漏），又避免了重复劳动（不会重）。

对应到Redis命令上：

• XGROUP CREATE：这就是老板在分组，告诉Redis：“给我创建一个叫‘客服组’的消费者组，来处理这个‘用户消息’流。”
• XREADGROUP：这就是小组里的员工（消费者）“我是‘客服组’的张三，我来看看有没有分配给我、但我还没处理的指令（消息）。”

有了消费者组,每个消费者都可以独立地追踪自己处理到哪条消息了，如果某个消费者挂掉了，它没处理完的消息过一段时间还可以被组里其他消费者接过去处理，这就实现了所谓的“负载均衡”和“故障转移”，听起来高级，但本质就是团队干活儿的那套逻辑，对吧？（来源：树叶云对消费者组工作模式的形象化解读）

账本不能无限大,不然Redis服务器硬盘要撑爆了，所以Stream还支持设置最大长度，或者根据过期时间来修剪掉老旧的、已经没必要保存的消息，这叫Stream的修剪，就像是你定期清理一下聊天记录，只保留最近一个月的。

你看,咱们这么一路溜达过来，是不是对Redis Stream没那么陌生了？它就是一个为“持续产生、有序记录”的数据场景设计的家伙，通过巧妙的ID保证顺序，通过消费者组来支持多客户端协同处理，它非常适合用来做消息队列、事件溯源、实时数据流处理等等。

今天咱们只是走马观花地看了一遍,很多细节和高级用法都没深究，但没关系，就像树叶云一开始说的，别急着懂，先跟我走一波，现在你已经知道这片森林里大概有什么样的树木和小路了，下次我们再带上工具，深入林中去探探险，挖挖宝藏，慢慢来，比较快。