delete empty ext result uid 有效 order his index

<?php header(‘content-type:text/html;charset=utf-8‘);
echo time();
class SeckillRedis { static protected $validity_time = 30; // 有效期 5分鐘
protected $goods_id;
protected $user_queue_key;
protected $goods_number_key;
protected $user_id;
public function __construct($goods_id,$area_id,$uid){
if($goods_id){
$this->goods_id=$goods_id;
//當前商品隊列的用戶情況
$this->user_queue_key="goods_".$goods_id."_user";
//當前商品的庫存隊列
$this->goods_number_key="goods_".$goods_id;
}
$this->user_id=$uid ? $uid : 2;
}

/* redis鏈接 */ static public function getRedis(){
$redis=new Redis();
$redis->connect(‘127.0.0.1‘,‘6379‘) or die(‘Can not Content Redis‘);
if($redis){
return $redis;
}else{
die(‘Can not Content Redis!‘);
}
} // 添加或改變庫存時初始化隊列
public function kuCun($num){
$redis=$this->getRedis();
$redis->delete($this->goods_number_key);
// $redis->delete($this->user_queue_key);
for ($i=0; $i < $num; $i++) { $redis->rPush($this->goods_number_key, 1); }
} // 判斷未支付訂單是否過期 ,定時更新秒殺商品入口人數 public function poling_set_seckill_redis(){
$redis=$this->getRedis();
//exists檢查key是否存在,存在返回1，不存在返回0,0也屬於不存在的
if($redis->exists($this->user_queue_key) == true){ // 清除過期的使用數量 $use_list = $redis->lRange($this->user_queue_key, 0, -1);
// var_dump($use_list);
foreach ($use_list as $k => $v) { $data = json_decode($v, true); if(time() - $data[‘time‘] > self::$validity_time){ // 超過有效期 刪除 $this->returnFree($k,$data[‘uid‘],$data[‘num‘]); } } } }

/* 獲取空閑搶購--num:購買件數 */ public function getFree($num){ if(empty($this->user_id)){ return array(‘result‘ => false, ‘message‘ => ‘搶購信息:用戶ID不能為空‘); } $redis = self::getRedis(); if($redis->llen($this->goods_number_key)>=$num){
for ($i=0; $i < $num; $i++) {
$result = $redis->lPop($this->goods_number_key);
}
// $result = $redis->lrem($this->goods_number_key,‘1‘,$num);
// var_dump($redis->lrange($seckill_array[$type][‘free_key‘],0,-1));
if($result == true){ // 添加使用數量 $index = $redis->rPush($this->user_queue_key, json_encode(array(‘uid‘ => $this->user_id, ‘time‘ => time(),‘num‘ => $num))) - 1; return array(‘result‘ => true, ‘index‘ => $index); }else{ return array(‘result‘ => false, ‘message‘ => ‘搶購信息:被搶光啦‘); }
}else{
return array(‘result‘ => false, ‘message‘ => ‘搶購信息:庫存不夠‘);
}
} /* 返回空閑搶購--$index為鍵值 */ public function returnFree($index,$uid,$num){ $redis = self::getRedis(); $value = $redis->lGet($this->user_queue_key,$index);
var_dump($value.‘hh‘);
if(!empty($value)){ $redis->lRem($this->user_queue_key, $value, 1); // 添加空閑數量
for ($i=0; $i < $num; $i++) {
$redis->rPush($this->goods_number_key, 1);
}
// $sql語句，庫存加1 return array(‘result‘ => true); }else{ return array(‘result‘ => false, ‘message‘ => ‘搶購信息:不存在索引‘); } } }
class Index{ /* 某個需要控制並發的控制器方法 */ public function getOrderInfo(){ $miaosha=new SeckillRedis(‘3‘,‘123‘,‘2‘);
// $miaosha->kuCun(‘100‘);
$miaosha->poling_set_seckill_redis();
$result = $miaosha->getFree(‘1‘);
return $result;
if($result[‘result‘] == false){ // 沒有機會 返回錯誤信息 return ‘網絡繁忙，請重試‘; } // 處理數據庫代碼
}
} $hua = new Index;
var_dump($hua->getOrderInfo()).‘<br>‘;
$redis=SeckillRedis::getRedis(); echo $redis->llen(‘goods_3‘);
var_dump($redis->lrange(‘goods_3‘,0,-1));
var_dump($redis->lrange(‘goods_3_user‘,0,-1));

php商城秒殺，可以購買多件商品，redis防高並發