当前位置：首页 > news >正文

Redis 消息队列详解

news 来源：原创 2025/5/15 7:06:40

Redis 消息队列详解

Redis 作为一个高性能的内存数据库，支持多种实现消息队列的方式，主要包括：

Redis List（基于列表的队列）
Redis Pub/Sub（发布/订阅）
Redis Stream（消息流）
Redis Sorted Set（延迟队列）

不同的方式适用于不同的场景，下面详细讲解各自的实现原理、适用场景以及示例代码。

1. 基于 Redis List 的消息队列

Redis 的 List 结构（链表）可以用来实现 任务队列，支持持久化存储，并允许消费者从队列中取出任务进行处理。

1.1. 基本原理

LPUSH queue_name message：将新任务加入队列头部。
RPUSH queue_name message：将新任务加入队列尾部。
LPOP queue_name / RPOP queue_name：从队列头部/尾部取出任务（非阻塞）。
BRPOP queue_name timeout：阻塞方式获取任务，如果队列为空，会等待新的任务到来。

1.2. 生产者代码

import redisr = redis.Redis(host='localhost', port=6379, decode_responses=True)# 添加任务到队列
r.lpush('task_queue', 'task1')
r.lpush('task_queue', 'task2')
print("Tasks added!")

1.3. 消费者代码

import redisr = redis.Redis(host='localhost', port=6379, decode_responses=True)while True:task = r.brpop('task_queue', timeout=0)  # 阻塞模式if task:print(f"Processing task: {task[1]}")

1.4. 适用场景

任务队列（Task Queue）：适用于 任务分发 和 异步处理。
多消费者竞争模式：多个消费者会竞争消费队列中的任务，每个任务只能被一个消费者取走。

1.5. 问题与优化

消息丢失：如果消费者取出任务后崩溃，任务就会丢失。可以使用 RPOPLPUSH 实现任务持久化：

task = r.rpoplpush('task_queue', 'processing_queue')
if task:process(task)r.lrem('processing_queue', 1, task)  # 任务完成后删除

限流：可以使用 Redis 令牌桶 或 滑动窗口算法 控制任务消费速率。

2. 基于 Redis Pub/Sub 的实时消息队列

Redis Pub/Sub 适用于实时广播通知，但不支持消息存储。

2.1. 基本原理

PUBLISH channel message：发布消息到频道。
SUBSCRIBE channel：订阅者监听频道消息。

2.2. 生产者代码

import redisr = redis.Redis(host='localhost', port=6379, decode_responses=True)
r.publish('news_channel', 'Breaking News: Redis is awesome!')

2.3. 消费者代码

import redisr = redis.Redis(host='localhost', port=6379, decode_responses=True)pubsub = r.pubsub()
pubsub.subscribe('news_channel')for message in pubsub.listen():if message['type'] == 'message':print(f"Received message: {message['data']}")

2.4. 适用场景

实时消息推送（如聊天系统、WebSocket）。
事件驱动架构（如监控报警、状态变更通知）。

2.5. 问题与优化

消息不会持久化，订阅者掉线后无法收到历史消息。
不能回放消息，消息是实时的，一旦发送就无法重新获取。
可以使用 Redis Stream 代替 来解决持久化问题。

3. 基于 Redis Stream 的持久化消息队列

Redis Stream 是一种高效、持久化的消息队列，支持消息存储、消费分组等特性，类似 Kafka。

3.1. 基本原理

XADD stream_name * field1 value1 field2 value2：添加消息。
XREAD COUNT 1 STREAMS stream_name last_id：读取消息。
XGROUP CREATE stream_name group_name $ MKSTREAM：创建消费组。

3.2. 生产者代码

import redisr = redis.Redis(host='localhost', port=6379, decode_responses=True)
r.xadd('event_stream', {'event': 'user_signup', 'user_id': '12345'})
print("Event published!")

3.3. 消费者代码

import redisr = redis.Redis(host='localhost', port=6379, decode_responses=True)while True:events = r.xread({'event_stream': '$'}, count=1, block=5000)for stream, messages in events:for message_id, message in messages:print(f"Received: {message}")

3.4. 适用场景

大规模消息存储（Kafka 替代）。
日志收集与分析。
事件溯源（能回放历史消息）。

4. 基于 Redis Sorted Set 的延迟队列

Sorted Set（有序集合）可以用于定时任务调度。

4.1. 生产者代码

