| 语法 | XAUTOCLAIM key group consumer min-idle-time start [COUNT n] [JUSTID] |
|---|---|
| 场景 | 消费者故障恢复 |
| 配套 | XPENDING 观察积压 |
示例
示例
redis-cli XAUTOCLAIM orders g1 worker-b 60000 0 COUNT 100认领后务必处理并 XACK，否则消息再次滞留在 pending 列表。
本包目录（421 条）
数据结构与选型42 条
- 分布式锁：SET NX PX 与安全释放
- Cache Aside：旁路缓存的读写顺序
- ZSet 排行榜：排名分页与同分处理
- Bitmap 位图签到与活跃标记
- Lua 脚本：原子执行与 EVALSHA
- ZSet 延时队列：分数存执行时间
- 五种结构选型对照表
- 计数器设计：INCR 与热点分摊
- 滑动窗口限流：ZSet 加 Lua
- Pub/Sub 与 Stream：消息语义对比
- Hash 编码：listpack 与 hashtable 切换
- HyperLogLog 基数统计
- Stream 消费组：XGROUP 与 XREADGROUP
- 缓存穿透：空值缓存与布隆过滤器
- ZSet 跳表编码与内存拐点
- Stream 消息写入：XADD 与 ID 规则
- GEO 地理检索：GEOADD 与 GEOSEARCH
- 缓存雪崩与 TTL 打散
- OBJECT ENCODING 查看键的底层编码
- XPENDING 与 XCLAIM 处理未确认消息
- 对象缓存：String 存 JSON 与 Hash 的取舍
- 热点 Key 击穿：互斥重建与逻辑过期
- String 与 SDS 结构：编码差异与内存
- quicklist 与 list-max-listpack-size
- 键名设计：分层命名与长度控制
- Lua 脚本的限制与超时行为
- 令牌桶限流：Hash 加时间差补桶
- listpack 紧凑列表结构
- Stream 容量控制：MAXLEN 与 XTRIM
- Hash 字段更新与计数：HINCRBY 家族
- 编码阈值调优：先测再调
- intset 整数集合与 Set 内存
- BITFIELD 位域计数器
- RedisJSON：结构化文档读写
- XAUTOCLAIM：认领超时消息
- ZADD 的 GT/LT：条件更新分数
- GETDEL 与 GETEX：原子取删与 TTL 维护
- SINTERCARD：带上限的交集计数
- LMPOP：多键弹出首选非空
- COPY：实例内复制键
- PFMERGE：合并多个 HyperLogLog
- SETRANGE：定长字段原位更新
XAUTOCLAIM：认领超时消息
XAUTOCLAIM 把满足最小空闲时间的 pending 消息转移给当前消费者，用于消费者宕机后的消息回收，可配合 JUSTID 只取 ID。
易错点
- 认领无上限，瞬间拉取海量消息压垮消费者
- 认领后未 XACK，pending 越滚越大
数据来源与参考
- Redis 官方文档：XAUTOCLAIM 说明