消息隊列：在消息的傳輸過程中保存消息的容器。
消息隊列管理器在將消息從它的源中繼到它的目標時充當中間人。隊列的主要目的是提供路由并保證消息的傳遞；如果發送消息時接收者不可用，消息隊列會保留消息，直到可以成功地傳遞它。

如圖所示：
在不使用消息隊列的情況下，用戶的請求數據直接寫入數據庫，再高并發的情況下，會對數據庫造成巨的壓力，同時也使得響應延遲加劇。在使用消息隊列后，用戶請求的數據發送給消息隊列后立即返回，再由消息隊列的消費者進程（通常情況下，該進程獨立部署在專門的服務器集群上）從消息隊列中獲取數據，異步寫入數據庫。由于消息隊列服務器處理速度遠大于數據庫，因此用戶的響應延遲可得到有效改善。

尤其是在淘寶搞“雙十一”，“春節特賣”等活動時，使用消息隊列有很好的削峰作用--------
即通過異步處理，將短時間高并發產生的事務消息存儲在消息隊列中，從而削平高峰期的并發事務。所以在一些電子商務網站促銷活動中，合理使用消息隊列，可有效抵御促銷活動剛開始大量涌入的訂單對系統造成的沖擊。

需要注意的是，由于數據寫入消息隊列后立即返回給用戶數據在后續的業務校驗、寫數據庫等操作可能失敗，因此在使用消息隊列進行業務異步處理后，需要適當修改業務流程進行配合，如訂單提交后，訂單數據寫入消息隊列，不能立即返回用戶訂單提交成功，需要在消息隊列的訂單消費者進程真正處理完該訂單，甚至商品出庫后，再通過電子郵件或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消息隊列內容請搜索腳本之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持腳本之家！