PHP+Redis事務(wù)解決高并發(fā)下商品超賣問題(推薦)

/**
 * 搶優(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>';
 }

 //秒殺商品的庫存key
 $key = 'secKill:'.$couponId.':stock';
 $redis->watch($key);

 //獲取庫存
 $stock = $redis->get($key);

 //秒殺未開始，表示庫存為null
 if (!$stock  !is_numeric($stock)) {
 echo '秒殺未開始';
 return false;
 }

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

 //用戶已經(jīng)成功秒殺過一次了，不允許再次參與秒殺
 if ($redis->sIsMember('secKill:'.$couponId.':uid', $uid)) {
 echo '秒殺失敗';
 return false;
 }

 //代碼走到這里，說明該用戶是第一次參與秒殺，將庫存減一，然后把這個人放到已搶到的集合表
 //multi()，返回一個redis對象，并進(jìn)入multi-mode模式，一旦進(jìn)入multi-mode模式，以后調(diào)用的所有方法都會返回相同的對象，
 //直到exec(）方法被調(diào)用。
 $result = $redis->multi()->decr($key)->sAdd('secKill:'.$couponId.':uid', $uid)->exec();

 if (empty($result)) {//事務(wù)被取消
 echo '秒殺失敗';
 return false;
 }

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

 $redis->close();
 return true;
}

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

ab -n 1000 -c 50 www.test.com/