写入与读取
写入与读取
XADD orders * user u1 amount 99 # * 自动生成 ID,如 1737100000000-0
XADD orders * user u2 amount 12
XLEN orders
XRANGE orders - + COUNT 10 # 从头读
XREVRANGE orders + - COUNT 10 # 从尾读
XREAD COUNT 5 BLOCK 3000 STREAMS orders $ # 阻塞 3s 读「新」消息($=只读新)
XTRIM orders MAXLEN ~ 100000 # 近似裁剪,防无限增长| 消息 ID | 毫秒时间戳-序号,单调递增,支持范围查询 |
|---|---|
| $ 与 0 | $=从现在起的新消息;0=从头(含历史) |
| 阻塞读 | BLOCK 毫秒,0 表示永久阻塞 |
与 List 队列相比:Stream 支持多条消费者组、ACK、回溯与多播,是更完整的消息方案。