/***redis控制并发**/function concurrence(){//实例化redis$redis = new \Redis();$redis->connect(C('REDIS_HOST'),C('REDIS_PORT'));$redis->auth(C('REDIS_AUTH'));//进入队列及出列，queue在加减的时候，要保证操作的唯一性，此时加锁，完成后在解锁$random = mt_rand();//生成随机数$start = $redis->set('clock', $random, array('nx', 'ex' => 10));//redis加锁，锁有效期10秒while (!$start) {usleep(100000);//沉睡100毫秒$start = $redis->set('clock', $random, array('nx', 'ex' => 10));//redis加锁，锁有效期10秒}$queue = $redis->get('queue');if ($queue <= 10){$redis->incr('queue');//自增if ($redis->get('clock') == $random) {//当clock值满足条件$redis->del('clock');//删除$random随机数}$process = '处理具体的业务逻辑中,耗时不定,当前时间戳：'.time();$endRandom = mt_rand();//随机数$end = $redis->set('clock', $endRandom, array('nx', 'ex' => 10));//redis加锁，锁有效期10秒while (!$end) {usleep(100000);//沉睡100毫秒$end = $redis->set('clock', $endRandom, array('nx', 'ex' => 10));//redis加锁，锁有效期10秒}$redis->decr('queue');//自减if ($redis->get('clock') == $endRandom) {//当clock值满足条件$redis->del('clock');//删除$endRandom随机数}return $process;}else{if ($redis->get('clock') == $random) {$redis->del('clock');}usleep(200000);//沉睡200毫秒concurrence();//递归再次调用}}