本文實例講述了PHP+MySQL實現(xiàn)消息隊列的方法。分享給大家供大家參考,具體如下:
最近遇到一個批量發(fā)送短信的需求,短信接口是第三方提供的。剛開始想到,獲取到手機(jī)號之后,循環(huán)調(diào)用接口發(fā)送不就可以了嗎?
但很快發(fā)現(xiàn)問題:當(dāng)短信數(shù)量很大時,不僅耗時,而且成功率很低。
于是想到,用PHP和MySQL實現(xiàn)一個消息隊列,一條一條的發(fā)送短信。下面介紹具體的實現(xiàn)方法:
首先,建立一個數(shù)據(jù)表sms,包含以下字段:
id,
phone, //手機(jī)號
content //短信內(nèi)容
將需要發(fā)送的短信和手機(jī)號存入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í)行定時器:
php timer_sms.php
好了,php定時器將會根據(jù)設(shè)定的時間間隔(這里設(shè)的是10秒),自動完成發(fā)送短信的任務(wù)。任務(wù)完成后將自動退出定時器,不再占用服務(wù)器資源。
根據(jù)我的測試,PHP定時器占用資源并不多,不會對服務(wù)器造成壓力。而且是異步訪問數(shù)據(jù)庫,也不會影響數(shù)據(jù)庫的運行。
這種方式的優(yōu)點是:
1、后臺運行,前臺無需等待
2、成功率高,失敗的記錄會自動重發(fā),直到成功
希望本文所述對大家PHP程序設(shè)計有所幫助。