php商城秒殺功能怎麼實現

//1、連線redis資料庫
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$redis_name = 'goods_id_2';//比如商品id=2的商品參與秒殺
//2、模擬搶購，庫存為10，將庫存放到redis中
$num = 10;
for($i=0;$i<$num;$i++){
$redis->lPush($redis_name,1);//這裡用某個商品的ID作為標識
}
echo "執行成功";

//1、連線redis資料庫
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$redis_name = 'goods_id_2';//比如商品id=2的商品參與秒殺
//3、模擬使用者請求，隨機獲取10名使用者表示搶購成功
for($i=0;$i<100;$i++){
$user_id = rand(100,999);
$len = $redis->lLen($redis_name);
$str = "";
if(!$len || $len<=0){
$str .= $user_id."搶購已結束";
break;
}else{
$redis_user_name = "goods_id_2_user_id";
//判斷搶購列表中是否已存在該使用者，獲取列表中所有的資料
$skill_list = $redis->lrange($redis_user_name, 0, -1);
if(in_array($user_id, $skill_list)){
$str .= $user_id."請勿重複提交";
}else{
$redis->rPop($redis_name);
$redis->lPush($redis_user_name,$user_id."_".ceil(microtime(true)*1000));
$str .= $user_id."已搶到";
}
}
file_put_contents("D:/wwwroot/test/skill/cron.txt", $str."\r\n",FILE_APPEND);
}
echo '執行完成';

<?php
$mysql_server_name = 'localhost'; //改成自己的mysql資料庫伺服器
$mysql_username = 'root'; //改成自己的mysql資料庫使用者名稱
$mysql_password = '123456'; //改成自己的mysql資料庫密碼
$mysql_database = 'test'; //改成自己的mysql資料庫名
$conn=mysqli_connect($mysql_server_name,$mysql_username,$mysql_password,$mysql_database); //連線資料庫
//連線資料庫錯誤提示
if (mysqli_connect_errno($conn)) {
die("連線 MySQL 失敗: " . mysqli_connect_error());
}
mysqli_query($conn,"set names utf8"); //資料庫編碼格式
//1、連線redis資料庫
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$redis_name = 'goods_id_2';//比如商品id=2的商品參與秒殺
//2、將list佇列中的資料讀取出來然後執行入庫
$redis_user_name = "goods_id_2_user_id";
while(true){
//判斷搶購列表中是否已存在該使用者，獲取列表中所有的資料
$result = $redis->rpop($redis_user_name);
if($result){
$skill_arr = array_filter(explode("_", $result));
$sql = "insert into skill (user_id,timestamp) values({$skill_arr[0]},{$skill_arr[1]})";
mysqli_query($conn,$sql); 
}
}
echo "執行成功";