PHP进程同步代码实例

  经常遇到这样一种情况,计划任务定时后台执行某个php程序,有时候也需要手动执行,可能多个人都需要执行这个程序,如果任务持续时间非常长,就很容易造成重复执行,所以就开发了下面的类。

  作用:在实际代码运行前检查与当前相同操作的进程是否正在运行,高并发运行是可靠的,运行中的进程中途异常中断不会产生任何影响。

  构造方法传递pid文件目录的绝对路径,需要自己保证不同进程对应不同pid文件。

  

复制代码 代码如下:

  <?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 = "<br>";

  //到这一步的话应该是出什么问题了

  $output = implode($n, $output);

  debug_print($output, E_USER_WARNING);

  return true;

  }

  }

  }else {

  return false;

  }

  }

  }

  Demo:

  

复制代码 代码如下:

  $sync = new SyncProcess(APP_PATH . '/data/pid'.implode('', $this->getRoute()));

  if ($sync->check()) {

  exit("process is running\n");

  }