前言:感觉这个好像没啥用,我没学过mq,好像这个东西用别的中间件比较好,比如kafka,rabbitmq
常用指令:
队列的常用指令:
xadd key *|id field value [field value]
xrange key - + [count n] //-表示最小,+表示最大
xrevrange key + - [count n] //上述反转
xdel key id
xlen key
xtrim key maxlen n //截取,允许的最大长度,先丢小的 xtrim key minid n //允许的最小的,比他小的都丢
xread [count n] [block milliseconds] streams key [key] id [id] //block默认是不阻塞,milliseconds为0就是永久阻塞
$表示特殊id,当前的最大的id的后一个就是$,所以用这个的时候就是找不到东西
0-0表示最小id
消费者的常用命令:
xgroup create key group $|0//用于创建消费者组,id为0表示从头开始消费,为$表示只消费新消息
xreadgroup GROUP group consumer1 [count n] STREAMS stream > //>表示从第一条尚未被消费的消息开始读取