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 timer_sms.php

好了，php定時器將會根據設定的時間間隔（這里設的是10秒），自動完成發送短信的任務。任務完成后將自動退出定時器，不再占用服務器資源。

根據我的測試，PHP定時器占用資源并不多，不會對服務器造成壓力。而且是異步訪問數據庫，也不會影響數據庫的運行。

這種方式的優點是：

1、后臺運行，前臺無需等待

2、成功率高，失敗的記錄會自動重發，直到成功

來自：http://my.oschina.net/crazymus/blog/479741