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

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

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

Redis消息隊(duì)列實(shí)現(xiàn)秒殺

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

下面寫(xiě)個(gè)Demo簡(jiǎn)單實(shí)現(xiàn)一下秒殺，也就是搶購(gòu)。

首先創(chuàng)建一個(gè)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('請(qǐng)耐心等待.......');
				$.get('lpush.php',{"uid":uid},function (data){
					if(data == 1 ){
						$('#msg'+uid).html('搶購(gòu)成功!!');
					}else{
						$('#msg'+uid).html('搶購(gòu)失敗!!');
					}
				});
			}
        </script>
    </head>
    <body>
        <span id="msg5"></span><br>
        <input type="button" value="搶購(gòu)5" onclick="push(5)"><br>
        <span id="msg15"></span><br>
        <input type="button" value="搶購(gòu)15" onclick="push(15)"><br>
        <span id="msg25"></span><br>
        <input type="button" value="搶購(gòu)25" onclick="push(25)"><br>
        <span id="msg35"></span><br>
        <input type="button" value="搶購(gòu)35" onclick="push(35)"><br>
        <span id="msg45"></span><br>
        <input type="button" value="搶購(gòu)45" onclick="push(45)"><br>
        <span id="msg55"></span><br>
        <input type="button" value="搶購(gòu)55" onclick="push(55)"><br>
    </body>
</html>

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

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

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

在創(chuàng)建一個(gè)守護(hù)進(jìn)程的文件pop.php

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

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

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

命令如下：