前两天想自己研究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 edis(); $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 edis(); $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
版权声明:本文为博主原创文章,转载请附上博文链接!