PHP+MySQL實現(xiàn)消息隊列的方法分析

更新時間：2018年05月09日 10:01:11 作者：戰(zhàn)神悟空

這篇文章主要介紹了PHP+MySQL實現(xiàn)消息隊列的方法,結(jié)合實例形式分析了php+mysql構(gòu)建消息隊列并使用定時器間歇發(fā)送信息相關(guān)操作技巧,需要的朋友可以參考下

本文實例講述了PHP+MySQL實現(xiàn)消息隊列的方法。分享給大家供大家參考，具體如下：

最近遇到一個批量發(fā)送短信的需求，短信接口是第三方提供的。剛開始想到，獲取到手機號之后，循環(huán)調(diào)用接口發(fā)送不就可以了嗎？

但很快發(fā)現(xiàn)問題：當短信數(shù)量很大時，不僅耗時，而且成功率很低。

于是想到，用PHP和MySQL實現(xiàn)一個消息隊列，一條一條的發(fā)送短信。下面介紹具體的實現(xiàn)方法：

首先，建立一個數(shù)據(jù)表sms，包含以下字段：

id,
phone, //手機號
content //短信內(nèi)容

將需要發(fā)送的短信和手機號存入sms表中。

接下來，需要用PHP實現(xiàn)一個定時器，定時讀取一條記錄，并發(fā)送短信：

<?php
$db = new Db();
$sms = new Sms();
while(true){
  $item = $db->getFirstRecord(); //獲取數(shù)據(jù)表第一條記錄
  if(!$item){
    //如果隊列中沒有數(shù)據(jù)，則結(jié)束定時器
    break;
  }
  $res = $sms->send($item['phone'],$item['content']); //發(fā)送短信
  if($res){
    $db->deleteFristRecord(); //刪除發(fā)送成功的記錄
    echo $item['phone'].'發(fā)送成功';
  }else{
    echo $item['phone'].'發(fā)送失敗，稍后繼續(xù)嘗試'；
  }
  sleep(10); //每隔十秒循環(huán)一次
}
echo '發(fā)送完畢！';
?>

將代碼保存為timer_sms.php，打開命令行，執(zhí)行定時器：