stream是一个轻量级的消息队列,可以用来解决发布订阅功能的一些局限性,比如消息无法持久化,无法记录历史信息
*号表示自动生成一个消息的id,添加的消息内容是redis
geekhour为消息的名字,可以看到有三条消息
这里的-和+可以表示所有的信息
删除指定信息
删除所有信息
手动指定ID
消息创建之后如何消费呢?
使用XREAD命令来读取信息,COUNT 2表示一次读取两条信息,BLOCK表示如果欸有信息的话,就阻塞1000毫秒 也就是1秒。streams后面加上消息队列的名称,0表示从头读取。
将0换成$,则可以获取最新消息
创建消费者组
在消费者组中添加消费者,创建消费者组的命令是XGROUP,后面加上一个CREATE,然后加上消息的名称,group1是组的名称,0是id
这样就创建了一个叫做group1的消费者组
查看消费者组的信息,返回了组的名称,消费者的数量,待处理的消息数等
在group1添加消费者consumer1
读取消息
count 2表示一次读取两条消息,
>右箭头白哦是从这个信息中读取最新的信息