Redis 消息队列主要通过 List、Pub/Sub、Sorted Set 和 Stream 四种机制实现。List 类型使用 lpush/rpop 命令实现先进先出队列，配合 brpop 阻塞读取可提高效率避免空轮询。Pub/Sub 适合实时通信但消息不持久。Sorted Set 可用于延迟队列。Stream 是 Redis 5.0 引入的专业结构，支持持久化和消费者组。常见问题如消息丢失可通过持久化解决，消费失败可重新入队，高并发下需注意线程模型优化。

田哥 手把手教 你用 Redis 做延迟消息队列

Redis 如何实现消息队列？大家都知道，Redis 的五种数据类型，其中有一种类型是 list。并且提供了相应的进入 list 的命令 lpush 和 rpush ,以及弹出 list 的命令 lpop 和 rpop。这里我们就可以把 List 理解为一个消息队列，并且 lpush 和 rpush 操作称之为进入队列，同时，lpop 和 rpop 称之为消息出队列。命令 lpush 将一个或多个值 value 插入到列表 key 的表头 如果有多个 value 值，那么各个 value 值按从左到右的顺序依次插入到表头：比如说，对空列表 mylist 执行命令 LPUSH mylist a b c ,列表的值将是 c b a , 这等同于原子性地执行 LPUSH mylist a、LPUSH mylist b 和 LPUSH mylist c 三个命令。如果 key 不存在，一个空列表会被创建并执行 LPUSH 操作。当 key 存在但不是列表类型时，返回一个错误。使用案例：rpush 将一个或多个值 value 插入到列表 key 的表尾 (最右边)。如果有多个 value 值，那么各个 value 值按从左到右的顺序依次插入到表尾：比如对一个空列表 mylist 执行 RPUSH mylist a b c ,得出的结果列表为 a b c ,等同于执行命令 RPUSH mylist a、RPUSH mylist b、RPUSH mylist c。如果 key 不存在，一个空列表会被创建并执行 RPUSH 操作。当 key 存在但不是列表类型时，返回一个错误。使用案例：lpop 使用方式：lpop key。移除并返回列表 key 的头元素。如果 key 不存在，返回 nil。使用案例：rpop 使用方式：rpop key，移除并返回列表 key 的尾元素。当 key 不存在时，返回 nil。使用案例：以上四个命令是不是相当的简单呢，这里说一下 lrange 命令。lrange

Redis 实现消息队列的 4 种方案

redis 实现消息队列的原理是什么？redis 作为内存中的 数据结构 存储，常用作 数据库 ,缓存和 消息代理 .它支持数据结构，如字符串，散列，列表，集合，带有范围查询的排序集 (sorted sets),位图 (bitmaps),超级日志 (hyperloglogs),具有半径查询和流的地理空间索引.redis 具有内置复制，lua 脚本，lru 驱逐，事务和不同级别的磁盘持久性，并通过 redis sentinel 和 redis cluster 自动分区。为了实现其出色的性能，redis 使用 内存数据集 (in-memory dataset) . mq 应用有很多，比如 activemq,rabbitmq, kafka 等，但是也可以基于 redis 来实现，可以降低系统的维护成本和实现复杂度，本篇介绍 redis 中实现 消息队列 的几种方案。1.基于 list 的 lpush+brpop 的实现 2. pub/sub，订阅/发布模式 3.基于 sorted-set 的实现 4.基于 stream 类型的实现 基于异步消息队列 list lpush-brpop(rpush-blpop) 使用 rpush 和 lpush 操作入队列，lpop 和 rpop 操作出队列。list 支持多个生产者和消费者并发进出消息 ,每个消费者拿到都是 不同 的列表元素。但是当队列为空时，lpop 和 rpop 会一直空轮训，消耗资源;所以引入阻塞读 blpop 和 brpop(b 代表 blocking),阻塞读在队列没有数据的时候进入休眠状态，一旦数据到来则立刻醒过来，消息延迟几乎为零。注意

剖析 Redis List 消息队列的三种消费线程模型

