1. 消息队列概述
消息队列（Message Queue，MQ）是分布式系统中实现异步通信的核心中间件。它通过生产者-消费者模型，将消息的发送与接收解耦，使系统各模块能够独立演进、弹性伸缩。本章从核心概念、应用场景和主流产品对比三个维度，为后续基于 Redis 构建消息队列打下理论基础。
1.1 核心概念
消息队列涉及以下关键角色与机制：
| 概念 | 说明 | 类比 |
|---|---|---|
| 生产者（Producer） | 发送消息的一方，负责将业务数据封装为消息并投递到队列 | 寄信人 |
| 消费者（Consumer） | 接收并处理消息的一方，从队列中拉取或由队列推送消息 | 收信人 |
| 队列（Queue） | 消息的临时存储容器，遵循先进先出（FIFO）原则 | 信箱 |
| 主题（Topic） | 消息的逻辑分类，支持发布/订阅模式，一对多分发 | 报纸栏目 |
| 消息确认（ACK） | 消费者处理完成后向队列发送确认，防止消息丢失 | 回执 |
| 死信队列（DLQ） | 存放无法被正常消费的消息，用于异常排查与重试 | 退信处 |
关键指标：消息队列的性能通常用吞吐量（TPS）、延迟（P99/P999）、持久化能力和可用性来衡量。不同场景对这四个指标的侧重差异很大。
1.2 三大核心应用场景
消息队列在分布式架构中主要解决三类问题：
-
解耦（Decoupling）
模块间不直接调用，通过队列传递数据。例如订单系统下单后，只需向队列发送一条“订单已创建”消息，库存、物流、积分等系统各自订阅处理，任一子系统故障不影响主流程。 -
异步（Asynchrony）
将非核心操作从同步链路中剥离。用户注册时，写入数据库后立即返回成功，而发送欢迎邮件、初始化推荐数据等耗时操作异步执行，将接口响应时间从 800ms 降至 50ms。 -
削峰填谷（Peak Clipping）
应对突发流量，将瞬时请求暂存到队列中，由消费者按自身处理能力匀速消费。秒杀场景下，队列可缓冲百万级请求，防止数据库被击穿。
实战视角：在 Redis 消息队列设计中，解耦和异步是核心收益，削峰则需要额外关注队列长度监控和背压（Backpressure）策略，避免内存溢出。
1.3 常见消息队列对比
当前主流的消息队列产品各有侧重，选择时需结合业务场景、运维能力和数据一致性要求综合评估。
| 特性 | RabbitMQ | Kafka | Redis |
|---|---|---|---|
| 定位 | 通用消息代理 | 分布式流处理平台 | 内存数据存储 + 轻量队列 |
| 协议 | AMQP 0-9-1 / MQTT / STOMP | 自定义二进制协议 | RESP（Redis Serialization Protocol） |
| 消息模型 | Exchange + Queue 路由 | Topic + Partition 分区 | List / Pub/Sub / Stream |
| 持久化 | 支持（磁盘 + 内存） | 强持久化（磁盘） | 支持（RDB / AOF） |
| 吞吐量 | 万级 TPS | 百万级 TPS | 十万级 TPS（单机） |
| 延迟 | 微秒级 | 毫秒级 | 微秒级 |
| 消息回溯 | 有限（需插件） | 强（按 offset / 时间戳） | Stream 支持范围查询 |
| 运维复杂度 | 中等 | 高 | 低 |
| 典型场景 | 任务调度、微服务异步 | 日志采集、大数据管道 | 实时计数、轻量任务、缓存加速 |
选型提醒：Redis 作为消息队列的优势在于极低延迟和极简运维，适合中小规模、对吞吐量要求不极端、需要快速上线的场景。但 Redis 不具备 Kafka 的日志持久化和分区顺序保证，也不如 RabbitMQ 的路由灵活。本课程聚焦 Redis Stream 数据结构，在保持轻量的同时弥补了传统 List/Pub/Sub 在消息回溯和消费者组方面的不足。
1.4 为什么选择 Redis 做消息队列
在微服务和云原生架构中，Redis 消息队列的独特价值体现在：
- 多数据结构支持：List（LPUSH/BRPOP）、Pub/Sub（发布/订阅）、Stream（5.0+ 引入的持久化消息队列），可根据场景灵活选择。
- 原子操作与事务：利用 Lua 脚本或 MULTI/EXEC 实现消息的原子性投递和消费，避免并发问题。
- 内置过期与淘汰：通过 TTL 和 maxmemory 策略自动清理过期消息，降低运维成本。
- 与缓存共用实例：减少中间件数量，降低部署复杂度，适合资源受限的团队。
课程重点：本课程将深入 Redis Stream 的索引设计（时间戳 + 自定义 ID）和任务回溯查询（XRANGE / XREVRANGE + 消费者组偏移管理），让你在实战中掌握 Redis 消息队列的高阶用法。