PHP+Redis鏈表解決高并發(fā)下商品超賣問題(實(shí)現(xiàn)原理及步驟)

/**
 * 添加商品數(shù)量到商品隊列
 * @param int $couponId 優(yōu)惠券ID
 */
function addCoupons($couponId)
{
 //1.初始化Redis連接
 $redis = new Redis();
 if (!$redis->connect('127.0.0.1', 6379)) {
 trigger_error('Redis連接出錯！??！', E_USER_ERROR);
 } else {
 echo '連接正常br>';
 }

 //根據(jù)優(yōu)惠券ID從數(shù)據(jù)庫中查詢該優(yōu)惠券的庫存量
 //$sql = "select id, stock from coupon where id = {$couponId}";
 $stock = 10; //假設(shè)10就是我們從數(shù)據(jù)庫中查詢出的該優(yōu)惠券在數(shù)據(jù)庫中的庫存量

 //我們現(xiàn)在將這10個庫存放入到以該商品ID為key的redis鏈表中,有幾件庫存，就存入多少次1，鏈表長度代表商品庫存數(shù)
 for($i = 0; $i  $stock; $i++) {
 $redis->lPush("secKill:".$couponId.":stock", 1);
 }

 $redis->close();
}
$couponId = 11211;
addCoupons($couponId);

//設(shè)置鏈表有效期是兩分鐘
$redis->expire('key', 120);

/**
 * 搶優(yōu)惠券(秒殺)
 * @param int $couponId 商品ID
 * @param int $uid 用戶ID
 * @return bool
 */
function secKill($couponId, $uid)
{
 //1.初始化Redis連接
 $redis = new Redis();
 if (!$redis->connect('127.0.0.1', 6379)) {
 trigger_error('Redis連接出錯?。?！', E_USER_ERROR);
 } else {
 echo '連接正常br>';
 }

 //將已經(jīng)成功搶購的用戶添加到該以該商品ID為key的集合(set)中
 //如果用戶已經(jīng)在集合中，說明用戶已經(jīng)成功秒殺過一次了，不允許再次參與秒殺
 if ($redis->sIsMember('secKill:'.$couponId.':uid', $uid)) {
 echo '秒殺失敗';
 return false;
 }

 //秒殺商品的庫存key
 $key = 'secKill:'.$couponId.':stock';

 //從以該優(yōu)惠券ID為key的鏈表中彈出一個值，如果有值，證明優(yōu)惠券還有庫存
 $isSockNotEmpty = $redis->lPop($key);

 //判斷庫存，如果庫存大于0，則減庫存，將該成功秒殺用戶加入哈希表，如果小于等于0，秒殺結(jié)束
 if ($isSockNotEmpty != 1) {
 echo '秒殺已結(jié)束';
 return false;
 }

 //搶券成功，將優(yōu)惠券ID和UID放入到隊列中，由一個單獨(dú)的進(jìn)程隊列來消費(fèi)隊列里的數(shù)據(jù)，向用戶推送搶到的優(yōu)惠券
 $redis->lPush('couponOrder', $couponId.'+'.$uid);

 //將成功搶券的用戶記錄到集合中，防止被已搶過的用戶再次秒殺
 $redis->sAdd('secKill:'.$couponId.':uid', $uid);
 $redis->close();
 return true;
}

$couponId = 11211;
$uid = mt_rand(1, 100);
secKill($couponId, $uid);

//此處代碼省略
//根據(jù)自己的業(yè)務(wù)場景看看是入數(shù)據(jù)庫還是放入rabbitMQ消息隊列中消費(fèi)

ab -n 2000 -c 100 www.test.com/