PHP进程同步代码实例

/* * 同一个PHP进程只运行一次，根据进程名字判断是否为排重进程，只能运行于linux，高并发条件下是并发安全的。 */

class SyncProcess {

private $pidFile;

function __construct($pidFile) { $this->pidFile = $pidFile; }

/** * 非阻塞方式返回进程是否正在运行 */ function check() { if (PHP_OS == 'Linux') { $pidFile = $this->pidFile; if (!empty($pidFile)) { $flag = false; $pidDir = dirname($pidFile); if (is_dir($pidDir)) { $flag = true; } if ($flag) { $running = true; clearstatcache(true,$this->pidFile); if (!file_exists($this->pidFile)) file_put_contents($this->pidFile,'',LOCK_EX); $f = fopen($this->pidFile,'r+'); if (flock($f,LOCK_EX ^ LOCK_NB)) { $pid = trim(fgets($f)); if (!$this->is_process_running($pid)) { $running = false; } } if (!$running) { fseek($f,0); ftruncate($f,0); fwrite($f,getmypid()); } flock($f,LOCK_UN); fclose($f); return $running; } else { debug_print("pid file($pidFile) is invalid",E_USER_WARNING); } } else { debug_print("pid file cant't be empty",E_USER_WARNING); } } else { debug_print(__CLASS__ . ' can only run in Linux',E_USER_WARNING); return true; } }

/** * 如果正在运行或者发生未知错误返回true，如果没有运行返回false * @param mixed $pid */ private function is_process_running($pid) { if (is_numeric($pid) && $pid > 0) { $output = array(); $line = exec("ps -o pid --no-headers -p $pid",$output); //返回值有空格 $line = trim($line); if ($line == $pid) { return true; } else { if (empty($output)) { return false; } else { if (php_sapi_name() == 'cli') $n = "n"; else $n = "
"; //到这一步的话应该是出什么问题了 $output = implode($n,$output); debug_print($output,E_USER_WARNING); return true; } } }else { return false; } }

}