redis消息队列PHP,如何基于redis实现消息队列

以你之姓@ 2022-11-12 09:53 278阅读 0赞

![f1d792136aeb6b31e67741f0777acb37.png][]

消息队列，Message Queue，常用于解决并发系统中的资源一致性问题，提升峰值的处理能力，同时保证消息的顺序性、可恢复性、必送达性，对应用进行解耦，或者实现异步通讯等。 (推荐学习：Redis视频教程)

市面上的 MQ应用有很多(例如：Kafka，RabbitMQ，Disque)，同时也可以基于 Redis 来实现，比较典型的方案有：

基于List的 LPUSH+BRPOP 的实现

PUB/SUB，订阅/发布模式

基于Sorted-Set的实现

基于Stream类型的实现

在消息队列使用中，有生产者producter和消费者consumer。生产者负责生成消息，消费者负责使用处理消息。

生产，指的是将消息放入消息队列。

消费，指的是读取并处理消息。通常一个消息再被消费后，就应该从消息队列中删除。

![8175706b673895424edb21a17554174a.png][]

基于List的 LPUSH+BRPOP 的实现

典型的命令为：LPUSH，将消息队列

BRPOP，从队列中取出消息，阻塞模式

就是一个典型的基于FIFL队列的解决方案。其中LPUSH是生产者做的事，而BRPOP是消费者做的事。

该模式有很多优点：

实现简单

Reids支持持久化消息，意味着消息不会丢失，可以重复查看(注意不是消费，只看不用，LRANGE类的指令)。

可以保证顺序，保证使用LPUSH命令，可以保证消息的顺序性

使用RPUSH，可以将消息放在队列的开头，达到优先消息的目的，可以实现简易的消息优先队列。

同时也有些劣势：

做消费确认ACK比较麻烦，就是不能保证消费者在读取之后，未处理后的宕机问题。导致消息意外丢失。通常需要自己维护一个Pending列表，保证消息的处理确认。

不能做广播模式，例如典型的Pub/Discribe模式。

不能重复消费，一旦消费就会被删除

不支持分组消费，需要自己在业务逻辑层解决

PUB/SUB，订阅/发布模式SUBSCRIBE，用于订阅信道

PUBLISH，向信道发送消息

UNSUBSCRIBE，取消订阅

生产者和消费者通过相同的一个信道(Channel)进行交互。信道其实也就是队列。通常会有多个消费者。多个消费者订阅同一个信道，当生产者向信道发布消息时，该信道会立即将消息逐一发布给每个消费者。可见，该信道对于消费者是发散的信道，每个消费者都可以得到相同的消息。典型的对多的关系。

典型的优点是：

典型的广播模式，一个消息可以发布到多个消费者

多信道订阅，消费者可以同时订阅多个信道，从而接收多类消息

消息即时发送，消息不用等待消费者读取，消费者会自动接收到信道发布的消息

也有些缺点：

消息一旦发布，不能接收。换句话就是发布时若客户端不在线，则消息丢失，不能寻回

不能保证每个消费者接收的时间是一致的

若消费者客户端出现消息积压，到一定程度，会被强制断开，导致消息意外丢失。通常发生在消息的生产远大于消费速度时

可见，Pub/Sub 模式不适合做消息存储，消息积压类的业务，而是擅长处理广播，即时通讯，即时反馈的业务。

基于SortedSet有序集合的实现ZADD KEY score member，压入集合

ZRANGEBYSCORE，依据score获取成员

有序集合的方案是在自己确定消息顺ID时比较常用，使用集合成员的Score来作为消息ID，保证顺序，还可以保证消息ID的单调递增。通常可以使用时间戳+序号的方案。确保了消息ID的单调递增，利用SortedSet的依据Score排序的特征，就可以制作一个有序的消息队列了。

和上面的方案相比，优点就是可以自定义消息ID，在消息ID有意义时，比较重要。缺点也明显，不允许重复消息(以为是集合)，同时消息ID确定有错误会导致消息的顺序出错。