1 核心流程 生产者使用 LPUSH key element[element] 将消息插入到队列的头部，如果 key 不存在则会创建一个空的队列再插入消息。如下，生产者向队列 queue 先后插入了「Java」「勇哥」「Go」,返回值表示消息插入队列后的个数。代码语言:javascript AI 代码解释>LPUSHqueue Java 勇哥 Go(integer)3 消费者使用 RPOP key 依次读取队列的消息，先进先出，所以「Java」会先读取消费：代码语言:javascript AI 代码解释>RPOPqueue"Java">RPOPqueue"勇哥">RPOPqueue"Go" 接下来，我们可以通过 spring-data-redisAPI 演示生产消费流程：生产者 代码语言:javascript AI 代码解释 redisTemplate.opsForList().leftPush("queue","Java");redisTemplate.opsForList().leftPush("queue","勇哥");redisTemplate.opsForList().leftPush("queue","Go"); 消费者 我们启动一个独立的线程从队列中读取消息 (RPOP 命令),读取成功之后，消费消息，若没有消息，则休眠一会，下一次循环再继续。上图的伪代码中，while(true) 循环内不停地调用 RPOP 指令，当有消息时，可以及时处理，但假如没有读取到消息，则需要休眠一会。这里要加休眠，主要是为了减少空读的频率，避免 CPU 无意义的消耗。有什么更优化的方式吗？有，那就是使用 Redis 阻塞读取 List 的命令。Redis 提供了 BLPOP、BRPOP 阻塞读取的命令，消费者在在读取队列没有数据的时自动阻塞，直到有新的消息写入队列，才会继续读取新消息执行业务逻辑。代码语言:javascript AI 代码解释 BRPOPqueue0 参数 0 表示阻塞等待时间无限制。如图，我们启动一个消费线程永动机，消费线程拉取消息后，执行消费逻辑。这种消费者线程模型非常容易理解，同时也非常适合顺序消费的模式。同时，假如我们在消费消息时，服务器宕机或者断电，可能丢失一条消息。接下来，我们想一想，有没有消费速度更高的消费模型吗？笔者根据过往的经历，列举三种模式：拉取线程 + 消费线程池 (非阻塞模式) 拉取线程 + 消费线程池 (阻塞模式) 拉取线程 + Disruptor(阻塞模式) 2 拉取线程 + 消费线程池 (非阻塞模式) 为了提升消费速度，我们可以将拉取和消费拆分成两种动作，分别通过不同的线程池来处理。

Redis 面试题之如何实现一个消息队列

使用 List 数据类型：使用 Redis 实现队列，一般会选择 List 这种数据类型。因为 List 数据类型，可以做到先进先出、先进后出的操作。这里的先进先出也就是队列思想，先进后出也就是堆栈思想。使用下面的两个命令，就可以实现一个队列功能：代码语言:shell AI 代码解释# 添加元素到队列中 LPUSH queue_name redis# 从队列中获取数据 LPOP queue_name 使用 List 数据类型执行消息队列，有点非常方便。只要消息添加到队列中，消费端可以采用队列或者栈的方式去获取数据。但 List 作为消息队列，没有 ack 机制，消费者端处理失败，没有回滚队列中的数据，则会导致数据丢失。使用发布订阅模式：发布订阅模式是，消息生产者和消费者都订阅同一个频道，当消息生产者往频道中插入数据时，消息消费者自动接收到数据。使用如下命令，就可以实现一个消息的发布订阅：代码语言:shell AI 代码解释# 消息生产者 PUBLISH queue_name"Hello World"# 消息消费者 SUBSCRIBE queue_name 虽然发布订阅模式也能实现一个队列功能，并且支持多个消费者，但是发布订阅模式不支持数据的持久化，有数据丢失的风险。建议不要使用该数据类型作为消息队列，或者使用在一些可接受数据丢失的应用场景。集合实现延迟队列 在很多时候，我们需要实现一个延迟队列，例如订单的有效时间处理场景。前面两种数据类型，在这方面实现起来就比较复杂，使用 Redis 的有序集合，通过分值来判断队列任务的优先级，就可以实现简单的一个消息队列。任务执行的时间戳可以用来当做分值，分值越小表示执行的优先级越高。代码语言:shell AI 代码解释#消息生产者 ZADD queue_name1message1 ZADD queue_name2message2#消息消费者 ZPOPMIN queue_name 集合实现消息队列，也非常的方便，并且也支持数据的持久化，能减少数据丢失的风险。对于前面两种数据类型，当数据量过大时，内存占用较大。Stream 实现消息队列 Redis Stream 是 Redis 5.0 版本引入的数据结构，它提供了一种新的机制来实现消息队列，具有以下特点：1、持久化:Redis Stream 的消息可以被持久化存储，即使在服务器重启后也不会丢失消息。2D:每个消息都有一个唯一的 ID，由时间戳和序列号组成，确保了消息的顺序性和可追踪性。3、消费者组：支持消费者组的概念，允许多个消费者以组的形式订阅 Stream，并且每个消息只会被组内的一个消费者处理。4、消 2、消息 ID:每个消息都有一个唯一的 ID，由时间戳和序列号组成，确保了消息的顺序性和可追踪性。

FAQ

Redis 实现消息队列有几种常见方案？

主要有基于 List 的 lpush+brpop 实现、Pub/Sub 订阅发布模式、基于 Sorted-set 的实现以及基于 Stream 类型的实现四种方案。

如何解决 Redis 消息队列的消息丢失问题？

List 和 Pub/Sub 模式可能存在消息丢失风险，建议使用支持持久化的 Stream 结构，或者在消费失败时将消息重新放入队列，同时开启 Redis 磁盘持久化功能。

如何提高 Redis 消息队列的消费效率？

可以使用阻塞读取命令如 BLPOP、BRPOP 避免空轮询消耗 CPU，或者采用拉取线程与消费线程池分离的模型，甚至结合 Disruptor 来提升消费速度。