Home > Backend Development > PHP Tutorial > PHP进程同步代码实例_PHP

PHP进程同步代码实例_PHP

WBOY
Release: 2016-05-31 13:17:01
Original
1215 people have browsed it

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

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

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

代码如下:


/*
 * 同一个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;
  }
 }

}

Demo:

代码如下:


$sync = new SyncProcess(APP_PATH . '/data/pid'.implode('', $this->getRoute()));
if ($sync->check()) {
 exit("process is running\n");
}

Related labels:
php
source:php.cn
Statement of this Website
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
Popular Tutorials
More>
Latest Downloads
More>
Web Effects
Website Source Code
Website Materials
Front End Template