get($key)); //有其它进程正在操作,不用重复 if (!empty($val)) { return; } $selfval = $worker_id + 1; $redis->SETEX($key, 55 , $selfval); $newvel = $redis->get($key); if ($selfval != intval($newvel)){ return; } $time = time(); $data = json_encode(['cmd'=>'test','act'=>'timeRsync','data'=>['t'=>$time,'s'=>date('Y-m-d H:i:s',$time)]]); $serv->task(Mypack::getInstance()->makeData($data)); return ; } }