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、成功率高,失敗的記錄會自動重發,直到成功


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM