PHPモールにフラッシュセール機能を実装する方法-PHPの問題-php.cn

PHPモールにフラッシュセール機能を実装する方法

藏色散人

リリース： 2023-03-17 06:14:02

オリジナル

1875 人が閲覧しました

phpモールのフラッシュセール機能の実装方法: 1. phpファイルを開き、redisデータベースに接続します; 2. スナップアップする商品のリストを作成します; 3. ユーザーリクエストをシミュレートし、設定しますスナップアップが成功したことを示す 10 人のユーザーをランダムに取得する; 4. ユーザーがスナップアップリストに既に存在するかどうかを確認し、リスト内のすべてのデータを取得する; 5. Redis 内のスナップアップユーザーをデータベースに保存する。

PHPモールにフラッシュセール機能を実装する方法

このチュートリアルの動作環境: Windows7 システム、PHP8.1 バージョン、DELL G3 コンピューター

php redis はフラッシュを実装します。 mysql での瞬間的な同時実行のプレッシャーを軽減できる sale 関数

# シナリオ: ある時点ある時点で、商品の Goods_ID = 2 個の急ぎ購入商品、商品在庫は 10

## 製品 Goods_id =2 在庫スナップアップリストを作成します

# #まずスナップアップする項目のリストを作成します。誰かがスナップアップに成功すると、リストが空になるまで、つまりスナップアップが完了するまで 1 つが削除されます。

//1、连接redis数据库
$redis = new Redis();
$redis->connect(&#39;127.0.0.1&#39;, 6379);
$redis_name = &#39;goods_id_2&#39;;//比如商品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(&#39;127.0.0.1&#39;, 6379);
$redis_name = &#39;goods_id_2&#39;;//比如商品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 &#39;执行完成&#39;;

ログイン後にコピー

#サーバーはキュー処理を実行し、redis にスナップアップしたユーザーをデータベース

<?php
$mysql_server_name = &#39;localhost&#39;; //改成自己的mysql数据库服务器
$mysql_username = &#39;root&#39;; //改成自己的mysql数据库用户名
$mysql_password = &#39;123456&#39;; //改成自己的mysql数据库密码
$mysql_database = &#39;test&#39;; //改成自己的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(&#39;127.0.0.1&#39;, 6379);
$redis_name = &#39;goods_id_2&#39;;//比如商品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 "执行成功";

ログイン後にコピー