首页 > 代码库 > 基于Redis/Memcached的高并发秒杀设计

基于Redis/Memcached的高并发秒杀设计

 如何设计高并发时的秒杀,是面试电商技术职位时必考的题目。今天在这里分享一下基于Redis或Memcached的技术方案,能解决重复提交、超发、高并发的问题。

 <?php 

//预定义总库存
define("TOTAL_STOCK", 5);
//预定义商品编号
define("ITEM_ID", "ITEM_001");

$userId = $_GET[‘userId‘];
$userIdKey = ITEM_ID . ‘_‘ . $userId;

$redis = new redis();
//如果有多台Redis服务器,可根据商品编号哈希后得到其中一台redis的地址
$result = $redis->connect(‘master104‘, 6379);

//获取之前已经领取掉的数量
$requested = $redis->get("requested");
echo "领取前库存: " . (string)(TOTAL_STOCK - $requested) . "<br />";

//如果已领取大于预定义库存,则认为库存为零,不允许继续
if ($requested && ($requested >= TOTAL_STOCK))
{
  echo "已领完,请下次再来";
  die();
}

//通过设置用户对该商品的领取状态,来检查该用户是否已领取过
//如果使用Memcached的话,可以使用cas()
if (!$redis->setnx($userIdKey, 1))
{
  echo "您已领取过该商品,不允许重复领取";
  die();
}

//增加领取数量以减少库存。
//高并发情况下可能会有多个incr()是成功的。但是没关系,在领取数大于库存数后,通过下面的if判断后,后面的请求都是无效的。
$requested = $redis->incr("requested");

//如果尝试增加的时候,发现库存已经为零了,需要重置用户领取状态
if ($requested && ($requested > TOTAL_STOCK))
{
  $redis->del($userIdKey);
  echo "已领完,请下次再来";
  die();
}

//以下可以做其他的后续操作,比如各种异步并行操作,或是投递消息到队列,等等
//Step1
//...
//StepN

//如果步骤进行到这里,不管以上的异步操作进行得如何,我们都必须认为用户已经领取成功。
//即使有任何失败,我们都需要用技术手段帮用户完成上述Step1到StepN
echo "领取成功!<br />";
echo "领取后库存: " . (string)(TOTAL_STOCK - $requested) . "<br />";


?>

 

基于Redis/Memcached的高并发秒杀设计