您当前的位置 :首页 > 学习资料 > php队列处理:php消息队列实现原理(图文)
投稿

php队列处理:php消息队列实现原理(图文)

2021-03-21 23:12:59 来源: 作者: 责任编辑:cncml

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
去数据库查看

文章来源: 责任编辑:cncml
版权声明:
1、本主题所有言论和图片纯属会员个人意见,与本网站立场无关
2、本站所有主题由该文章作者发表,该文章作者与享有文章相关版权
3、其他单位或个人使用、转载或引用本文时必须同时征得该文章作者和的同意
4、文章作者须承担一切因本文发表而直接或间接导致的民事或刑事法律责任
5、本帖部分内容转载自其它媒体,但并不代表本站赞同其观点和对其真实性负责
6、如本帖侵犯到任何版权问题,请立即告知本站,本站将及时予与删除并致以最深的歉意
7、管理员和版主有权不事先通知发贴者而删除本文
不良信息举报信箱 新闻热线:18733599993 技术服务:18733599993 网上投稿
关于本站 | 广告服务 | 免责申明 | 招聘信息 | 联系我们
在线网 版权所有 Copyright(C)2005-2026