php结合redis 秒杀商品的详解

这篇文章主要介绍了关于php结合redis 秒杀商品的详解,有着一定的参考价值,现在分享给大家,有需要的朋友可以参考一下

1 首先,一点点准备工作。

1.1建立商品表,订单表,并初始化数据

订单表。


1.2 将商品数据写入到redis 队列中去。

例如编号1 商品有100件。 就往 goods_1 队列里写100个1 进去。例用pop 操作的原子性(扛并发) 后面购买时,买一个就pop 一个。

//代码使用yii 框架,重点在思路,其它框架做少量调整即可。 
 $redis = self::createRedisObj(); //创建redis 对象,后面提供详细代码

        $sql = "select * from sec_goods";
        $rows = Yii::app()->db->createCommand($sql)->queryAll();

        foreach( $rows as $key => $row ):
            $goods_id = $row["id"];
            $stock_avail =  $row["stock_avail"];
            $redis_key = "goods_".$goods_id;
            for($i =0 ; $i< $stock_avail; $i++){
                $redis->lpush($redis_key , 1);
            }
            echo $goods_id."llen is ".$redis->lLen($redis_key)."<br/>";
        endforeach;

建好后如下图。(真实情况下,后台可能出现库调整,需要对应的去同步redis 中的数据,实际项目中请留意,此处暂且不表)

2 无redis时,常规的购买代码。

//用随机值模拟客户,商品,单次购买份数 
 $uid = rand(1,10);
        $amount = rand(1,5);
        $goods_id = rand(1,6);
        $time = time();
$this->buy($uid , $goods_id , $amount);

public function buy($uid , $goods_id , $amount){

     //使用行锁.
        try {
            $trans = Yii::app()->db->beginTransaction();

            $sql = "select stock_avail from sec_goods where id = $goods_id for update";  //
            $stock_avail = Yii::app()->db->createCommand($sql)->queryScalar();

            if( $stock_avail >= $amount ){  //份额足够。
                $sn = date("YmdHis")."-".$uid."-".$goods_id.rand(1000,9999);

                $sql = "insert into sec_order set sn = '$sn',user_id = $uid, goods_id = $goods_id, create_at = $time,num = $amount";
                $bool = Yii::app()->db->createCommand($sql)->execute();
                if( !$bool ){ throw new Exception("执行失败".$sql); }

                $sql = "update sec_goods set stock_avail = stock_avail - $amount  where id= $goods_id";
                $bool = Yii::app()->db->createCommand($sql)->execute();
                if( !$bool ){ throw new Exception("执行失败".$sql); }
            }
            $trans->commit();
            return true;
        } catch (Exception $e) {
            //日志记录
            $trans->rollback();
            return false;
        }
}

然后使用 apache 的 ab 小工具进行测试。
-n 代表请求次数 -c 代表单次并发多少个请求。

ab -n 1000 -c 100 http://xxx

(把上述代码中的事务去掉,再ab 跑时会出现爆单,超卖问题 详情点击)

由于使用了行锁 for update。 基于事务的隔离性,一定是顺序的执行,所以上述代码,也不会出现超卖爆单问题。(10件库存卖出11件),但这样的代码,有个性能问题,就是有多少次并发请求,就会往数据库请求多少次。脆弱的mysql 很快就崩掉了。

郑重声明:本文版权包含图片归原作者所有,转载文章仅为传播更多信息之目的,如作者信息标记有误,请第一时间联系我们(delete@yzlfxy.com)修改或删除,多谢。

郑重声明:本文版权归原作者所有,转载文章仅为传播更多信息之目的,如作者信息标记有误,请第一时间联系我们修改或删除,多谢。

留言与评论(共有 0 条评论)
昵称:
匿名发表
   
验证码: