Redis Stream 消费者组与可靠处理实践

Redis Stream 消费者组与可靠处理实践创建与生产redis-cli XADD tasks * type login user_id 123

redis-cli XGROUP CREATE tasks group1 $ MKSTREAM

消费与确认# 读取未处理与挂起消息

redis-cli XREADGROUP GROUP group1 worker1 COUNT 10 STREAMS tasks >

redis-cli XACK tasks group1 <message-id>

挂起消息与转移# 查看挂起

redis-cli XPENDING tasks group1 - + 10 worker1

# 转移超时挂起给当前消费者

redis-cli XCLAIM tasks group1 worker1 <message-id> 60000

清理与维护# 修剪流长度，保留最近 10000 条

redis-cli XTRIM tasks MAXLEN 10000

总结通过消费者组与确认机制，可以实现至少一次投递与挂起恢复，保证处理可靠性。