前两天想自己研究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('购买成功。');
}
就是这么简单,不仅高效,而且不会出现超卖情况,很实用的并发处理。