Redis 如何实现消息队列？

Question

Redis 如何实现消息队列？

仓乃文 · Accepted Answer

Redis 可以用 List 的 BLPOP/BRPOP 实现简单消息队列，或用 Stream 类型实现更完善的消息队列（支持消费者组、消息确认）。 List 实现（简单场景）： ```java // 生产者：LPUSH 入队 redisTemplate.opsForList().leftPush("task:queue", taskJson); // 消费者：BRPOP 阻塞出队（超时 30 秒） String task = redisTemplate.opsForList() .rightPop("task:queue", 30, TimeUnit.SECONDS); ``` Stream 实现（推荐，支持消费者组）： ```java // 生产者：XADD 添加消息 Map message = Map.of( "type", "send_email", "to", "user@example.com" ); RecordId msgId = redisTemplate.opsForStream() .add("mystream", message); // 创建消费者组 redisTemplate.opsForStream() .createGroup("mystream", "email-group"); // 消费者：XREADGROUP 读取消息 List> messages = redisTemplate .opsForStream() .read( Consumer.from("email-group", "consumer-1"), StreamReadOptions.empty().count(10).block(Duration.ofSeconds(5)), StreamOffset.create("mystream", ReadOffset.lastConsumed()) ); // 确认消息 redisTemplate.opsForStream() .acknowledge("mystream", "email-group", msgId); ``` 补充说明： - List 方案简单但消息不持久化，消费者宕机会丢失消息 - Stream 支持消费者组、消息确认、消息回溯，功能更完善 - Redis 5.0+ 才支持 Stream，旧版本用 List 或 Pub/Sub - 专业消息队列（RabbitMQ、Kafka）在可靠性和功能上更完善