PHP加MySQL消息隊(duì)列深入理解

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

如圖所示：
在不使用消息隊(duì)列的情況下，用戶的請(qǐng)求數(shù)據(jù)直接寫(xiě)入數(shù)據(jù)庫(kù)，再高并發(fā)的情況下，會(huì)對(duì)數(shù)據(jù)庫(kù)造成巨的壓力，同時(shí)也使得響應(yīng)延遲加劇。在使用消息隊(duì)列后，用戶請(qǐng)求的數(shù)據(jù)發(fā)送給消息隊(duì)列后立即返回，再由消息隊(duì)列的消費(fèi)者進(jìn)程（通常情況下，該進(jìn)程獨(dú)立部署在專門的服務(wù)器集群上）從消息隊(duì)列中獲取數(shù)據(jù)，異步寫(xiě)入數(shù)據(jù)庫(kù)。由于消息隊(duì)列服務(wù)器處理速度遠(yuǎn)大于數(shù)據(jù)庫(kù)，因此用戶的響應(yīng)延遲可得到有效改善。

尤其是在淘寶搞“雙十一”，“春節(jié)特賣”等活動(dòng)時(shí)，使用消息隊(duì)列有很好的削峰作用--------
即通過(guò)異步處理，將短時(shí)間高并發(fā)產(chǎn)生的事務(wù)消息存儲(chǔ)在消息隊(duì)列中，從而削平高峰期的并發(fā)事務(wù)。所以在一些電子商務(wù)網(wǎng)站促銷活動(dòng)中，合理使用消息隊(duì)列，可有效抵御促銷活動(dòng)剛開(kāi)始大量涌入的訂單對(duì)系統(tǒng)造成的沖擊。

需要注意的是，由于數(shù)據(jù)寫(xiě)入消息隊(duì)列后立即返回給用戶數(shù)據(jù)在后續(xù)的業(yè)務(wù)校驗(yàn)、寫(xiě)數(shù)據(jù)庫(kù)等操作可能失敗，因此在使用消息隊(duì)列進(jìn)行業(yè)務(wù)異步處理后，需要適當(dāng)修改業(yè)務(wù)流程進(jìn)行配合，如訂單提交后，訂單數(shù)據(jù)寫(xiě)入消息隊(duì)列，不能立即返回用戶訂單提交成功，需要在消息隊(duì)列的訂單消費(fèi)者進(jìn)程真正處理完該訂單，甚至商品出庫(kù)后，再通過(guò)電子郵件或SMS消息通知用戶訂單成功，以免交易糾紛。

最近遇到一個(gè)批量發(fā)送短信的需求，短信接口是第三方提供的。剛開(kāi)始想到，獲取到手機(jī)號(hào)之后，循環(huán)調(diào)用接口發(fā)送不就可以了嗎？

但很快發(fā)現(xiàn)問(wèn)題：當(dāng)短信數(shù)量很大時(shí)，不僅耗時(shí)，而且成功率很低。

于是想到，用PHP和MySQL實(shí)現(xiàn)一個(gè)消息隊(duì)列，一條一條的發(fā)送短信。下面介紹具體的實(shí)現(xiàn)方法：

首先，建立一個(gè)數(shù)據(jù)表sms，包含以下字段：

id,
phone, //手機(jī)號(hào)
content //短信內(nèi)容

將需要發(fā)送的短信和手機(jī)號(hào)存入sms表中。

接下來(lái)，需要用PHP實(shí)現(xiàn)一個(gè)定時(shí)器，定時(shí)讀取一條記錄，并發(fā)送短信：

?php
$db = new Db();
$sms = new Sms();
while(true){
  $item = $db->getFirstRecord(); //獲取數(shù)據(jù)表第一條記錄
  if(!$item){
    //如果隊(duì)列中沒(méi)有數(shù)據(jù)，則結(jié)束定時(shí)器
    break;
  }
  $res = $sms->send($item['phone'],$item['content']); //發(fā)送短信
  if($res){
    $db->deleteFristRecord(); //刪除發(fā)送成功的記錄
    echo $item['phone'].'發(fā)送成功';
  }else{
    echo $item['phone'].'發(fā)送失敗，稍后繼續(xù)嘗試'；
  }
  sleep(10); //每隔十秒循環(huán)一次      
}
 
echo '發(fā)送完畢！';
?>

將代碼保存為timer_sms.php，打開(kāi)命令行，執(zhí)行定時(shí)器：

php timer_sms.php

到此這篇關(guān)于PHP+MySQL消息隊(duì)列深入理解的文章就介紹到這了,更多相關(guān)PHP+MySQL消息隊(duì)列內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！