其中包括: 生成消息ID, 消息确认, 分组消费等功能.
Stream有一个消息链表, 将所有加入的消息都串联起来, 每个消息都有一个唯一的ID和对应的内容....消息是持久化的, Redis重启时, 消息不会丢失.
1
XADD
向指定队列中添加信息.
xadd key [NOMKSTREAM] [MAXLEN|MINID [=|~] threshold [LIMIT...ID,可以自定义或Redis 自动生成; 自定义生成时, 需要保证单调递增; 使用符号"*"表示由Redis生成; 按时间戳-序号规则生成, 其中时间戳是毫秒级的Redis服务器时间;
field value...可以减轻 Redis服务准确计算队列长度的压力;
127.0.0.1:6379> XTRIM mystream MAXLEN ~ 1000
6
XDEL
删除指定ID消息
127.0.0.1:6379>...同一消费组中, 可以有多个消费者, 协同消费消息, 每读取一条消息, last_delivered_id都会下移一位, 同时会记录在PEL(pending_ids)中, 直到消息被ACK确认后, 才会从