"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 总结通过消费者组与确认机制，可以实现至少一次投递与挂起恢复，保证处理可靠性。