redis并发操作（lpop/lpush实现）

【核心代码】

<?php

namespace app\web\controller;

use think\Controller;
use think\Model;
use think\Cookie;
use lib\Rsa;
use lib\Excel;

class Redisorder extends Common {
    
 public function newList() {
      return json(["success"=>false,"data"=>["name"=>input("name")]]);
    }
    public function rudui() {
        $store = 10;
        $redis = new \Redis();
        $redis->connect('127.0.0.1', 6379);
        $res = $redis->llen('goods_store');
        $count = $store - $res;
        for ($i = 0; $i < $count; $i  ) {
            $redis->lpush('goods_store', 1);
        }
        echo "ok";
    }

    public function xbuy() {
        for ($i = 0; $i < 15; $i  ) {
            echo $i . "<br>";
            $this->buy();
        }
        echo "ok";
    }

    public function buy() {
        //下单前判断redis队列库存量
        $redis = new \Redis();
        $redis->connect('127.0.0.1', 6379);
        $count = $redis->lpop('goods_store');
        if (!$count) {
            echo '已经抢光了哦';
        } else {
            echo '恭喜您!抢到了哦';
        }
    }

    public function memberRedis() {
        $uniqid = uniqid('uid-', TRUE);    // 模拟唯一用户ID
        $redis = new \Redis();
        $redis->connect('127.0.0.1', 6379);    // 连接 redis
        $redis->watch('rest_count');  // 监测 rest_count 是否被其它的进程更改
        $rest_count = intval($redis->get("rest_count"));  // 模拟唯一订单ID
        if ($rest_count > 0) {
            echo "抢到了" . PIPELINEHP_EOL;
            $value = "{$rest_count}-{$uniqid}";  // 表示当前订单，被当前用户抢到了
            // do something ... 主要是模拟用户抢到单后可能要进行的一些密集运算
            $rand = rand(100, 1000000);
            $sum = 0;
            for ($i = 0; $i < $rand; $i  ) {
                $sum  = $i;
            }
            // redis 事务
            $redis->multi();
            $redis->lPush('uniqids', $value);
            $redis->decr('rest_count');
            $replies = $redis->exec();  // 执行以上 redis 事务
            // 如果 rest_count 的值被其它的并发进程更改了，以上事务将回滚
            if (!$replies) {
                echo "订单 {$value} 回滚" . PIPELINEHP_EOL;
            }
        }
        $redis->unwatch();
    }

}