- 1.Stream基本介绍
- 2.基本命令
- 3.消息消费
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 mes3.消息消费
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组读取消息，注意：从尾部读取消息，只会取最新的，所以要设置阻塞时间，等到有消息进来时才会读取到消息
