PHP加MySQL消息隊列深入理解
消息隊列：在消息的傳輸過程中保存消息的容器。
消息隊列管理器在將消息從它的源中繼到它的目標時充當中間人。隊列的主要目的是提供路由並保證消息的傳遞；如果發送消息時接收者不可用，消息隊列會保留消息，直到可以成功地傳遞它。
如圖所示：
在不使用消息隊列的情況下，用戶的請求數據直接寫入數據庫，再高並發的情況下，會對數據庫造成巨的壓力，同時也使得響應延遲加劇。在使用消息隊列後，用戶請求的數據發送給消息隊列後立即返回，再由消息隊列的消費者進程（通常情況下，該進程獨立部署在專門的服務器集群上）從消息隊列中獲取數據，異步寫入數據庫。由於消息隊列服務器處理速度遠大於數據庫，因此用戶的響應延遲可得到有效改善。
尤其是在淘寶搞“雙十一”，“春節特賣”等活動時，使用消息隊列有很好的削峰作用——–
即通過異步處理，將短時間高並發產生的事務消息存儲在消息隊列中，從而削平高峰期的並發事務。所以在一些電子商務網站促銷活動中，合理使用消息隊列，可有效抵禦促銷活動剛開始大量湧入的訂單對系統造成的沖擊。
需要註意的是，由於數據寫入消息隊列後立即返回給用戶數據在後續的業務校驗、寫數據庫等操作可能失敗，因此在使用消息隊列進行業務異步處理後，需要適當修改業務流程進行配合，如訂單提交後，訂單數據寫入消息隊列，不能立即返回用戶訂單提交成功，需要在消息隊列的訂單消費者進程真正處理完該訂單，甚至商品出庫後，再通過電子郵件或SMS消息通知用戶訂單成功，以免交易糾紛。
最近遇到一個批量發送短信的需求，短信接口是第三方提供的。剛開始想到，獲取到手機號之後，循環調用接口發送不就可以瞭嗎？
但很快發現問題：當短信數量很大時，不僅耗時，而且成功率很低。
於是想到，用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+MySQL消息隊列深入理解的文章就介紹到這瞭,更多相關PHP+MySQL消息隊列內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！