您好,登錄后才能下訂單哦!
這篇文章主要為大家展示了PHP如何添加MySQL消息隊列,內(nèi)容簡而易懂,條理清晰,希望能夠幫助大家解決疑惑,下面讓小編帶大家一起來研究并學習一下“PHP如何添加MySQL消息隊列”這篇文章吧。
消息隊列:在消息的傳輸過程中保存消息的容器。
消息隊列管理器在將消息從它的源中繼到它的目標時充當中間人。隊列的主要目的是提供路由并保證消息的傳遞;如果發(fā)送消息時接收者不可用,消息隊列會保留消息,直到可以成功地傳遞它。
如圖所示:
在不使用消息隊列的情況下,用戶的請求數(shù)據(jù)直接寫入數(shù)據(jù)庫,再高并發(fā)的情況下,會對數(shù)據(jù)庫造成巨的壓力,同時也使得響應延遲加劇。在使用消息隊列后,用戶請求的數(shù)據(jù)發(fā)送給消息隊列后立即返回,再由消息隊列的消費者進程(通常情況下,該進程獨立部署在專門的服務器集群上)從消息隊列中獲取數(shù)據(jù),異步寫入數(shù)據(jù)庫。由于消息隊列服務器處理速度遠大于數(shù)據(jù)庫,因此用戶的響應延遲可得到有效改善。
尤其是在淘寶搞“雙十一”,“春節(jié)特賣”等活動時,使用消息隊列有很好的削峰作用--------
即通過異步處理,將短時間高并發(fā)產(chǎn)生的事務消息存儲在消息隊列中,從而削平高峰期的并發(fā)事務。所以在一些電子商務網(wǎng)站促銷活動中,合理使用消息隊列,可有效抵御促銷活動剛開始大量涌入的訂單對系統(tǒng)造成的沖擊。
需要注意的是,由于數(shù)據(jù)寫入消息隊列后立即返回給用戶數(shù)據(jù)在后續(xù)的業(yè)務校驗、寫數(shù)據(jù)庫等操作可能失敗,因此在使用消息隊列進行業(yè)務異步處理后,需要適當修改業(yè)務流程進行配合,如訂單提交后,訂單數(shù)據(jù)寫入消息隊列,不能立即返回用戶訂單提交成功,需要在消息隊列的訂單消費者進程真正處理完該訂單,甚至商品出庫后,再通過電子郵件或SMS消息通知用戶訂單成功,以免交易糾紛。
最近遇到一個批量發(fā)送短信的需求,短信接口是第三方提供的。剛開始想到,獲取到手機號之后,循環(huán)調(diào)用接口發(fā)送不就可以了嗎?
但很快發(fā)現(xiàn)問題:當短信數(shù)量很大時,不僅耗時,而且成功率很低。
于是想到,用PHP和MySQL實現(xiàn)一個消息隊列,一條一條的發(fā)送短信。下面介紹具體的實現(xiàn)方法:
首先,建立一個數(shù)據(jù)表sms,包含以下字段:
id, phone, //手機號 content //短信內(nèi)容
將需要發(fā)送的短信和手機號存入sms表中。
接下來,需要用PHP實現(xiàn)一個定時器,定時讀取一條記錄,并發(fā)送短信:
<?php $db = new Db(); $sms = new Sms(); while(true){ $item = $db->getFirstRecord(); //獲取數(shù)據(jù)表第一條記錄 if(!$item){ //如果隊列中沒有數(shù)據(jù),則結束定時器 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,打開命令行,執(zhí)行定時器:
php timer_sms.php
以上就是關于“PHP如何添加MySQL消息隊列”的內(nèi)容,如果改文章對你有所幫助并覺得寫得不錯,勞請分享給你的好友一起學習新知識,若想了解更多相關知識內(nèi)容,請多多關注億速云行業(yè)資訊頻道。
免責聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權內(nèi)容。