redis之Stream

x33g5p2x  于2021-10-29 转载在 Redis  
字(0.6k)|赞(0)|评价(0)|浏览(177)

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组读取消息,注意:从尾部读取消息,只会取最新的,所以要设置阻塞时间,等到有消息进来时才会读取到消息

相关文章

微信公众号

最新文章

更多