使用Redis實現秒殺功能

 <?php

 $id = 1;

 $pdo=new PDO("mysql:host=127.0.0.1;dbname=test","root","root");

 $pdo->exec("UPDATE `ms_goods` SET `nums`=`nums`-1 WHERE id=$id ");

 echo "miao sha success";

 //  队列   链表   list    :array

 //  array:先进后出

 //  list: 先进先出

 ?>

 <?php

 //  库存复数   ： 并发量足够大

 $r=new Redis();

 $r->connect("127.0.0.1",6379);

 $res=$r->rpop("mslist");    //right  右：出队    --->

 if(!$res){

    echo "out of print";

 }else{

     $id = 1;

     $pdo=new PDO("mysql:host=127.0.0.1;dbname=test","root","root");

     $pdo->exec("UPDATE `ms_goods` SET `nums`=`nums`-1 WHERE id=$id ");

     echo "miao sha success";

 }

 //  队列   链表   list    :array

 //  array:先进后出

 //  list: 先进先出

 ?>

 <?php

 $id = 1;  // 活动id

 $pdo=new PDO("mysql:host=127.0.0.1;dbname=test","root","root");

 $num = $pdo->query("SELECT * FROM `ms_goods` WHERE id = $id ")->fetch();

 $nums = $num['nums'];  //库存

 //  库存复数   ： 并发量足够大

 $r=new Redis();

 $r->connect("127.0.0.1",6379);

 for($i=1;$i<=$nums;$i++){

    $r->lpush("mslist","$i");  //left   左：入队   ---->

 }

 echo "[nums:{$nums}]  list: miaosha start ...";

 ?>

 <?php

 $id = 1;

 $pdo=new PDO("mysql:host=127.0.0.1;dbname=test","root","root");

 $res=$pdo->query("SELECT * FROM `ms_goods` where id = $id")->fetch(PDO::FETCH_ASSOC);

 ?>

 <!DOCTYPE html>

 <html lang="en">

 <head>

     <meta charset="UTF-8">

     <title>秒杀功能</title>

 </head>

 <body>

 <center>

     <h1>抢购活动，热卖，促销</h1>

     <div style="width:320px;height:160px;border:1px solid #ccc;">

    <img src="tel_5.jpg" />

    </div>

    <p>库存：<?php echo $res['nums']; ?></p>

    <button id="msbtn">秒杀</button>

 </center>

 </body>

 </html>

 <script type="text/javascript">

     document.getElementById('msbtn').onclick=function(){

         window.location.href = 'doms.php';

     }

 </script>

巴特西

使用Redis實現秒殺功能

最新文章

热门文章