PHP加MySQL消息队列深入理解

消息队列：在消息的传输过程中保存消息的容器。
消息队列管理器在将消息从它的源中继到它的目标时充当中间人。队列的主要目的是提供路由并保证消息的传递；如果发送消息时接收者不可用，消息队列会保留消息，直到可以成功地传递它。

如图所示：
在不使用消息队列的情况下，用户的请求数据直接写入数据库，再高并发的情况下，会对数据库造成巨的压力，同时也使得响应延迟加剧。在使用消息队列后，用户请求的数据发送给消息队列后立即返回，再由消息队列的消费者进程（通常情况下，该进程独立部署在专门的服务器集群上）从消息队列中获取数据，异步写入数据库。由于消息队列服务器处理速度远大于数据库，因此用户的响应延迟可得到有效改善。

尤其是在淘宝搞“双十一”，“春节特卖”等活动时，使用消息队列有很好的削峰作用--------
即通过异步处理，将短时间高并发产生的事务消息存储在消息队列中，从而削平高峰期的并发事务。所以在一些电子商务网站促销活动中，合理使用消息队列，可有效抵御促销活动刚开始大量涌入的订单对系统造成的冲击。

需要注意的是，由于数据写入消息队列后立即返回给用户数据在后续的业务校验、写数据库等操作可能失败，因此在使用消息队列进行业务异步处理后，需要适当修改业务流程进行配合，如订单提交后，订单数据写入消息队列，不能立即返回用户订单提交成功，需要在消息队列的订单消费者进程真正处理完该订单，甚至商品出库后，再通过电子邮件或SMS消息通知用户订单成功，以免交易纠纷。

最近遇到一个批量发送短信的需求，短信接口是第三方提供的。刚开始想到，获取到手机号之后，循环调用接口发送不就可以了吗？

但很快发现问题：当短信数量很大时，不仅耗时，而且成功率很低。

于是想到，用PHP和MySQL实现一个消息队列，一条一条的发送短信。下面介绍具体的实现方法：

首先，建立一个数据表sms，包含以下字段：

id,
phone, //手机号
content //短信内容

<?php
$db = new Db();
$sms = new Sms();
while(true){
  $item = $db->getFirstRecord(); //获取数据表第一条记录
  if(!$item){
    //如果队列中没有数据，则结束定时器
    break;
  }
  $res = $sms->send($item['phone'],$item['content']); //发送短信
  if($res){
    $db->deleteFristRecord(); //删除发送成功的记录
    echo $item['phone'].'发送成功';
  }else{
    echo $item['phone'].'发送失败，稍后继续尝试'；
  }
  sleep(10); //每隔十秒循环一次      
}
 
echo '发送完毕！';
?>

php timer_sms.php