PHP消息队列实现及应用：消息队列概念介绍

一时失言乱红尘 2022-05-15 08:06 261阅读 0赞

在互联网项目开发者经常会遇到『给用户群发短信』、『订单系统有大量的日志需要记录』或者在秒杀业务的时候服务器无法承受瞬间并发的压力。   
这种情况下，我们怎么保证系统正常有效的运行呢？

这个时候，我们可以引入一个叫『消息队列』的概念来解决上面的需求。

### 消息队列的概念、原理和场景 ###

在高并发的时候，程序往往无法做到及时的处理。我们引入一个中间的系统，来进行分流和减压。   
所以从本质上讲：消息队列就是一个队列结构的中间件。也就是说，你把消息和内容放入这个容器之后就可以直接返回，不用等它后期处理的结果。另外会有一个程序，读取这些数据并按照顺序处理。

1、队列结构的中间件
    2、消息放入后，不必立即处理
    3、由订阅者/消费者按顺序处理

也就是说：当遇到一个比较大或者耗时比较长的环节的时候，而同时你的业务又不需要立即知道这个环节的结果，使用消息队列是好的选择。

核心结构如下面：   
![这里写图片描述][SouthEast]

### 消息队列 适用场景 ###

**一、数据需要冗余的时候**   
比如订单系统中，后续需要进行数据的转换和记录。消息队列可以把这些数据持久化的存储在队列中，然后由订单后期处理程序进行处理，处理完成之后再把这条记录从队列中删除。

**二、系统的解耦**   
消息队列解决了2套系统之间深度耦合的问题。   
使用消息队列后，入队的系统和出队的系统没有直接的关系。   
入队系统和出队系统，其中一个崩溃之后不会影响另外一个的正常运行。

**三、流量削峰**   
就是秒杀和抢购的时候，会出现明显的流量剧增，对服务器的压力非常大。   
实际项目开发中，配合缓存来使用消息队列，一种很好的方案。

**四、异步通信**   
消息队列本身就实现了程序的异步操作，因此只要适合于异步的场景都可以使用消息队列

**五、扩展性**   
比如订单系统，订单入队之后，后期或许还有财务系统处理，但是如果还要加一个配货系统。   
只需要让这个配货系统 订阅这个 消息队列 即可。

**六、排序保证**   
在有些场景下，数据的处理顺序是非常重要的，队列本身就可以做成单线程的单进单出的系统。   
从而有效的保证数据按照顺序进行处理。

**队列的最主要用途是异步任务和通信两个方面。**

异步的思路主要用来缓解瞬间压力、耗时操作、并行任务等。  
1. 缓解瞬间压力：若系统每秒处理能力是100请求，而最高峰值可能达到每秒1000请求，若不采用队列，很有可能会出现服务不可用或者长时间等待。此时可以用队列将未能成功执行的请求放入队列，顺序执行，直到所有请求都被处理。  
2. 耗时操作：如@loki 提到的缩略图生成。  
3. 并行任务：如在发贴后分发通知所有的好友。

通信的思路主要用来解决在不同的独立模块或者系统之间相互同步数据、通知执行某些操作等。

### 常见 队列实现 的优缺点 ###

队列介质：

Mysql：可靠性高、易实现、速度慢
    Redis：速度快，单条大消息包时效率低
    消息系统：专业性强、可靠，学习成本高(比如：RabbtiMQ)

消息处理的触发机制：

死循环方式读取：易实现，故障时无法及时恢复；
    定时任务：压力均分，有处理量上限。(最大的缺陷：定位任务时间的间隔和处理的数据需要精准把握，不能上一个任务还没有处理完成，下一个认为就已经启动了)
    
    守护进程：类似于PHP-FPM和PHP-CGI，需要shell知识

[SouthEast]: /images/20220515/097a775fc7eb46019dece8ab703ee77e.png

发表评论取消回复

表情：

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

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

相关阅读

相关 PHP + Redis 实现消息队列

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

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

相关 php消息发布,PHP发送队列消息接收队列消息

$MSGKEY = 519052; $msg\_id = msg\_get\_queue ($MSGKEY, 0600); if (!msg\_send ($msg\_id

秒速五厘米/ 2022年11月18日 04:39/ 0 赞/ 214 阅读

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

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

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

相关消息队列及常见消息队列介绍

一、消息队列(MQ)概述消息队列（Message Queue），是分布式系统中重要的组件，其通用的使用场景可以简单地描述为： > 当不需要立即获得结果，但是并发量又需

青旅半醒/ 2022年10月05日 05:50/ 0 赞/ 272 阅读

相关消息队列简单介绍

模型 ZeroMQ 把通讯的需求看成四类。其中一类是一对一结对通讯，用来支持传统的 TCP socket 模型，但并不推荐使用。常用的通讯模式只有三类。 1. 请求回

Bertha 。/ 2022年06月04日 01:38/ 0 赞/ 254 阅读

相关消息队列（二）之消息队列基本概念详解

前言上一篇说明了一下，消息队列的用处和使用场景。这篇给大家简单介绍一下它的一些基本概念。一、消息队列的基本概念 1.1 Broker Broker的概念

柔情只为你懂/ 2022年05月27日 09:24/ 0 赞/ 184 阅读

相关消息队列及常见消息队列介绍

> 导语：消息队列是分布式系统中重要的组件，在很多生产环境如商品抢购等需要控制并发量的场景下都需要用到。最近组内需要做流水server的选型升级，这里对消息队列及常见的消息

落日映苍穹つ/ 2022年05月19日 13:26/ 0 赞/ 315 阅读

相关 PHP消息队列实现及应用：消息队列概念介绍

在互联网项目开发者经常会遇到『给用户群发短信』、『订单系统有大量的日志需要记录』或者在秒杀业务的时候服务器无法承受瞬间并发的压力。这种情况下，我们怎么保证系统正常

一时失言乱红尘/ 2022年05月15日 08:06/ 0 赞/ 262 阅读

相关消息队列技术介绍

一、消息队列概述消息队列中间件是分布式系统中重要的组件，主要解决应用耦合、异步消息、流量削锋等问题。实现高性能、高可用、可伸缩和最终一致性架构。是大型分布式系统不可缺

Bertha 。/ 2022年03月28日 12:38/ 0 赞/ 266 阅读

相关消息队列介绍

来源：[https://blog.csdn.net/boonya/article/details/68064231][https_blog.csdn.net_boonya_ar

墨蓝/ 2022年03月25日 08:20/ 0 赞/ 292 阅读