빠른 판매와 반짝 세일은 매우 흔한 장면입니다. 예를 들어 타오바오에서 반짝 세일을 달성하는 방법 등을 묻는 등 면접관들이 자주 질문합니다.
급매 및 반짝세일의 구현은 매우 간단하지만 해결해야 할 몇 가지 문제가 있으며 주로 두 가지 문제에 중점을 둡니다.
1 데이터베이스의 높은 동시성으로 인한 압력
2 경쟁 상태에서 올바른 재고 감소를 해결하는 방법("과잉 판매" 문제)
첫 번째 질문은 PHP의 경우 매우 간단합니다. Memcache, Redis 및 기타 캐싱 기술을 사용하여 데이터베이스 부담을 완화할 수 있습니다. 캐싱 기술.
두 번째 질문은 좀 더 복잡합니다.
관습:
해당 상품의 재고를 조회하여 0보다 큰지 확인한 후 주문 생성 등의 작업을 수행하지만 판단할 때는 인벤토리가 0보다 큰지 여부, 높은 동시성에서 문제가 발생하여 부정적인 인벤토리가 발생하는 경우
<?php
$conn=mysql_connect("localhost","big","123456");
if(!$conn){
echo "connect failed";
exit;
}
mysql_select_db("big",$conn);
mysql_query("set names utf8");
$price=10;
$user_id=1;
$goods_id=1;
$sku_id=11;
$number=1;
//生成唯一订单
function build_order_no(){
return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
}
//记录日志
function insertLog($event,$type=0){
global $conn;
$sql="insert into ih_log(event,type)
values('$event','$type')";
mysql_query($sql,$conn);
}
//模拟下单操作
//库存是否大于0
$sql="select number from ih_store where goods_id='$goods_id' and sku_id='$sku_id'";
//解锁 此时ih_store数据中goods_id='$goods_id' and sku_id='$sku_id' 的数据被锁住(注3)，其它事务必须等待此次事务 提交后才能执行
$rs=mysql_query($sql,$conn);
$row=mysql_fetch_assoc($rs);
if($row['number']>0){//高并发下会导致超卖
$order_sn=build_order_no();
//生成订单
$sql="insert into ih_order(order_sn,user_id,goods_id,sku_id,price)
values('$order_sn','$user_id','$goods_id','$sku_id','$price')";
$order_rs=mysql_query($sql,$conn);
//库存减少
$sql="update ih_store set number=number-{$number} where sku_id='$sku_id'";
$store_rs=mysql_query($sql,$conn);
if(mysql_affected_rows()){
insertLog('库存减少成功');
}else{
insertLog('库存减少失败');
}
}else{
insertLog('库存不够');
}로그인 후 복사
이런 경우 어떻게 해야 하나요? 몇 가지 최적화 방법을 살펴보겠습니다.
최적화 계획 1: 인벤토리 필드 번호 필드를 unsigned로 설정합니다. 인벤토리가 0이면 필드가 음수가 될 수 없으므로 false가 반환됩니다
1 //库存减少
2 $sql="update ih_store set number=number-{$number} where sku_id='$sku_id' and number>0";
3 $store_rs=mysql_query($sql,$conn);
4 if(mysql_affected_rows()){
5 insertLog('库存减少成功');6 }로그인 후 복사
최적화 계획 2: MySQL 트랜잭션을 사용하여 작업 행 잠그기
<?php
$conn=mysql_connect("localhost","big","123456");
if(!$conn){
echo "connect failed";
exit;
}
mysql_select_db("big",$conn);
mysql_query("set names utf8");
$price=10;
$user_id=1;
$goods_id=1;
$sku_id=11;
$number=1;
//生成唯一订单号
function build_order_no(){
return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
}
//记录日志
function insertLog($event,$type=0){
global $conn;
$sql="insert into ih_log(event,type)
values('$event','$type')";
mysql_query($sql,$conn);
}
//模拟下单操作
//库存是否大于0
mysql_query("BEGIN"); //开始事务
$sql="select number from ih_store where goods_id='$goods_id' and sku_id='$sku_id' FOR UPDATE";//此时这条记录被锁住,其它事务必须等待此次事务提交后才能执行
$rs=mysql_query($sql,$conn);
$row=mysql_fetch_assoc($rs);
if($row['number']>0){
//生成订单
$order_sn=build_order_no();
$sql="insert into ih_order(order_sn,user_id,goods_id,sku_id,price)
values('$order_sn','$user_id','$goods_id','$sku_id','$price')";
$order_rs=mysql_query($sql,$conn);
//库存减少
$sql="update ih_store set number=number-{$number} where sku_id='$sku_id'";
$store_rs=mysql_query($sql,$conn);
if(mysql_affected_rows()){
insertLog('库存减少成功');
mysql_query("COMMIT");//事务提交即解锁
}else{
insertLog('库存减少失败');
}
}else{
insertLog('库存不够');
mysql_query("ROLLBACK");
}로그인 후 복사
최적화 솔루션 3: 비차단 파일 독점 잠금 사용
<?php
$conn=mysql_connect("localhost","root","123456");
if(!$conn){
echo "connect failed";
exit;
}
mysql_select_db("big-bak",$conn);
mysql_query("set names utf8");
$price=10;
$user_id=1;
$goods_id=1;
$sku_id=11;
$number=1;
//生成唯一订单号
function build_order_no(){
return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
}
//记录日志
function insertLog($event,$type=0){
global $conn;
$sql="insert into ih_log(event,type)
values('$event','$type')";
mysql_query($sql,$conn);
}
$fp = fopen("lock.txt", "w+");
if(!flock($fp,LOCK_EX | LOCK_NB)){
echo "系统繁忙，请稍后再试";
return;
}
//下单
$sql="select number from ih_store where goods_id='$goods_id' and sku_id='$sku_id'";
$rs=mysql_query($sql,$conn);
$row=mysql_fetch_assoc($rs);
if($row['number']>0){//库存是否大于0
//模拟下单操作
$order_sn=build_order_no();
$sql="insert into ih_order(order_sn,user_id,goods_id,sku_id,price)
values('$order_sn','$user_id','$goods_id','$sku_id','$price')";
$order_rs=mysql_query($sql,$conn);
//库存减少
$sql="update ih_store set number=number-{$number} where sku_id='$sku_id'";
$store_rs=mysql_query($sql,$conn);
if(mysql_affected_rows()){
insertLog('库存减少成功');
flock($fp,LOCK_UN);//释放锁
}else{
insertLog('库存减少失败');
}
}else{
insertLog('库存不够');
}
fclose($fp);로그인 후 복사
최적화 솔루션 4: pop 작업은 원자적이므로 redis 대기열을 사용합니다. 많은 사용자가 동시에 도착하더라도 순차적으로 실행됩니다. (mysql 트랜잭션 성능은 동시성이 높을 때 크게 떨어집니다. 파일 잠금 방식)
제품 재고를 먼저 넣으세요. 예를 들어 대기열
<?php
$store=1000;
$redis=new Redis();
$result=$redis->connect('127.0.0.1',6379);
$res=$redis->llen('goods_store');
echo $res;
$count=$store-$res;
for($i=0;$i<$count;$i++){
$redis->lpush('goods_store',1);
}
echo $redis->llen('goods_store');로그인 후 복사
급히 구매, 설명 논리
<?php
$conn=mysql_connect("localhost","big","123456");
if(!$conn){
echo "connect failed";
exit;
}
mysql_select_db("big",$conn);
mysql_query("set names utf8");
$price=10;
$user_id=1;
$goods_id=1;
$sku_id=11;
$number=1;
//生成唯一订单号
function build_order_no(){
return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
}
//记录日志
function insertLog($event,$type=0){
global $conn;
$sql="insert into ih_log(event,type)
values('$event','$type')";
mysql_query($sql,$conn);
}
//模拟下单操作
//下单前判断redis队列库存量
$redis=new Redis();
$result=$redis->connect('127.0.0.1',6379);
$count=$redis->lpop('goods_store');
if(!$count){
insertLog('error:no store redis');
return;
}
//生成订单
$order_sn=build_order_no();
$sql="insert into ih_order(order_sn,user_id,goods_id,sku_id,price)
values('$order_sn','$user_id','$goods_id','$sku_id','$price')";
$order_rs=mysql_query($sql,$conn);
//库存减少
$sql="update ih_store set number=number-{$number} where sku_id='$sku_id'";
$store_rs=mysql_query($sql,$conn);
if(mysql_affected_rows()){
insertLog('库存减少成功');
}else{
insertLog('库存减少失败');
}로그인 후 복사
위는 높은 동시성에서 급하게 구매하는 간단한 시뮬레이션일 뿐입니다. 이보다 더 복잡하고 주의할 점이 많습니다
예를 들어 급구매 페이지를 정적으로 만든 경우 ajax를 통해 인터페이스를 호출하면
위에서는 한 명의 사용자가 여러 항목을 가져오게 됩니다.
대기열, 구매 결과 대기열, 재고 대기열이 필요합니다. 동시성이 높은 경우 먼저 대기열에 사용자를 입력하고 스레드 루프를 사용하여 대기열에서 사용자를 제거한 다음 해당 사용자가 이미 급매 결과 대기열에 있는지 확인합니다. 그렇지 않으면 인벤토리가 1만큼 줄어들고 사용자를 결과 대기열에 넣습니다.
저는 쇼핑몰 프로젝트를 진행하면서 플래쉬세일을 위해 직접 redis를 사용했습니다. 그동안 위의 방법들은 다르지만 모두 같은 목적을 달성하기 위해 살펴보았습니다. 행복해요.
위 내용은 PHP와 Redis를 이용한 높은 동시성에서의 급매수, 플래시세일 기능의 예시를 자세히 설명의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
