消息隊列常用在流量削峰(秒殺場景),異步通信等地方。
大體的結構如下:

類似於消費者和生產者的關系,首先生產者在消息隊列未滿的時候,才將生產的產品放進消息隊列中;消費者在消息隊列不為空的時候,才從消息隊列中取出產品進行消費。出隊的那個步驟常用的方法是一直輪詢和定時操作。
這里舉一個外賣送餐的案例:
有個生意很好的飯店,好到什么程度呢?一分鍾有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實現消息隊列,與這個方法類似。需要注意的是,上面的代碼其實有很大的問題,比如,如果涉及到並發,數據庫中同時操作一條數據怎么辦,這個時候,考慮的問題就多了。
