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

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

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

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

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

id,
phone, //手機(jī)號(hào)
content //短信內(nèi)容

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

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

<?php$db = new Db();$sms = new Sms();while(true){  $item = $db->getFirstRecord(); //獲取數(shù)據(jù)表第一條記錄  if(!$item){    //如果隊(duì)列中沒(méi)有數(shù)據(jù)，則結(jié)束定時(shí)器    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，打開(kāi)命令行，執(zhí)行定時(shí)器：

php timer_sms.php

好了，php定時(shí)器將會(huì)根據(jù)設(shè)定的時(shí)間間隔（這里設(shè)的是10秒），自動(dòng)完成發(fā)送短信的任務(wù)。任務(wù)完成后將自動(dòng)退出定時(shí)器，不再占用服務(wù)器資源。

根據(jù)我的測(cè)試，PHP定時(shí)器占用資源并不多，不會(huì)對(duì)服務(wù)器造成壓力。而且是異步訪問(wèn)數(shù)據(jù)庫(kù)，也不會(huì)影響數(shù)據(jù)庫(kù)的運(yùn)行。

這種方式的優(yōu)點(diǎn)是：

1、后臺(tái)運(yùn)行，前臺(tái)無(wú)需等待

2、成功率高，失敗的記錄會(huì)自動(dòng)重發(fā)，直到成功

希望本文所述對(duì)大家PHP程序設(shè)計(jì)有所幫助。