VIP20
本课程属于：051-消息队列任务索引选择复盘 Web后端与企业应用开发 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Redis做消息队列：索引设计与任务回溯查询实战

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
消息队列概述
消息队列的核心概念 · 应用场景（解耦 · 异步
消息队列概述消息队列的核心概…
02
Redis基础回顾
Redis数据结构（String · List · Set
Redis基础回顾
03
Redis List实现消息队列
LPUSH + BRPOP 原理 · 生产者消费者模型 · 代码实战（Python redis-…
RedisList
04
List模式优缺点分析
消息丢失风险 · 消息重复消费 · ACK机制缺失
List模式优缺点分析
05
Redis Pub/Sub模式
PUBLISH · SUBSCRIBE · PSUBSCRIBE 命令详解
RedisPub/Sub
06
Pub/Sub模式局限性
消息不持久化 · 离线消费者丢失消息 · 可靠性不足
Pub/Sub模式局限性
07
Redis Streams 数据结构
Stream核心概念（Entry · Consumer Group · Consumer）
RedisStreams
08
Streams 生产者实战
XADD 添加消息 · 消息ID生成规则（毫秒时间戳-序号） · 消息字段设计
Streams生产者实战
09
Streams 消费者实战
XREAD 阻塞读取 · XREADGROUP 消费者组读取 · 消息确认机制
Streams消费者实战
10
消费者组详解
组内负载均衡 · 消息归属 · pending列表
消费者组详解组内负载均衡
11
消息确认与ACK
XACK命令 · 消息处理失败处理策略 · 死信队列概念
ACK消息确认
12
消息回溯查询需求
为什么需要回溯？业务场景（订单状态追… · 日志审计 · 故障排查）
消息回溯查询需求为什么需要回溯？…
13
索引设计基础
Redis Streams 天然索引… · 范围查询（XRANGE · XREVRANGE）
索引设计基础Redis
14
基于时间范围的回溯
XRANGE 按时间窗口查询 · 分页查询（COUNT + 游标）
基于时间范围的回…XRANGE
15
基于消息ID的回溯
XREAD 指定ID开始读取 · 精确跳转
ID基于消息
16
二级索引设计
使用Sorted Set 为消息建立…
二级索引设计Sorted
17
Sorted Set 索引实战
ZADD 添加索引 · ZRANGEBYSCORE 查询 · ZREM 清理过期索引
SortedSet
18
Hash 索引设计
使用Hash存储消息元数据（如消息状… · 处理时间 · 重试次数）
Hash索引设计
19
多条件组合查询
结合Sorted Set + Has…
多条件组合查询Sorted
20
任务状态机设计
消息状态流转（待处理 · 处理中 · 成功
任务状态机设计消息状态流转
21
延迟消息实现
使用Sorted Set 按执行时间… · 定时任务轮询 · XADD 投递
延迟消息实现Sorted
22
延迟消息实战
ZADD 添加延迟任务 · ZRANGEBYSCORE 获取到期… · Lua脚本原子操作
延迟消息实战ZADD
23
消息去重机制
使用Set 或 Bloom Filt… · 幂等性设计
消息去重机制Set
24
消息优先级队列
使用多个Stream或Sorted… · 消费者按优先级消费
消息优先级队列Stream
25
消息轨迹追踪
为每条消息生成唯一TraceID · 记录消息流转日志到Hash或List
消息轨迹追踪TraceID
26
大规模消息清理策略
XTRIM 裁剪Stream · 定时清理过期索引 · 内存监控
大规模消息清理策…XTRIM
27
高可用与故障转移
Redis Sentinel 哨兵模… · Redis Cluster 集群模式 · 消息不丢失保证
高可用故障转移
28
性能优化
批量写入（Pipeline） · 消费者并发控制 · 合理设置Stream长度
性能优化Pipeline
29
监控与告警
Redis INFO 命令 · 监控队列长度 · 消费延迟
监控告警
30
综合实战
设计一个完整的订单消息队列系统 · 包含生产 · 消费
综合实战设计一个完整的订…