[toc] ## :-: **队列 的 概念** 1、是队列结构的中间件 2、消息放入后<span style="color:red;">不需要立即处理</span> 3、由订阅者/消费者按顺序处理 ## :-: **队列 原理**  - 也是解耦的原理：业务系统和队列处理系统没有关系 - 一个写（业务系统），一个读（队列管理系统）。 - <span style="color:red;">写的只管</span>往队列里<span style="color:blue;">写</span>，别的不用操心，读的能不能读完和写的也没有关系 - 同样，<span style="color:red;">读的只管</span>从队列里往外<span style="color:blue;">读</span>，来活儿就干，没活儿歇着 ## :-: **应用场景** - 冗余：<span style="color:red;">持久化的存储在队列中</span>，后续由订单处理程序获取，处理完成之后，在把这条记录进行删除 - 解耦：是解这2套系统（业务和队列处理），我们平常做的都是一套系统的。入队和出队的系统没有直接的关系，<span style="color:red;">其中一套蹦了，另一套系统不会受影响</span>，因为中间隔了个队列 - 流量削锋：秒杀和抢购。流量剧增，<span style="color:red;">配合缓存使用消息队列</span>（就是限制下，如 只允许10个，队列里存10个之后就不存了，在来就提示秒杀结束） - 异步通信：<span style="color:red;">因为消息本身就可使入队的系统</span>直接返回，所以说实现了程序的异步操作 - 场景扩展性：如 现在只有订单系统和财务系统，后续我想加个配货系统，<span style="color:red;">直接让配货系统订阅这个队列就可以 </span> - 排序保证：有些场景下，如 银行数据的<span style="color:red;">处理顺序是很重要</span>的，因为队列本身就可以做成单线程，单进单出的这种系统 ## :-: **实现介质** 1、使用mysql：可靠性高，易实现，速度慢 2、使用redis：速度快，单条大消息包时效率低 3、使用更专业的第三方类库：专业性强，可靠，学习成本高。 请参考我这篇博客http://blog.csdn.net/qq\_33862644/article/details/79386484 ## :-: **消息触发机制** 1、死循环方式读取：易实现，故障时无法及时回复（<span style="color:red;">适用于秒杀这种短时间的</span>） 2、定时任务：压力均分，有处理上限（无论你队列前的系统，峰值多么不稳定，<span style="color:red;">队列后的系统依然会定时执行</span>） >[warning]定时时间是个关键：不要上一个还定时任务没执行完，下一个定时任务就启动了 示例：订单系统，下单后将订单信息写入队列后，立刻返回下单成功。配货系统每隔几分钟<span style="color:red;">定时读取队列</span>，对订单进行汇总处理 3、守护进程：类似于php-fpm和cgi，需要shell基础（用这个进程来检测，队列中是否有内容，有内容的话，启动出队系统进行处理） ## :-: **使用mysql实现解耦的示例** - 为什么要解耦：如果架构在一起。订单系统压力大，而物流信息是不需要立刻返回的。订单崩了，物流也就蹦了，所以要解耦   - 表的设计  - 订单系统写入队列的代码  - 配货系统读取队列的代码  执行定时任务crontab -e  >[warning] 这日志要自己新建  1、通过浏览器访问order.php添加订单 2、去数据库看结果，在shell中的日志中看结果(没有执行成功，可能是这sh文件需要放在某个特点目录吧，等复习完 在跑) ## :-: **使用redis进行流量削锋的示例**  - 思路： 1、秒杀程序请求写入redis     2、检查redis已存放数据的长度，超出上限直接丢弃（返回秒杀结束） 3、死循环处理存入redis的数据并入库 - 表的设计：  - 秒杀代码  - 入库代码  浏览器直接访问user.php 在shell中使用php -f savetodb.php 去数据库查看