1. 程式人生 > >PHP訊息佇列的實現方式

PHP訊息佇列的實現方式

佇列的概念:

1、是佇列結構的中介軟體

2、訊息放入後不需要立即處理

3、由訂閱者/消費者按順序處理

佇列原理:

在這裡插入圖片描述

也是解耦的原理:業務系統和佇列處理系統沒有關係

一個寫(業務系統),一個讀(佇列管理系統)。

寫的只管往佇列裡寫,別的不用操心,讀的能不能讀完和寫的也沒有關係

同樣,讀的只管從佇列裡往外讀,來活兒就幹,沒活兒歇著

應用場景:

冗餘:持久化的儲存在佇列中,後續由訂單處理程式獲取,處理完成之後,在把這條記錄進行刪除

解耦:是解這2套系統(業務和佇列處理),我們平常做的都是一套系統的。入隊和出隊的系統沒有直接的關係,其中一套蹦了,另一套系統不會受影響,因為中間隔了個佇列

流量削鋒:秒殺和搶購。流量劇增,配合快取使用訊息佇列(就是限制下,如 只允許10個,佇列裡存10個之後就不存了,在來就提示秒殺結束)

非同步通訊:因為訊息本身就可使入隊的系統直接返回,所以說實現了程式的非同步操作

場景擴充套件性:如 現在只有訂單系統和財務系統,後續我想加個配貨系統,直接讓配貨系統訂閱這個佇列就可以

排序保證:有些場景下,如 銀行資料的處理順序是很重要的,因為佇列本身就可以做成單執行緒,單進單出的這種系統

實現介質:

1、使用mysql:可靠性高,易實現,速度慢

2、使用redis:速度快,單條大訊息包時效率低

3、使用更專業的第三方類庫:專業性強,可靠,學習成本高。

請參考我這篇部落格http://blog.csdn.net/qq_33862644/article/details/79386484

訊息處理觸發機制:

1、死迴圈方式讀取:易實現,故障時無法及時回覆(適用於秒殺這種短時間的)

2、定時任務:壓力均分,有處理上限(無論你佇列前的系統,峰值多麼不穩定,佇列後的系統依然會定時執行)

注意:定時時間是個關鍵:不要上一個還定時任務沒執行完,下一個定時任務就啟動了

案例:訂單系統,下單後將訂單資訊寫入佇列後,立刻返回下單成功。配貨系統每隔幾分鐘定時讀取佇列,對訂單進行彙總處理

3、守護程序:類似於php-fpm和cgi,需要shell基礎(用這個程序來檢測,佇列中是否有內容,有內容的話,啟動出隊系統進行處理)

使用mysql實現解耦案例:
為什麼要解耦:如果架構在一起。訂單系統壓力大,而物流資訊是不需要立刻返回的。訂單崩了,物流也就蹦了,所以要解耦

在這裡插入圖片描述

在這裡插入圖片描述

表的設計:
在這裡插入圖片描述

訂單系統寫入佇列的程式碼:

在這裡插入圖片描述

配貨系統讀取佇列的程式碼:

在這裡插入圖片描述

執行定時任務Crontab -e

在這裡插入圖片描述

注意:這日誌檔案要自己新建

1、通過瀏覽器訪問order.php新增訂單

2、去資料庫看結果,在shell中的日誌中看結果(沒有執行成功,可能是這sh檔案需要放在某個特點目錄吧,等複習完 在跑)

使用redis進行流量削鋒案例
在這裡插入圖片描述

思路:

1、秒殺程式請求寫入redis

2、檢查redis已存放資料的長度,超出上限直接丟棄(返回秒殺結束)

3、死迴圈處理存入redis的資料併入庫

表的設計:
在這裡插入圖片描述

秒殺程式碼:

在這裡插入圖片描述

入庫程式碼:

在這裡插入圖片描述

瀏覽器直接訪問user.php

在shell中使用php -f savetodb.php

去資料庫檢視

轉載自公眾號
在這裡插入圖片描述