1.Stream基本介绍

1.从redis5.0开始，推出了Stream功能。在Stream中有一个消息链表，所有加入链表中的消息都会被串起来，每一条消息都有自己唯一的ID，还有对应的消息内容，消息内容就是key-value。一个Stream上可以有多个消费者，每个消费者都有一个游标，用于访问消息，在消息链表移动就代表着消费消息，多个消费者之间互不影响。

2.基本命令

1.xadd，添加消息，返回的是消息的ID

xadd mes * name xiaoming age 13

2.xlen,获取消息长度

xlen mes

3.xdel，删除消息

xdel mes 1635437380918-0

4.xrange，获取消息列表，-代表最小值，+代表最大值

xrange mes - +

5.del，删除Stream

del mes

3.消息消费

1.xread命令实现消费
1）先在消息链中加数据

2）从消息链头部开启读取1条消息，0-0代表头部

xread count 1 streams mes 0-0

3）从消息链尾部读取消息，block 0代表永远阻塞，知道有消息进来，$代表从消息链尾部开始读取消息

xread count 1 block 0 streams mes $

2.xreadgroup命令，通过消费组来实现消费消息
1）创建消费组，g1组从头部开启读取消息，g2组从尾部开始读取消息

2）xreadgroup读取消息，通过游标一个一个读取
g1组读取消息：

g2组读取消息，注意：从尾部读取消息，只会取最新的，所以要设置阻塞时间，等到有消息进来时才会读取到消息