PHP 쇼핑몰에서 플래시 세일 기능을 구현하는 방법-PHP 문제-php.cn

PHP 쇼핑몰에서 플래시 세일 기능을 구현하는 방법

藏色散人

풀어 주다： 2023-03-17 06:14:02

원래의

1853명이 탐색했습니다.

PHP 몰의 플래시 세일 기능을 구현하는 방법: 1. PHP 파일을 열고 redis 데이터베이스에 연결합니다. 2. 스냅할 제품 목록을 생성합니다. 3. 사용자 요청을 시뮬레이션하고 무작위로 10개를 얻도록 설정합니다. 4. 스냅업을 결정합니다. 사용자가 이미 목록에 있는지 확인하고 목록에 있는 모든 데이터를 가져옵니다. 5. 구매한 사용자를 데이터베이스에 저장합니다.

PHP 쇼핑몰에서 플래시 세일 기능을 구현하는 방법

이 튜토리얼의 운영 환경: Windows 7 시스템, PHP 버전 8.1, DELL G3 컴퓨터

php+redis는 플래시 종료 기능을 구현하여 mysql에서 즉각적인 동시성의 부담을 완화할 수 있습니다

시나리오: 특정 시점에 상품의 재고가 10

인 상품의 긴급 구매가 이루어졌습니다. 긴급 구매 목록 of products_id=2

먼저 스냅업할 상품 목록을 생성하세요. 누군가 스냅핑에 성공했다면, 목록이 비워질 때까지 삭제하세요. 구매가 완료되었습니다.

//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 "执行成功";

로그인 후 복사