Redis消息隊列實現(xiàn)秒殺教程

更新時間：2025年04月22日 10:26:43 作者：PengQQ_09

這篇文章主要介紹了Redis消息隊列實現(xiàn)秒殺教程,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教

Redis消息隊列實現(xiàn)秒殺

消息隊列的應(yīng)用場景例如：秒殺、搶單功能。

下面寫個Demo簡單實現(xiàn)一下秒殺，也就是搶購。

首先創(chuàng)建一個lpush.html文件

代碼如下：

<!DOCTYPE html>
<html>
    <head>
        <title>TODO supply a title</title>
        <meta charset="UTF-8">
        <meta name="viewport" content="width=device-width, initial-scale=1.0">
        <script src="jquery-3.2.1.min.js" ></script>
        <script>
			function push(uid){
	        	$('#msg'+uid).html('請耐心等待.......');
				$.get('lpush.php',{"uid":uid},function (data){
					if(data == 1 ){
						$('#msg'+uid).html('搶購成功!!');
					}else{
						$('#msg'+uid).html('搶購失敗!!');
					}
				});
			}
        </script>
    </head>
    <body>
        <span id="msg5"></span><br>
        <input type="button" value="搶購5" onclick="push(5)"><br>
        <span id="msg15"></span><br>
        <input type="button" value="搶購15" onclick="push(15)"><br>
        <span id="msg25"></span><br>
        <input type="button" value="搶購25" onclick="push(25)"><br>
        <span id="msg35"></span><br>
        <input type="button" value="搶購35" onclick="push(35)"><br>
        <span id="msg45"></span><br>
        <input type="button" value="搶購45" onclick="push(45)"><br>
        <span id="msg55"></span><br>
        <input type="button" value="搶購55" onclick="push(55)"><br>
    </body>
</html>

在創(chuàng)建一個lpush.php文件用來處理數(shù)據(jù)

這個文件里頭的內(nèi)容呢就是執(zhí)行入隊操作，代碼如下：

<?php
    //實例化redis對象
    $redis = new redis();
    //連接redis,第一個參數(shù)是redis服務(wù)的IP127.0.0.1是自己的,6379是端口號
    $redis->connect('127.0.0.1', 6379);
    //接收ajax傳來的值,請看lpush.html
    $uid = $_GET['uid'];
    //入隊列
    $redis->lpush('tv', $uid);
    //寫一個死循環(huán)用來判斷結(jié)果
    while (true) {
        //守護進程是否將所有訂單處理完畢
        if ($redis->scard('tvuser') == 5) {
            //判斷當(dāng)前用戶是否有對應(yīng)的訂單
            if ($redis->sismember('tvuser' , $uid)) {
                $flag = 1;
            } else {
                $flag = 0;
            }
            //返回給頁面
            echo $flag;
            //滿足條件后停止循環(huán)
            break;
         }
     }
?>

在創(chuàng)建一個守護進程的文件pop.php

這個文件里頭的主要內(nèi)容就是去隊列里頭的值并且返回人數(shù)是否已夠，代碼如下：

<?php
    //實例化redis對象
    $redis = new redis();
    //連接redis,第一個參數(shù)是redis服務(wù)的IP127.0.0.1是自己的,6379是端口號
    $redis->connect('127.0.0.1', 6379);
    //定義一個變量用來存儲循環(huán)次數(shù)
    $num = 0;
    //循環(huán)取值
    while (true) {
        //每隔一秒取一次
        sleep(1);
        //redis取值
        $uid = $redis->rpop('tv');
        //判斷取出來的UID又沒有值
        if ($uid > 0) {
            //有值
            //create order 生成用戶對應(yīng)的訂單
            echo 'order created for user ' . $uid . "\r\n";
            $redis->sadd('tvuser' , $uid); //搶購成功的用戶id
            //如果有值的話num會++
            $num++;
        } else {
            //無值
            //insert log
            echo 'no uid ' . "\r\n";
        }
        //如果num值大于等于5那么循環(huán)終止,循環(huán)次數(shù)是看秒殺多少件商品來變的,這里的話我就定義了5次
        if ($num >= 5) {
            break;
        }
    }
?>

我們在執(zhí)行守護進程之前可以先把redis里的數(shù)據(jù)清空一下，以免擾亂程序執(zhí)行結(jié)果，

命令如下：