本文實例講述了PHP+MySQL實現消息隊列的方法。分享給大家供大家參考,具體如下:
最近遇到一個批量發送短信的需求,短信接口是第三方提供的。剛開始想到,獲取到手機號之后,循環調用接口發送不就可以了嗎?
但很快發現問題:當短信數量很大時,不僅耗時,而且成功率很低。
于是想到,用PHP和MySQL實現一個消息隊列,一條一條的發送短信。下面介紹具體的實現方法:
首先,建立一個數據表sms,包含以下字段:
id,
phone, //手機號
content //短信內容
將需要發送的短信和手機號存入sms表中。
接下來,需要用PHP實現一個定時器,定時讀取一條記錄,并發送短信:
?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 '發送完畢!';
?>
將代碼保存為timer_sms.php,打開命令行,執行定時器:
好了,php定時器將會根據設定的時間間隔(這里設的是10秒),自動完成發送短信的任務。任務完成后將自動退出定時器,不再占用服務器資源。
根據我的測試,PHP定時器占用資源并不多,不會對服務器造成壓力。而且是異步訪問數據庫,也不會影響數據庫的運行。
這種方式的優點是:
1、后臺運行,前臺無需等待
2、成功率高,失敗的記錄會自動重發,直到成功
更多關于PHP相關內容感興趣的讀者可查看本站專題:《php+mysql數據庫操作入門教程》、《php+mysqli數據庫程序設計技巧總結》、《php面向對象程序設計入門教程》、《PHP數組(Array)操作技巧大全》、《php字符串(string)用法總結》及《php常見數據庫操作技巧匯總》
希望本文所述對大家PHP程序設計有所幫助。
您可能感興趣的文章:- PHP使用ActiveMQ實現消息隊列的方法詳解
- PHP使用ActiveMQ實例
- PHP Beanstalkd消息隊列的安裝與使用方法實例詳解
- 基于PHP實現微信小程序客服消息功能
- PHP消息隊列實現及應用詳解【隊列處理訂單系統和配送系統】
- PHP+RabbitMQ實現消息隊列的完整代碼
- PHP多進程通信-消息隊列使用
- php基于Redis消息隊列實現的消息推送的方法
- 使用PHP訪問RabbitMQ消息隊列的方法示例
- php實現微信模板消息推送
- php ActiveMQ的安裝與使用方法圖文教程