使用Redis Streams作为高并发消息队列的核心方案，通过XADD命令快速生产消息，XREAD或XREADGROUP实现消费，支持消费者组避免重复消费。高并发下，应对消息积压可采用多实例消费者水平扩展、设置阻塞读取XREAD BLOCK参数优化空轮询；性能瓶颈解决：开启pipeline批量操作、Lua脚本原子化处理、配置合理的maxmemory-policy allkeys-lru内存淘汰，并结合Redis Cluster分片扩展容量。代码示例：生产消息：XADD mystream * field value；消费：XREAD BLOCK 0 COUNT 10 STREAMS mystream 0。

方案一：Redis Streams + 消费者组

Redis Streams是专门为消息队列设计的，支持消费者组（Consumer Groups），可以实现可靠的消息传递和负载均衡。在高并发场景下，使用消费者组可以让多个消费者并行消费消息，避免单点瓶颈。对于消息积压，可以动态增加消费者实例来加速消费速度。

方案二：环形缓冲区 + 多线程消费

Redis List作为环形缓冲区，LPUSH/RPOP实现生产消费，应对高并发用RPOPLPUSH做阻塞弹出。消息积压时，启动多线程消费者同时从队列头取出消息处理，设置lpush和rpop的pipeline批量提交减少RTT。性能瓶颈通过调整list-max-ziplist-entries参数优化内存使用。

方案三：Pub/Sub + 持久化List

Pub/Sub适合实时性要求高的场景，但不持久化，可结合List实现ACK机制。积压问题：用BRPOP阻塞等待，消费者空闲时不占CPU。高并发性能：多订阅者分担负载，积压超阈值时切换到Stream模式。瓶颈解决：设置pubsub客户端缓存，避免网络抖动。

扩展策略

1. 水平扩展：部署Redis Cluster，多主多从分片队列。2. 限流：生产端用令牌桶算法控制QPS。3. 死信队列：消费失败N次后移到死信Stream，手动重试。4. 监控：用INFO和redis-cli --latency监控积压长度和延迟。

优化性能细节

使用Lua脚本原子执行XACK确认和业务逻辑，减少网络往返；pipeline打包多个XREAD命令；配置tcp-keepalive和timeout避免长连接问题；高并发下用连接池如JedisCluster管理连接。

实战配置

redis.conf中：maxmemory 4gb、maxmemory-policy allkeys-lru、tcp-backlog 511、timeout 0。客户端：设置线程池大小等于CPU核数*2，队列深度监控脚本：if LLEN queue > 10000 then alert。

FAQ
Q: Redis消息队列积压怎么快速消化？
A: 增加消费者实例数，使用多线程并行消费，临时开启备用队列分流。
Q: 高并发下Redis性能怎么调优？
A: 开启pipeline、Lua脚本、连接池，监控slowlog清除热点key。
Q: Stream和List哪个更适合高并发MQ？
A: Stream更适合，支持ACK和消费者组，List简单但无原生去重。
Q: 消息丢失怎么避免？
A: 生产用WATCH+事务或Lua，消费阻塞读取+ACK机制，主从异步复制加AOF持久化。