redis队列和秒杀应用方式

header("Content-type: text/html; charset=utf-8");
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

$redis_name= "miaosha";
//库存
$nums = 10;
//用户id
$user_id = $_GET['uid'];
if(($redis->llen($redis_name)) <  $nums ){
	$redis->lpush($redis_name,json_encode(array('uid'=>$user_id,'time'=>microtime())));
	echo $user_id."秒杀成功!";
	exit();
}else{
	echo "秒杀失败!";
	exit();
}
$redis->close();

header("Content-type: text/html; charset=utf-8");
error_reporting(E_ALL);
require_once './db.php';
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

$redis_name = "miaosha";

//数据库
$configs =array('host'=>'127.0.0.1','port'=>'3306','user'=>'***','passwd'=>'','dbname'=>'test');
$mysql = new MMysql($configs);

//处理开始
while ($count = $redis->lLen($redis_name)) {
    $task = $redis->rpop($redis_name);
	
    $taskdata = json_decode($task, true);
	$data = array(
    	'uid'=>$taskdata['uid'],
    	'time'=>$taskdata['time'],
    );

	$rs = $mysql->insert('redis',$data);
	if(!$rs){
		//由于我们是在右边取,所以如果数据插入失败了要从左边放回去（重新排队）,以免影响队列中其他元素的处理
		$redis->lpush($redis_name,$task);
		echo "处理失败<br>";
	}else{
		echo "处理成功<br>";
	}
    
	sleep(1);
}

$redis->close();

$redis = new Redis();
$redis->connect('127.0.0.1', 6379, 60);
 
 //
$tnums = $redis->get('goods_stock_nums');

//设置商品的库存
if($tnums==0){
	echo "活动已经结束,明天请早end!";
	exit();
}

//监视该key
$redis->watch('goods_stock_nums');

//sleep(5);
//开启事务
$redis->multi();
 
//修改库存数
$redis->decr('goods_stock_nums');
 
//提交事务，如果在此期间有其他请求修改了该key，那么事务会失败
if ($redis->exec()) {
    echo '抢购成功suc';
} else {
    echo '数据错误，请重新再试fail';
}

function getRedis()
{
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6379, 60);
    return $redis;
}
 
function lock($key, $random)
{
    $redis = getRedis();
    return $redis->set($key, $random, ['nx', 'ex' => 3]);
}
 
function unlock($key, $random)
{
    $redis = getRedis();
    //使用lua脚本保证原子性
    $script = 'if redis.call("get",KEYS[1]) == ARGV[1] then return redis.call("del",KEYS[1]) else return 0 end';
    return $redis->eval($script, [$key, $random], 1);
}
 
function decrGoodsStockNums()
{
    $redis = getRedis();
 
    //获取商品库存数
    $ret = $redis->get('goods_stock_nums');
 
    if ($ret === false) {
        return false;
    }
 
    if ($ret <= 0) {
        return false;
    }
 
    $random = mt_rand();
    //先获取锁
    if (lock('goods_stock_nums_lock', $random)) {
        //修改库存数
        $redis->decr('goods_stock_nums');
 
        //释放锁
        unlock('goods_stock_nums_lock', $random);
        return true;
    } else {
        usleep(100);
        decrGoodsStockNums();
    }
}
 
decrGoodsStockNums();