php+redis+TP处理并发

前两天想自己研究PHP的并发问题，看到很多人都说用redis的队列处理并发很好，所以自己也去研究了一下，下面用实际项目记录一下自己的成果。

基本思路是所有操作用过redis的队列和集合处理并发

 

1.用户抢购队列（List），user_list

2.商品队列（List），goods_list

3.订单信息（Hash集合）,order_info

4.购买成功用户（Set集合）,bought_list

PS：1和2用来控制并发，队列的rPop是具有原子性的，即使处理并发，也是一个个处理，不会出现重复和超卖的情况。

3则是用来暂时存放订单信息，之后再入库。

4是为了防止用户重复购买做的（Set的特性是不能重复）。

 

并发模拟则是在Linux的webbench做的。

经过试验发现，并发1000条的抢购，直接操作数据库要12秒，使用redis只要6秒，速度快了整整一倍！

 

下面贴源码

商品入货1000个：

public function ruhuo(){
        $redis = new \redis();
        $redis->connect(\'127.0.0.1\', 6379);
        for($i = 1;$i<=1000;$i++)
            $redis->lpush(\'goods_list\',$i);
        echo \'进货成功\';
    }

秒杀接口：

public function redis_qianghuo(){
        $redis = new \redis();
        $redis->connect(\'127.0.0.1\', 6379);
        //查询库存
        if($redis->lLen(\'goods_list\') == 0)
            $this->ajaxReturn(\'商品已售完...\');
        $uid = $_SERVER[\'REMOTE_PORT\'];
        //查询是否购买过
        if($redis->sIsMember(\'bought_list\',$uid))
            $this->ajaxReturn(\'你已经购买过了!\');
        $goods_id = $redis->rpop(\'goods_list\');
        $redis->sAdd(\'bought_list\',$uid);
        $value = array(
            \'uid\'   =>  $uid,
            \'goods_id\'   =>  $goods_id,
            \'time\'  =>  time(),
        );
        $redis->hSet(\'order_info\',$uid,json_encode($value));
        $this->ajaxReturn(\'购买成功。\');
    }

就是这么简单，不仅高效，而且不会出现超卖情况，很实用的并发处理。

---------------------
作者：Me佳佳丶
来源：CSDN
原文：https://blog.csdn.net/q6627666/article/details/78364599
版权声明：本文为博主原创文章，转载请附上博文链接！