所以，若不是需要自定义消息ID，这个方案好像有点鸡肋…

基于 Stream 类型的实现

这个Stream类型redis就是为了实现消息队列的。支持自动生成消息ID，分组消费，ACK，消息转移，队列监控等核心消息队列功能

更多Redis相关技术文章，请访问Redis入门教程栏目进行学习！

[f1d792136aeb6b31e67741f0777acb37.png]: /images/20221022/07bd73e8b4f440638e81744a692d4e6f.png
[8175706b673895424edb21a17554174a.png]: /images/20221022/bf63211189684919afd069c37fab7b97.png

发表评论取消回复

表情：

评论列表（有 0 条评论，278人围观）

还没有评论，来说两句吧...

相关阅读

相关 Redis消息队列

Redis消息队列 1.认识消息队列 2.Redis消息队列-基于List实现消息队列 3.Redis消息队列-基于PubSub的消息队列 4.R

￡神魔★判官ぃ/ 2024年03月31日 08:49/ 0 赞/ 120 阅读

相关 Redis实现消息队列

7、Redis消息队列 7.1 Redis消息队列-认识消息队列什么是消息队列：字面意思就是存放消息的队列。最简单的消息队列模型包括3个角色：消息队列：

妖狐艹你老母/ 2024年03月27日 11:17/ 0 赞/ 108 阅读

相关 PHP+Redis消息队列

PHP+Redis消息队列消息队列概念队列结构的中间件消息放入后，不需要立即处理由订阅者/消费者按顺序处理 ![在这里插入图片描述][20210326

ゞ浴缸里的玫瑰/ 2023年10月06日 16:14/ 0 赞/ 21 阅读

相关 Redis实现消息队列

前言 Redis可以通过发布订阅模式、轮询机制实现消息队列。由于没有消息持久化与 ACK 的保证，所以，Redis 的发布订阅功能并不可靠。这也就导致了它的应用场景很

向右看齐/ 2023年10月01日 12:03/ 0 赞/ 31 阅读

相关 PHP + Redis 实现消息队列

Redis做消息队列的好处在于它的轻量级，高并发，延迟敏感，应用场景有即时数据分析、秒杀计数器、缓存等 Redis做消息队列待解决的问题：　　1、消息的可靠性：没有相

太过爱你忘了你带给我的痛/ 2023年08月17日 16:14/ 0 赞/ 141 阅读

相关 php+redis实现消息队列功能

php+redis消息队列是php+mysql性能不足时的一个中间间处理方案。应用场景：用于服务器瞬间请求大，数据库压力大的情况。如并发量大导致的超卖、并发量大导

落日映苍穹つ/ 2023年03月13日 15:22/ 0 赞/ 19 阅读

相关 redis实现消息队列

1. 实现方式队列模式发布订阅模式 2. 原理原理很简单，用的redis的List类型，list是按照插入的顺序排序的字符串链表。和数据结构中的普通链表类似，可

客官°小女子只卖身不卖艺/ 2023年03月13日 06:42/ 0 赞/ 19 阅读

相关 redis消息队列PHP,如何基于redis实现消息队列

![f1d792136aeb6b31e67741f0777acb37.png][] 消息队列，Message Queue，常用于解决并发系统中的资源一致性问题，提升峰值的处理

以你之姓@/ 2022年11月12日 09:53/ 0 赞/ 279 阅读

相关 php+redis消息队列抢购实现

实现功能： 1. 基于redis队列，防止高并发的超卖 2. 基于mysql的事务加排它锁，防止高并发的超卖基于redis队列工作流程： 1. 管理员根据goo

左手的ㄟ右手/ 2022年06月18日 08:17/ 0 赞/ 214 阅读

相关 redis_消息队列

Redis的消息是topic（广播）机制。感觉实用性不大，因为消息有专门的消息技术，如kafka,mq。在这里简单做个笔记。发布消息：publish 名称 "内容" 订阅

╰半橙微兮°/ 2022年05月25日 08:55/ 0 赞/ 252 阅读