PHP redis秒杀场景队列使用

队列

1.将用户信息存到redis

<?php
    $redis = new Redis();
    $redis->connect('127.0.0.1',6379);
    $redisName = "miaosha";

    for($i = 0; $i < 100; $i++){
            //接收用户的uid
            $uid = rand(1,999999);
            //规定抢购的数量
            $num = 10;
            //如果少于10则加入这个队列
            if($redis->lLen($redisName) < 10){
                    $redis->rPush($redisName,$uid.'%'.microtime());
                    echo $uid."秒杀成功"."<br>";
            }else{
                    echo "秒杀已经结束"."<br>";
            }
    }
    $redis->close();
?>

2.停止秒杀活动操作队列将信息刷到mysql中

<?php
$dbms='mysql';     //数据库类型
$host='localhost'; //数据库主机名
$dbName='test';    //使用的数据库
$user='root';      //数据库连接用户名
$pass='123456';          //对应的密码
$dsn="$dbms:host=$host;dbname=$dbName";
$dbh = new PDO($dsn, $user, $pass);
$redis = new Redis();
$redis->connect('127.0.0.1',6379);
$redisName = "miaosha";

//死循环
while(1){
        //队列左侧取值
        $user = $redis->lPop($redisName);
        //判断值是否存在
        if(!$user || $user == 'nil'){
                sleep(2);
                continue;
        }
        //切割时间
        $userArr = explode('%',$user);
        $uid = $userArr[0];
        $time = date("Y-m-d H:i:s",time());
        $res = $dbh->query("INSERT INTO redis (id,uid,time) VALUES (NULL,$uid,'$time')");
        //如果失败  丢回队列
        if(!$res){
                $redis->rPush($redisName,$uid);
        }
        sleep(2);

}
//释放redis
$redis->close();
?>

redis事务

监视

<?php

    $redis = new redis();
    $redis->conect("127.0.0.1",6379);
    //redis监视  redis事务在执行之前，检测这个key ,检测版本是否一致，不一致不会执行
    $redis->watch("count");
    //库存
    $store = 3;
    //记录销售量
    $count = $redis->get("count");
    if($count >= $store){
        exit("活动结束");
    }
    $redis->multi();
    $redis->incr("count");//销量+1
    sleep(1);
    $res = $redis->exec();//检测版本标识
    //抢购成功
    if($res){
        include "db.php";
        sqli();
    }
?>

数据库（db.php）

<?php

$dbhost = '127.0.0.1';  // mysql服务器主机地址
$dbuser = 'root';            // mysql用户名
$dbpass = 'root';          // mysql用户名密码
function sqli(){
    $conn = mysqli_connect($dbhost, $dbuser, $dbpass);
    if(! $conn ){
        die('Could not connect: ' . mysqli_error());
    }
    // 设置编码，防止中文乱码
    mysqli_query($conn , "set names utf8");
    $sql = 'UPDATE shop SET store=store-1 WHERE runoob_id=1';
    mysqli_select_db( $conn, 'test' );
    $retval = mysqli_query( $conn, $sql );
    mysqli_close($conn);
}
?>

PHP redis秒杀场景队列使用

队列

redis事务

推荐阅读更多精彩内容