import time
import redisr = redis.Redis(host='localhost', port=6379, decode_responses=True)
r.zadd('delay_queue', {'task1': time.time() + 10})  # 10秒后执行

4.2. 消费者代码

import time
import redisr = redis.Redis(host='localhost', port=6379, decode_responses=True)while True:now = time.time()tasks = r.zrangebyscore('delay_queue', 0, now)for task in tasks:print(f"Processing {task}")r.zrem('delay_queue', task)time.sleep(1)

4.3. 适用场景

定时任务（如定时短信、延迟执行）。
超时检测（如订单过期、缓存清理）。

5. 选择合适的 Redis 消息队列

方案	持久化	支持多消费者	适用场景
List	✅	竞争消费	任务队列、异步任务
Pub/Sub	❌	广播消费	实时推送、通知
Stream	✅	组消费	事件流、日志收集
Sorted Set	✅	竞争消费	延迟任务

总结

如果需要任务队列，使用 List（支持竞争消费，适合任务调度）。
如果需要实时推送，使用 Pub/Sub（广播消息，不存储）。
如果需要持久化消息流，使用 Stream（类似 Kafka，支持回放）。
如果需要定时任务，使用 Sorted Set（适合延迟队列）。

Redis 消息队列详解

Redis 消息队列详解 Redis 作为一个高性能的内存数据库，支持多种实现消息队列的方式，主要包括： Redis List（基于列表的队列）Redis Pub/Sub（发布/订阅）Redis Stream（消息流&#xf…...

编程日记 2025/5/15 7:06:40

C语言编译过程全面解析

今天是2025年1月26日，农历腊月二十七，一个距离新春佳节仅一步之遥的日子。城市的喧嚣中，年味已悄然弥漫——能在这个时候坚持上班的人，真可称为“牛人”了吧，哈哈。。。。此刻，我在重新审视那些曾被遗忘的…...

编程日记 2025/5/13 5:46:56

萌新学 Python 之运算符

Python 中运算符包括：算术运算符、比较运算符、逻辑运算符、赋值运算符、位运算符、海象运算符算术运算符：加减 - 乘 * 除 / 取整 // 求余 % 求幂 ** 注意：取整时，一正一负整除，向下取整比如 5 // …...

编程日记 2025/5/16 0:14:07

【开源免费】基于Vue和SpringBoot的在线文档管理系统（附论文）

本文项目编号 T 038 ，文末自助获取源码 \color{red}{T038，文末自助获取源码} T038，文末自助获取源码目录一、系统介绍二、演示录屏三、启动教程四、功能截图五、文案资料5.1 选题背景5.2 国内外研究现状5.3 可行性分析六、核心代码6.1 查…...

编程日记 2025/5/11 7:34:22

四.4 Redis 五大数据类型/结构的详细说明/详细使用（ zset 有序集合数据类型详解和使用）

四.4 Redis 五大数据类型/结构的详细说明/详细使用（ zset 有序集合数据类型详解和使用） 文章目录四.4 Redis 五大数据类型/结构的详细说明/详细使用（ zset 有序集合数据类型详解和使用）1. 有序集合 Zset(sorted set)2. zset 有序…...

编程日记 2025/5/15 2:49:25

Linux 信号驱动IO

