> 叙事主角：老李，AI 时代的互联网架构师

---
![image.png](https://developer.qcloudimg.com/http-save/yehe-9261324/604d5a221bbed6a8e4c55fc1c7386294.png)

---

## 一、痛点引入

> *"春蚕到死丝方尽，蜡炬成灰泪始干。"*

老李最近接到一个需求：电商平台的订单创建后，需要异步通知库存服务扣减库存、通知积分服务发放积分、通知短信服务发送确认短信。

产品经理说：「并发不高，TPS 峰值撑死 500，但消息不能丢。」

老李打开方案评审文档，一列同事写的方案：**引入 Kafka**。

Kafka？一个集群最少三台 Broker + ZooKeeper，运维复杂度直接拉满，监控告警一大堆。老李摇摇头——**杀鸡焉用牛刀**。

架构选型的本质是：**用最低的复杂度，解决当前规模的问题**。Redis 早已内置了多种消息队列能力，Spring Boot 生态完善，接入成本极低。

---

## 二、是什么：Redis 的三种 MQ 模式

> *"横看成岭侧成峰，远近高低各不同。"*

Redis 提供了三种做消息队列的方式，能力递增：

| 模式 | 核心命令 | 特点 | 适用场景 |
|------|----------|------|----------|
| **List 队列** | LPUSH / BRPOP | 简单可靠，FIFO，单消费者 | 任务队列、轻量异步 |
| **Pub/Sub 发布订阅** | PUBLISH / SUBSCRIBE | 广播模式，消息不持久化 | 实时通知、聊天 |
| **Stream 流** | XADD / XREADGROUP | 持久化、消费者组、ACK | 生产级 MQ 替代 |

**Stream 是 Redis 5.0 引入的终极答案**，支持消费者组、消息确认、消息回溯，是最接近 Kafka 语义的轻量方案。

---

## 三、为什么用 Redis 做 MQ

> *"不识庐山真面目，只缘身在此山中。"*

**三大理由让老李选择 Redis MQ：**

1. **基础设施复用**：99% 的 Spring Boot 项目已经引入 Redis 做缓存，不引入新组件，运维零负担。
2. **延迟极低**：Redis 内存操作，P99 延迟 < 1ms，远优于 Kafka 磁盘顺序写的毫秒级延迟。
3. **Spring 原生支持**：`spring-data-redis` + `spring-boot-starter-data-redis` 开箱即用，RedisTemplate 直接搞定。

**适合用 Redis MQ 的场景：**
- 订单异步处理、积分发放等低并发异步任务
- 延迟任务（结合 ZSet TTL 实现）
- 微服务内部事件通知
- 秒杀、限流等短时高频场景

**不适合的场景：**
- 日均亿级消息吞吐（上 Kafka/RocketMQ）
- 强事务保障的金融核心链路

---

## 四、架构图：三种模式全景

> *"会当凌绝顶，一览众山小。"*

![image.png](https://developer.qcloudimg.com/http-save/yehe-9261324/f82fc00c5698ec16e285c4adfec0b4d6.png)

---

## 五、安装配置

> *"工欲善其事，必先利其器。"*

### 1. 依赖引入（pom.xml）

```xml
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

<dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-pool2</artifactId>
</dependency>
```

### 2. application.yml 配置

```yaml
spring:
  redis:
    host: localhost
    port: 6379
    password: your_password
    lettuce:
      pool:
        max-active: 16
        max-idle: 8
        min-idle: 2
```

### 3. RedisTemplate Bean 配置

```java
@Configuration
public class RedisConfig {

    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(factory);
        // 使用 JSON 序列化
        Jackson2JsonRedisSerializer<Object> serializer =
            new Jackson2JsonRedisSerializer<>(Object.class);
        template.setValueSerializer(serializer);
        template.setHashValueSerializer(serializer);
        template.setKeySerializer(new StringRedisSerializer());
        template.setHashKeySerializer(new StringRedisSerializer());
        template.afterPropertiesSet();
        return template;
    }
}
```

> 💡 **AI 提效提示**：以上配置让 Claude Code / CodeBuddy 直接生成，描述「Spring Boot Redis 连接池配置，Lettuce，JSON 序列化」即可秒出。

---

## 六、实战演示

> *"纸上得来终觉浅，绝知此事要躬行。"*

### 模式一：List 队列（推荐入门）

**生产者 - 订单服务推送消息：**

```java
@Service
@RequiredArgsConstructor
public class OrderProducer {

    private final RedisTemplate<String, Object> redisTemplate;
    private static final String ORDER_QUEUE = "queue:order:new";

    public void sendOrder(OrderMessage message) {
        // LPUSH 推入队列左端
        redisTemplate.opsForList().leftPush(ORDER_QUEUE, message);
        log.info("订单消息已入队: {}", message.getOrderId());
    }
}
```

**消费者 - 库存服务阻塞消费：**

```java
@Component
@RequiredArgsConstructor
@Slf4j
public class InventoryConsumer {

    private final RedisTemplate<String, Object> redisTemplate;
    private static final String ORDER_QUEUE = "queue:order:new";

    @Scheduled(fixedDelay = 100)  // 每 100ms 轮询一次
    public void consume() {
        // BRPOP 阻塞式从右端弹出，超时 2 秒
        Object message = redisTemplate.opsForList()
            .rightPop(ORDER_QUEUE, Duration.ofSeconds(2));
        if (message != null) {
            OrderMessage order = (OrderMessage) message;
            log.info("消费订单消息，扣减库存: {}", order.getOrderId());
            // 处理业务逻辑...
        }
    }
}
```

---

### 模式二：Pub/Sub 广播（实时通知）

**发布者：**

```java
@Service
@RequiredArgsConstructor
public class NotificationPublisher {

    private final RedisTemplate<String, Object> redisTemplate;

    public void publish(String channel, Object message) {
        redisTemplate.convertAndSend(channel, message);
    }
}
```

**订阅者配置（Spring 方式）：**

```java
@Configuration
public class RedisPubSubConfig {

    @Bean
    public RedisMessageListenerContainer listenerContainer(
            RedisConnectionFactory factory,
            MessageListenerAdapter smsAdapter,
            MessageListenerAdapter pointsAdapter) {

        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(factory);
        container.addMessageListener(smsAdapter, new ChannelTopic("channel:order:created"));
        container.addMessageListener(pointsAdapter, new ChannelTopic("channel:order:created"));
        return container;
    }

    @Bean
    public MessageListenerAdapter smsAdapter(SmsService smsService) {
        return new MessageListenerAdapter(smsService, "onMessage");
    }

    @Bean
    public MessageListenerAdapter pointsAdapter(PointsService pointsService) {
        return new MessageListenerAdapter(pointsService, "onMessage");
    }
}
```

---

### 模式三：Redis Stream + 消费者组（生产推荐）

**生产者写入 Stream：**

```java
@Service
@RequiredArgsConstructor
public class StreamProducer {

    private final RedisTemplate<String, Object> redisTemplate;
    private static final String STREAM_KEY = "stream:order";

    public void send(OrderMessage order) {
        Map<String, Object> fields = new HashMap<>();
        fields.put("orderId", order.getOrderId());
        fields.put("userId", order.getUserId());
        fields.put("amount", order.getAmount().toString());

        // XADD 写入 Stream，自动生成 MessageId
        redisTemplate.opsForStream().add(
            StreamRecords.newRecord()
                .in(STREAM_KEY)
                .ofMap(fields)
        );
    }
}
```

**消费者组监听（Spring Data Redis Stream Listener）：**

```java
@Component
@RequiredArgsConstructor
@Slf4j
public class StreamOrderConsumer implements StreamListener<String, MapRecord<String, String, String>> {

    private final RedisTemplate<String, Object> redisTemplate;
    private static final String STREAM_KEY = "stream:order";
    private static final String GROUP = "inventory-group";

    @Override
    public void onMessage(MapRecord<String, String, String> message) {
        log.info("Stream 消息接收: id={}, body={}", message.getId(), message.getValue());
        // 处理业务...

        // 手动 ACK，确认消费成功
        redisTemplate.opsForStream().acknowledge(STREAM_KEY, GROUP, message.getId());
    }
}
```

**注册 Stream 监听容器：**

```java
@Bean
public StreamMessageListenerContainer<String, MapRecord<String, String, String>>
    streamContainer(RedisConnectionFactory factory, StreamOrderConsumer consumer) {

    StreamMessageListenerContainer.StreamMessageListenerContainerOptions<String,
        MapRecord<String, String, String>> options =
        StreamMessageListenerContainer.StreamMessageListenerContainerOptions
            .builder()
            .pollTimeout(Duration.ofSeconds(1))
            .build();

    StreamMessageListenerContainer<String, MapRecord<String, String, String>>
        container = StreamMessageListenerContainer.create(factory, options);

    container.receive(
        Consumer.from("inventory-group", "consumer-1"),
        StreamOffset.create("stream:order", ReadOffset.lastConsumed()),
        consumer
    );
    container.start();
    return container;
}
```

---

## 七、三条洞见

> *"问渠那得清如许，为有源头活水来。"*

### 洞见一：消息可靠性要用 Stream，不要用 List

List 的 BRPOP 弹出即删除，消费者崩溃则消息永久丢失。Stream 的 XREADGROUP + XACK 机制，消费失败消息留在 PEL（Pending Entry List）可重新投递。

![image.png](https://developer.qcloudimg.com/http-save/yehe-9261324/50102df6dd5cecff25d73807b478be70.png)

---

### 洞见二：延迟队列用 ZSet，时间戳当 Score

Redis 没有原生延迟队列，但 ZSet（有序集合）天然支持按分数排序。将消息执行时间戳作为 Score，定时轮询 `ZRANGEBYSCORE` 取到期消息。

![image.png](https://developer.qcloudimg.com/http-save/yehe-9261324/d1c2f93b520135737f224b99d01ffa49.png)

---

### 洞见三：消费者组水平扩展，实现并行消费

Stream 消费者组允许多个消费者实例共同消费同一个 Stream，每条消息只会被组内一个消费者处理，天然实现负载均衡。

![image.png](https://developer.qcloudimg.com/http-save/yehe-9261324/9a6ca33cbdf7827f2e2edabf06443dcf.png)

> **水平扩容只需新增 Pod**，无需修改任何配置，Kubernetes HPA 直接支持。

---

## 八、总结方法论

> *"不经一番寒彻骨，怎得梅花扑鼻香。"*

**老李的架构选型口诀：** 能用 Redis 搞定的，不上 Kafka；能单机搞定的，不上集群。复杂度是工程债务，偿还的是下一任维护者的时间。

![image.png](https://developer.qcloudimg.com/http-save/yehe-9261324/e3bceb19a3b0deef546cc32deef84cdf.png)

---

## 方法论速查表

| 场景 | 推荐模式 | 核心命令 | 消息持久化 | 消费者组 |
|------|----------|----------|------------|----------|
| 轻量异步任务 | List 队列 | LPUSH / BRPOP | ❌ | ❌ |
| 实时广播通知 | Pub/Sub | PUBLISH / SUBSCRIBE | ❌ | ❌ |
| 生产级异步处理 | Stream | XADD / XREADGROUP | ✅ | ✅ |
| 延迟任务调度 | ZSet | ZADD / ZRANGEBYSCORE | ✅ | ❌ |
| 高吞吐亿级消息 | Kafka / RocketMQ | — | ✅ | ✅ |

> **行动号召**：下次架构评审遇到「引入 Kafka」的提案，先问一句——**当前 TPS 是多少？Redis Stream 够用吗？** 省下一套 Kafka 集群的运维成本，就是架构师的价值所在。

老李最近接到一个需求：电商平台的订单创建后，需要异步通知库存服务扣减库存、通知积分服务发放积分、通知短信服务发送确认短信。

别再滥用MQ了！Redis 当消息队列，Spring Boot 接入只需 5 分钟

能用 Redis 搞定的，不上 Kafka；能单机搞定的，不上集群。复杂度是工程债务，偿还的是下一任维护者的时间。

架构师

数据库

后端

开发工具

Redis提供三种消息队列模式：List队列适合轻量异步任务，Pub/Sub实现实时广播，Stream支持持久化和消费者组。RedisMQ复用现有基础设施，延迟低于1ms，SpringBoot原生支持，是低并发异步处理的理想选择。适用于订单处理、积分发放等场景，避免Kafka的运维负担。

消息队列

负载均衡

短信

容器

Redis

Kafka

JSON

2026采购季 | AI焕新·智启新局

message-queue-catalog

文章

问答

视频

教程

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云智能顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云AI代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

功能1上新10个字符

功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符。

功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符。

功能5描述100个字符功能5描述100个字符功能5描述100个字符功能5描述100个字符功能5描述100个字符功能5描述100个字符

功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符

功能4上新

文章&问答评论现已支持表情

全新交互，全新视觉，新增快捷键、悬浮工具栏、高亮块等功能并同时优化现有功能，全面提升创作效率和体验

社区富文本编辑器全新改版！诚邀体验～ 

精选全网热门MCP server，让你的AI更好用 🚀

💥开发者 MCP广场重磅上线！

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

聚焦“写作效率、视觉美观与运行性能”三方面进行全面升级，为您提供更高效、稳定的创作环境

社区富文本&Markdown编辑器全新改版上线，欢迎大家体验!

诚挚邀请您参与本次调研，分享您的真实使用感受与建议。您的反馈至关重要，感谢您的支持与参与！

社区新版编辑器体验调研

别再滥用MQ了！Redis 当消息队列，Spring Boot 接入只需 5 分钟-腾讯云开发者社区-腾讯云

别再滥用MQ了！Redis 当消息队列，Spring Boot 接入只需 5 分钟

别再滥用MQ了！Redis 当消息队列，Spring Boot 接入只需 5 分钟

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