php队列处理mysql_php队列处理：php消息队列实现原理（图文）

php队列是什么意思？怎么实现的？有哪些应用场景？以下通过使用mysql实现解耦案例和使用redis进行流量削锋案例详细讲解php消息队列的实现原理。

队列的概念：

1、是队列结构的中间件

2、消息放入后不需要立即处理

3、由订阅者/消费者按顺序处理

队列原理：

也是解耦的原理：业务系统和队列处理系统没有关系

一个写(业务系统)，一个读(队列管理系统)。

写的只管往队列里写，别的不用操心，读的能不能读完和写的也没有关系

同样，读的只管从队列里往外读，来活儿就干，没活儿歇着

应用场景：

冗余：持久化的存储在队列中，后续由订单处理程序获取，处理完成之后，在把这条记录进行删除

解耦：是解这2套系统(业务和队列处理)，我们平常做的都是一套系统的。入队和出队的系统没有直接的关系，其中一套蹦了，另一套系统不会受影响，因为中间隔了个队列

流量削锋：秒杀和抢购。流量剧增，配合缓存使用消息队列(就是限制下，如只允许10个，队列里存10个之后就不存了，在来就提示秒杀结束)

异步通信：因为消息本身就可使入队的系统直接返回，所以说实现了程序的异步操作

场景扩展性：如现在只有订单系统和财务系统，后续我想加个配货系统，直接让配货系统订阅这个队列就可以

排序保证：有些场景下，如银行数据的处理顺序是很重要的，因为队列本身就可以做成单线程，单进单出的这种系统

实现介质：

1、使用mysql：可靠性高，易实现，速度慢

2、使用redis：速度快，单条大消息包时效率低

3、使用更专业的第三方类库：专业性强，可靠，学习成本高。

消息处理触发机制：

1、死循环方式读取：易实现，故障时无法及时回复(适用于秒杀这种短时间的)

2、定时任务：压力均分，有处理上限(无论你队列前的系统，峰值多么不稳定，队列后的系统依然会定时执行)

注意：定时时间是个关键：不要上一个还定时任务没执行完，下一个定时任务就启动了

案例：订单系统，下单后将订单信息写入队列后，立刻返回下单成功。配货系统每隔几分钟定时读取队列，对订单进行汇总处理

3、守护进程：类似于php-fpm和cgi，需要shell基础(用这个进程来检测，队列中是否有内容，有内容的话，启动出队系统进行处理)

使用mysql实现解耦案例：

为什么要解耦：如果架构在一起。订单系统压力大，而物流信息是不需要立刻返回的。订单崩了，物流也就蹦了，所以要解耦

表的设计：

订单系统写入队列的代码：

配货系统读取队列的代码：

执行定时任务Crontab -e

注意：这日志文件要自己新建

1、通过浏览器访问order.php添加订单

2、去数据库看结果，在shell中的日志中看结果(没有执行成功，可能是这sh文件需要放在某个特点目录吧，等复习完在跑)

使用redis进行流量削锋案例

思路：

1、秒杀程序请求写入redis

2、检查redis已存放数据的长度，超出上限直接丢弃(返回秒杀结束)

3、死循环处理存入redis的数据并入库

表的设计：

秒杀代码：

入库代码：

浏览器直接访问user.php

在shell中使用php -f savetodb.php

去数据库查看

php队列处理mysql_php队列处理：php消息队列实现原理（图文）相关推荐

消息队列系列二（IOT中消息队列的应用）
许多消息队列旨在为您的应用程序提供轻量级的发布/订阅消息传输协议.为什么以及何时在您的物联网项目中使用消息队列? 考虑温室中的温度传感器,它测量温度.您的应用程序可以在15分钟的时间间隔内(每天月96 ...
redis 队列_Redis系列5实现简单消息队列
任务异步化打开浏览器,输入地址,按下回车,打开了页面.于是一个HTTP请求(request)就由客户端发送到服务器,服务器处理请求,返回响应(response)内容. 我们每天都在浏览网页,发送大大 ...
【重难点】【RabbitMQ 01】消息队列的作用、主流的消息队列、RabbitMQ 基于什么传输消息、RabbitMQ 模型架构、死信队列和延迟队列
[重难点][RabbitMQ 01]消息队列的作用.主流的消息队列.RabbitMQ 基于什么传输消息.RabbitMQ 模型架构.死信队列和延迟队列文章目录 [重难点][RabbitMQ 01]消 ...
【消息队列笔记】chp2-如何选择消息队列
一.选择消息队列的基本标准不同的消息队列产品在功能和特性方面是各有优劣的,但是我们在选择的时候应尽量保证一个通用的最低标准. 1.必须是开源的产品开源很重要,如果在使用该产品时遇到了影响业务的bu ...
rabbitmq实战:高效部署分布式消息队列_一文看懂消息队列中间件--AMQ及部署介绍...
概述最近有个小项目用到了AMQ来做消息队列,之前介绍的主要是rabbitmq,所以今天主要提一下AMQ,也简单介绍下两者的区别~ 消息队列中间件消息队列中间件(简称消息中间件)是指利用高效可靠的消 ...
阿里云消息队列python_41. Python Queue 多进程的消息队列 PIPE
消息队列: 消息队列是在消息传输过程中保存消息的容器. 消息队列最经典的用法就是消费者和生产者之间通过消息管道来传递消息,消费者和生产生是不通的进程.生产者往管道中写消息,消费者从管道中读消息. 相当 ...
python 消息队列如何接收处理_python使用消息队列RabbitMq（进阶）
importpika connection=pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel=connec ...
python消息队列celery高可用_分布式消息队列-Celery
怎么能不恨呢,在我发现自己是恶鬼的时候,在我最绝望最虚弱的时候,这个世上最该跟我在一起的人却用刀把我的心刺穿了 Celery 是 Distributed Task Queue,分布式任务队列.分布式决 ...
redis简单队列java_使用Redis的简单消息队列
redis简单队列java 在本文中,我们将使用列表命令将Redis用作简单的消息队列. 假设我们有一个允许用户上传照片的应用程序. 然后在应用程序中,我们以不同大小显示照片,例如Thumb,Medi ...
rabbitmq 消费端代码获取队列名称_C#调用RabbitMQ实现消息队列的示例代码
前言我在刚接触使用中间件的时候,发现,中间件的使用并不是最难的,反而是中间件的下载,安装,配置才是最难的. 所以,这篇文章我们从头开始学习RabbitMq,真正的从头开始. 关于消息队列其实消息队 ...

php队列处理mysql_php队列处理：php消息队列实现原理（图文）

php队列处理mysql_php队列处理：php消息队列实现原理（图文）相关推荐

最新文章

热门文章