Linux 信号驱动IO 1. fcntl() 在Linux操作系统中，fcntl() 是一个用于操作文件描述符的系统调用。它提供了多种功能，包括控制文件描述符的属性、管理文件锁定、设置文件的非阻塞模式等。本文只截取了用于IO模型的 fcntl() 部分内容， fcntl(…...

编程日记 2025/5/16 0:39:49

OpenCV：开运算

目录 1. 简述 2. 用腐蚀和膨胀实现开运算 2.1 代码示例 2.2 运行结果 3. 开运算接口 3.1 参数详解 3.2 代码示例 3.3 运行结果 4. 开运算应用场景 5. 注意事项 6. 总结相关阅读 OpenCV：图像的腐蚀与膨胀-CSDN博客 OpenCV：闭运算-CSDN博客 …...

编程日记 2025/5/15 0:11:49

宝塔mysql数据库容量限制_宝塔数据库mysql-bin.000001占用磁盘空间过大

磁盘空间占用过多，排查后发现网站/www/wwwroot只占用7G，/www/server占用却高达8G，再深入排查发现/www/server/data目录下的mysql-bin.000001和mysql-bin.000002两个日志文件占去了1.5G空间。百度后学到以下知识，做个记录。 mysql…...

编程日记 2025/5/14 3:46:23

使用 Iptables 实现网络安全策略：从入门到精通

使用 Iptables 实现网络安全策略：从入门到精通在运维工作中，网络安全是重中之重，而 iptables 作为 Linux 内核自带的防火墙工具，提供了强大的流量控制能力。通过合理的 iptables 规则，我们可以有效防止未经授权的访问，保护服务器免受攻击。今天，我们就来深入探讨如何使…...

编程日记 2025/5/12 1:58:54

AI作画提示词：Prompts工程技巧与最佳实践

成长路上不孤单😊😊😊😊😊😊 【14后😊///计算机爱好者😊///持续分享所学😊///如有需要欢迎收藏转发///😊】今日分享关于物联网智能项目之——智能家居项目…...

编程日记 2025/5/16 1:06:46

vue框架技术相关概述以及前端框架整合

vue框架技术概述及前端框架整合 1 node.js 介绍：什么是node.js Node.js就是运行在服务端的JavaScript。 Node.js是一个事件驱动I/O服务端JavaScript环境，基于Google的V8引擎。作用 1 运行java需要安装JDK，而Node.js是JavaScript的运行环…...

编程日记 2025/5/16 0:14:08

并发编程 - 线程同步（二）

经过前面对线程同步初步了解，相信大家对线程同步已经有了整体概念，今天我们就来一起看看线程同步的具体方案。 01、ThreadStatic 严格意义上来说这两个并不是实现线程同步方案，而是解决多线程资源安全问题，而我们研究线程同步最终…...

编程日记 2025/5/16 0:13:01

仿知乎网站问答源码，开源版

按照需要一定动手能力发文章，发视频，发想法，提问回答，注册登录开发环境使用技术：springbootthymeleafRedis； 开发环境：tomcat8.0，jdk8.0, IDEA项目，mysql5.7 源码下…...

编程日记 2025/5/16 0:42:05

CTF-web: phar反序列化+数据库伪造 [DASCTF2024最后一战 strange_php]

step 1 如何触发反序列化? 漏洞入口在 welcome.php case delete: // 获取删除留言的路径，优先使用 POST 请求中的路径，否则使用会话中的路径 $message $_POST[message_path] ? $_POST[message_path] : $_SESSION[message_path]; $msg $userMes…...

编程日记 2025/5/16 0:31:06

阿里：基于路由和规划的多agent系统

📖标题：Talk to Right Specialists: Routing and Planning in Multi-agent System for Question Answering 🌐来源：arXiv, 2501.07813 🌟摘要 🔸利用大型语言模型（LLM）&#xff0c…...

编程日记 2025/5/15 21:08:09

Java基础面试题总结（题目来源JavaGuide）

问题1：Java 中有哪 8 种基本数据类型？它们的默认值和占用的空间大小知道不？ 说说这 8 种基本数据类型对应的包装类型。在 Java 中，有 8 种基本数据类型（Primitive Types）： 基本数据类型关键…...

编程日记 2025/5/16 1:20:29

CSS（快速入门）

欢迎大家来到我的博客~欢迎大家对我的博客提出指导，有错误的地方会改进的哦~点击这里了解更多内容目录一、什么是CSS?二、基本语法规范三、CSS选择器3.1 标签选择器3.2 id选择器3.3 class选择器3.4 通配符选择器3.5 复合选择器四、常用CSS样式4.1 color4.2 font…...

编程日记 2025/5/15 13:20:03

架构技能（六）：软件设计（下）

我们知道，软件设计包括软件的整体架构设计和模块的详细设计。在上一篇文章（见《架构技能（五）：软件设计（上）》）谈了软件的整体架构设计，今天聊一下模块的详细设计。模…...

编程日记 2025/5/15 8:05:09

2. Java-MarkDown文件解析-工具类

2. Java-MarkDown文件解析-工具类 1. 思路读取markdown文件的内容，根据markdown的语法进行各个类型语法的解析。引入工具类 commonmark 和 commonmark-ext-gfm-tables进行markdown语法解析。 2. 工具类 pom.xml  <d…...

编程日记 2025/5/15 23:47:19

OpenEuler学习笔记（十五）：在OpenEuler上搭建Java运行环境

一、在OpenEuler上搭建Java运行环境在OpenEuler上搭建Java运行环境可以通过以下几种常见方式，下面分别介绍基于包管理器安装OpenJDK和手动安装Oracle JDK的步骤。使用包管理器安装OpenJDK OpenJDK是Java开发工具包的开源实现，在OpenEuler上可以方便…...

编程日记 2025/5/15 7:15:51

【Rust自学】15.4. Drop trait：告别手动清理，释放即安全

喜欢的话别忘了点赞、收藏加关注哦（加关注即可阅读全文），对接下来的教程有兴趣的可以关注专栏。谢谢喵！(･ω･) 15.4.1. Drop trait的意义类型如果实现了Drop trait，就可以让程序员自定义当值…...

编程日记 2025/5/10 5:54:42

深入探讨Web应用开发：从前端到后端的全栈实践

在数字化时代，Web应用已成为连接用户与服务的关键桥梁。无论是电商平台、社交媒体，还是企业内部管理系统，Web应用都扮演着不可或缺的角色。本文将深入探讨Web应用开发的全栈实践，从前端的用户体验设计到后端的数据处理与存储&…...

编程日记 2025/5/16 1:10:00

4.贪心算法

贪心贪心算法（Greedy Algorithms）是 C 等编程语言中常用的一种算法策略。定义贪心算法是指在对问题求解时，总是做出在当前看来是最好的选择。也就是说，不从整体最优上加以考虑，算法得到的是在某种意义上的局部最…...

编程日记 2025/5/16 1:01:17

js笔记（黑马程序员）

（Web APIs day4） 一、日期对象 1.实例化在代码中发现了 new 关键字时，一般将这个操作称为实例化创建一个时间对象并获取时间// 1．得到当前时间 2.日期对象方法因为日期对象返回的数据我们不能直接使用，所以需…...

编程日记 2025/5/15 15:12:07

LangChain：使用表达式语言优化提示词链

在 LangChain 里，LCEL 即 LangChain Expression Language（LangChain 表达式语言），本文为你详细介绍它的定义、作用、优势并举例说明，从简单示例到复杂组合示例，让你快速掌握LCEL表达式语言使用技巧。定义 …...

编程日记 2025/5/11 17:45:55

Python 有用的资源

Python 有用的资源引言 Python 作为一种强大的编程语言，因其简洁明了的语法和丰富的库资源，在数据分析、人工智能、网络开发等领域拥有广泛的应用。对于初学者和专业人士来说，掌握一些有用的Python资源可以大大提高编程效率。本文将为您介绍一些实用的Python资源，帮助您…...

编程日记 2025/5/13 0:54:11

汽车蓝牙钥匙定位仿真小程序

此需求来自于粉丝的真实需求，假期没事，牛刀小试。一、项目背景如今，智能车钥匙和移动端定位技术已经相当普及。为了探索蓝牙 Beacon 在短距离定位场景下的可行性，我们搭建了一个简易原型：利用 UniApp 在移动端采集蓝牙信标的 RSSI（信号强度），通过三边定位算法估算钥…...

编程日记 2025/5/11 20:45:29

项目开发实践——基于SpringBoot+Vue3实现的在线考试系统(九)（完结篇）

文章目录一、成绩查询模块实现1、学生成绩查询功能实现1.1 页面设计1.2 前端页面实现1.3 后端功能实现2、成绩分段查询功能实现2.1 页面设计2.2 前端页面实现2.3 后端功能实现二、试卷练习模块实现三、我的分数模块实现1、页面设计2、前端页面实现3、后端功能实现四、交流区…...

编程日记 2025/5/12 14:35:28

python学opencv|读取图像（四十九）原理探究：使用cv2.bitwise()系列函数实现图像按位运算

【0】基础定义按位与运算：两个等长度二进制数上下对齐，全1取1，其余取0。按位或运算：两个等长度二进制数上下对齐，有1取1，其余取0。按位异或运算： 两个等长度二进制数上下对齐，相…...

编程日记 2025/5/13 14:30:56

electron打包客户端在rk3588上支持h265硬解

目录前言 chromium是如何支持h265硬解 electron/chromium第一次编译 electron/chromium第二次编译前言我们的客户端程序是用electron打包的前端程序，其在rk3588主机上的linux环境运行。之前使用客户端查看h264编码的视频直播是没有问题的，但视频源…...

编程日记 2025/5/14 17:25:10

MyBatis 缓存机制详解

目录一、什么是缓存？ 1. 什么是缓存？ 2. 为什么使用缓存？ 3. 什么样的数据适合使用缓存？ 二、MyBatis 缓存机制 1. 一级缓存（也叫本地缓存） 2. 一级缓存失效的情况 3. 二级缓存 4. 二级缓存失效的…...

编程日记 2025/5/15 19:02:57

Cloudwego脚手架使用 cwgo脚手架 cwgo脚手架安装的命令： GOPROXYhttps://goproxy.cn/,direct go install github.com/cloudwego/cwgolatest依赖thriftgo的安装： go install github.com/cloudwego/thriftgolatest编辑echo.thrift文件用于生成项目&…...

编程日记 2025/5/12 22:26:28

数据结构选讲（更新中）

参考 smWCDay7 数据结构选讲2 by yyc 。可能会补充的： AT_cf17_final_j TreeMST 的 F2 Boruvka算法目录 AT_cf17_final_j Tree MST AT_cf17_final_j Tree MST link 题意给定一棵 n n n 个点的树，点有点权 w i w_i wi，边有边权。建立…...

编程日记 2025/5/15 12:05:00

springboot 简化 spring开发

什么是自动配置？ 简单概念： Spring Boot 自动配置是一种 “约定优于配置” 的做法。根据项目类路径（classpath）上存在的依赖、配置文件中的某些属性，Spring Boot 会自动为常见场景创建并配置相关 Bean，省…...

编程日记 2025/5/15 8:48:34

Yolo11 + OCR 营业执照识别+信息抽取（预期后续改用其他ocr更简单，推理预计使用onnxruntim加速，分c++和python两种方式部署）

目录一数据集制作 1 labelimg的安装与使用 2 标注方式 3 数据集制作二模型训练三使用Yolo11 + OCR 实现“营业执照”信息解析完整方案 1 cutLinesforcode.py 2 getBusinessLicenseContentPart.py 3 getPartWords.py 4 pdfTojpg.py 5 main.py 本项目可用于毕业…...

编程日记 2025/5/14 15:56:08

机器学习day3

自定义数据集使用框架的线性回归方法对其进行拟合 import matplotlib.pyplot as plt import torch import numpy as np # 1.散点输入 # 1、散点输入 # 定义输入数据 data [[-0.5, 7.7], [1.8, 98.5], [0.9, 57.8], [0.4, 39.2], [-1.4, -15.7], [-1.4, -37.3], [-1.8, -49.1]…...

编程日记 2025/5/11 20:45:16

C基础寒假练习(3)

一、求数组中的第二大值 #include <stdio.h> int main() {int arr[] {12, 35, 1, 10, 34, 1};int size sizeof(arr) / sizeof(arr[0]);if (size < 2) {printf("数组元素不足两个\n");return 0;}int first -2147483648, second -2147483648; // 使用IN…...

编程日记 2025/5/11 20:45:15

星际战争模拟系统：新月的编程之道

星际战争模拟系统：新月的编程之道作为一名在 25 世纪星际时代成长起来的科学家和军事战略家，我对编程和人工智能的热爱始于童年。我的父亲是一位著名的物理学家，母亲是一位杰出的生物工程师。在他们的影响下，我从小就对科学和技术…...

编程日记 2025/5/14 3:05:00

【Redis】 String 类型的介绍和常用命令

1. 介绍 Redis 中的 key 都是字符串类型Redis 中存储字符串是完全按照二进制流的形式保存的，所以 Redis 是不处理字符集编码的问题，客户端传入的命令中使用的是什么编码就采用什么编码，使得 Redis 能够处理各种类型的数据，包括文…...

编程日记 2025/5/11 18:20:50

U盘打开提示格式化：深度解析与数据恢复全攻略

在数字化时代，U盘作为便捷的数据存储和传输工具，广泛应用于各个领域。然而，当我们满怀期待地插入U盘，却遭遇“U盘打开提示格式化”的尴尬局面时，那份焦虑与无助感油然而生。本文将全面剖析U盘打开提示格式化的原因、应…...

编程日记 2025/5/13 20:33:22

vue2在线生成二维码

亲情提示：如果可以让后端生成就让后端生成实在不行再前端解决（分享方法只是为了让你快点下班不是为了让你能者多劳） 创建 npm install qrcodejs2 pnpm install qrcodejs2 <div ref"qrcode" id"myQrCode" class&…...

编程日记 2025/5/15 13:16:21

Linux中的几个基本指令（二）

文章目录 1、cp指令例一：例二：例三：例四：例五： 2、mv 指令例一：例二： 3、cat指令例一： 4、tac指令5、which指令6、date指令时间戳：7、zip指令今天我们继续学习Linux下的…...

编程日记 2025/5/14 17:48:42

基于Springboot的健身房管理系统【附源码】

基于Springboot的健身房管理系统效果如下： 系统登陆页面管理员主页面器材类型管理页面健身房管理页面教练管理页面用户管理页面个人信息页面课程管理页面研究背景随着健康意识的不断增强和人们生活水平的提高，健身房已经成为了现代城市中不…...

编程日记 2025/5/12 23:13:15

【HarmonyOS之旅】基于ArkTS开发(三) -＞兼容JS的类Web开发(一)

目录 1 -> 概述 1.1 -> 整体架构 2 -> 文件组织 2.1 -> 目录结构 2.2 -> 文件访问规则 2.3 -> 媒体文件格式 3 -> js标签配置 3.1 -> pages 3.2 -> window 3.3 -> 示例 4 -> app.js 4.1 -> 应用生命周期 4.2 -> 应用对象6…...

编程日记 2025/5/15 3:47:19

Spring Boot多环境配置实践指南

在开发Spring Boot应用时，我们常常需要根据不同的运行环境（如开发环境、测试环境和生产环境）来配置不同的参数。Spring Boot提供了非常灵活的多环境配置机制，通过使用profile-specific properties文件，我们可以轻松地管…...

编程日记 2025/5/14 2:10:34

知识图谱质量评估：构建高质量语义网络的关键

目录前言1. 知识图谱质量评估的必要性2. 知识图谱质量评估的核心维度2.1 数据层面2.2 结构层面2.3 语义层面2.4 性能层面 3. 知识图谱质量评估的方法3.1 定量评估方法3.2 定性评估方法 4. 知识图谱质量优化建议结语前言随着大数据和人工智能技术的飞速发展，知识…...

编程日记 2025/5/15 5:44:19

＜ OS 有关＞ Android 手机 SSH 客户端 app: connectBot

connectBot 开源且功能齐全的SSH客户端,界面简洁,支持证书密钥。下载量超 500万方便在 Android 手机上，连接 SSH 服务器，去运行命令。 Fail2ban 12小时内抓获的 IP ~ ~ ~ ~ rootjpn:~# sudo fail2ban-client status sshd Status for the jail: sshd …...

编程日记 2025/5/14 21:40:02

Unity游戏(Assault空对地打击)开发(1) 创建项目和选择插件

目录前言创建项目插件导入地形插件前言这是游戏开发第一篇，进行开发准备。创作不易，欢迎支持。我的编辑器布局是【Tall】，建议调整为该布局，如下。创建项目首先创建一个项目，过程略，名字请勿…...

编程日记 2025/5/15 12:48:03

SpringBoot 日志

目录一. 日志概述二. 日志的使用 1. 打印日志 (1) 获取日志对象 (2) 输出要打印的内容 2. 日志框架简介 (1) 门面模式简介 (2) SLF4J 框架简介 3. 日志的格式 4. 日志的级别 5. 日志配置 (1) 配置日志级别 (2) 日志持久化存储 ① 配置日志文件名 ② 配置日志的…...

编程日记 2025/5/11 20:44:52

每日 Java 面试题分享【第 16 天】

欢迎来到每日 Java 面试题分享栏目！ 订阅专栏，不错过每一天的练习今日分享 3 道面试题目！ 评论区复述一遍印象更深刻噢~ 目录问题一：Java 运行时异常和编译时异常之间的区别是什么？问题二：什么是 Jav…...

编程日记 2025/5/10 23:53:42

Redis 消息队列详解

1. 基于 Redis List 的消息队列

1.1. 基本原理

1.2. 生产者代码

1.3. 消费者代码

1.4. 适用场景

1.5. 问题与优化

2. 基于 Redis Pub/Sub 的实时消息队列

2.1. 基本原理

2.2. 生产者代码

2.3. 消费者代码

2.4. 适用场景

2.5. 问题与优化

3. 基于 Redis Stream 的持久化消息队列

3.1. 基本原理

3.2. 生产者代码

3.3. 消费者代码

3.4. 适用场景

4. 基于 Redis Sorted Set 的延迟队列

4.1. 生产者代码

4.2. 消费者代码

4.3. 适用场景

5. 选择合适的 Redis 消息队列

总结

相关文章：