PHP使用MySQL實現消息隊列


消息隊列常用在流量削峰(秒殺場景),異步通信等地方。

大體的結構如下:

   類似於消費者和生產者的關系,首先生產者在消息隊列未滿的時候,才將生產的產品放進消息隊列中;消費者在消息隊列不為空的時候,才從消息隊列中取出產品進行消費。出隊的那個步驟常用的方法是一直輪詢和定時操作。

這里舉一個外賣送餐的案例:

  有個生意很好的飯店,好到什么程度呢?一分鍾有500人下單,這樣的話,店家掌櫃肯定處理不過來,於是,就先暫時不通知用戶是夠接單,先把所有的訂單先存着,只告訴他們正在處理中,但是呢,還有一個問題,就是有一些是其他飯店專門來搞事的(眼紅了),所以就要查看訂單是否合法。

  上面的情景可以這樣實現:用戶下單之后,后台會創建一個隨機的order_id對應該訂單;並且該訂單的初始狀態(status)為待處理(0);當商家查看該訂單情況時,將status改為1,表示正在處理;當商家確認這個訂單可以接受時,就將該訂單的status改為2,表示成功接單。

  首先在數據庫中創建一個order_list訂單表,表結構如下:

mysql> desc order_list;
+----------+------------+------+-----+----------+-------+
| Field    | Type       | Null | Key | Default  | Extra |
+----------+------------+------+-----+----------+-------+
| order_id | int(11)    | NO   | PRI | NULL     |       |
| mobile   | int(8)     | NO   |     | 88888888 |       |
| status   | tinyint(1) | YES  |     | 0        |       |
+----------+------------+------+-----+----------+-------+
3 rows in set (0.05 sec)

  有兩個PHP程序,分別是producer.php(用戶、生產者);     consumer.php(商家、消費者)  

  一旦有用戶下單,就往order_list中添加一條數據,這里方便測試,於是執行下面的PHP程序,表示用戶方(producer.php),每隔2秒下一次單;

<?php 
	$pdo=new PDO("mysql:host=localhost;dbname=test","root","root");
	$stmt=$pdo->prepare("insert into order_list (order_id,mobile,status) values (?,?,?)");
	while(1){
		$order_id=rand(10000,99999);
		$mobile=rand(11111111,99999999);
		$stmt->execute(array($order_id,$mobile,0));
		echo date("Y-m-d H:i:s",time())."添加了一條訂單,訂單號為{$order_id},手機號為{$mobile}\n";
		sleep(2);
	}
 ?>

  用戶提交訂單后,剩下的事情就交給商家了,商家(consumer.php)生意太忙了,每4秒才能處理一個訂單:

<?php 
	$pdo=new PDO("mysql:host=localhost;dbname=test","root","root");
	$stmt=$pdo->prepare("update order_list set status=? where status=? limit 1");
	$stmt_select=$pdo->prepare("select order_id from order_list where status=1");//正在處理的訂單號
	while(1){
		$init=0;//初始status
		$lock=1;//標記為正在處理
		$success=2;//成功接單
		//為了保證數據的一致性,處理訂單之前,要先鎖定一個訂單,將其status由0改為1,然后才可處理
		//處理完畢后,然后再將status從1改為2

		$stmt->execute(array($lock,$init));//鎖定要處理的訂單
		$stmt_select->execute();
		$result=$stmt_select->fetch(PDO::FETCH_ASSOC);//查詢正在處理的訂單號
		$order_id=$result['order_id'];
		echo date("Y-m-d H:i:s")."准備處理訂單,訂單號為{$order_id}\n";
		sleep(3);//處理3秒
		$stmt->execute(array($success,$lock));
		echo date("Y-m-d H:i:s")."訂單處理完成,訂單號為{$order_id}\n";
		sleep(1);//休息1秒
	}
 ?>

  這樣就使用MySQL實現了一個簡單的消息隊列,可以看一下如何使用Redis實現消息隊列,與這個方法類似。需要注意的是,上面的代碼其實有很大的問題,比如,如果涉及到並發,數據庫中同時操作一條數據怎么辦,這個時候,考慮的問題就多了。

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM