PHP如何添加MySQL消息隊列

這篇文章主要為大家展示了PHP如何添加MySQL消息隊列，內容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶大家一起來研究并學習一下“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消息隊列”的內容，如果改文章對你有所幫助并覺得寫得不錯，勞請分享給你的好友一起學習新知識，若想了解更多相關知識內容，請多多關注億速云行業資訊頻道。