PHP实现程序单例运行_PHP教程
程序员文章站
2022-04-01 21:58:48
...
PHP实现程序单例运行
一、场景描述:
最近我们一块业务,需要不断的监听一个目录的变化,如果目录中有文件,则启动PHP脚本处理掉。最初的方案是使用crontab执行sh脚本,脚本大概如下:
SOK=`ps -ef |grep /www/sender.sh | grep -v grep|wc -l` if [[ $SOK实际运行中出现了异常:ps -ef | grep xxx的方式,可能无法正确的判断进程是否正在执行,if条件永远都不会成立,使得PHP脚本永远不会执行。经过考虑后,决定建立一个独立于其他模块的,能够实现进程单例运行的类,解决这个问题。
二、方案设计
1、通过PID文件实现进程单例
2、程序启动、退出自动创建、删除PID文件,做到不需要业务代码考虑PID文件删除
3、尽量保证代码独立性,不影响业务代码
三、原理
1、启动创建PID文件
2、绑定程序退出、被杀死等信号量,用于删除PID文件
3、添加析构函数,对象被销毁时,删除PID文件
四、遇到的问题
程序正常退出时,无法捕获到信号量,不知道是不是信号量选错了,ctrl+c等信号是正常的,如果可以解决捕获程序正常退出时的信号量,则可以替代析构函数方案,更加稳定
五、代码
single(); * */ class DaemonSingle { //PID文件路径 private $pid_dir; //PID文件名称 private $filename; //PID文件完整路径名称 private $pid_file; /** * 构造函数 * @param $filename * @param string $pid_dir */ public function __construct($filename, $pid_dir='/tmp/'){ if(empty($filename)) throw new JetException('filename cannot be empty...'); $this->filename = $filename; $this->pid_dir = $pid_dir; $this->pid_file = $this->pid_dir . DIRECTORY_SEPARATOR . substr(basename($this->filename), 0, -4) . '.pid'; } /** * 单例模式启动接口 * @throws JetException */ public function single(){ $this->check_pcntl(); if(file_exists($this->pid_file)) { throw new Exception('the process is already running...'); } $this->create_pid_file(); } /** * @throws JetException */ private function create_pid_file() { if (!is_dir($this->pid_dir)) { mkdir($this->pid_dir); } $fp = fopen($this->pid_file, 'w'); if(!$fp){ throw new Exception('cannot create pid file...'); } fwrite($fp, posix_getpid()); fclose($fp); $this->pid_create = true; } /** * 环境检查 * @throws Exception */ public function check_pcntl() { // Make sure PHP has support for pcntl if (!function_exists('pcntl_signal')) { $message = 'PHP does not appear to be compiled with the PCNTL extension. This is neccesary for daemonization'; throw new Exception($message); } //信号处理 pcntl_signal(SIGTERM, array(&$this, signal_handler)); pcntl_signal(SIGINT, array(&$this, signal_handler)); pcntl_signal(SIGQUIT, array(&$this, signal_handler)); // Enable PHP 5.3 garbage collection if (function_exists('gc_enable')) { gc_enable(); $this->gc_enabled = gc_enabled(); } } /** * 信号处理函数,程序异常退出时,安全删除PID文件 * @param $signal */ public function signal_handler($signal) { switch ($signal) { case SIGINT : case SIGQUIT: case SIGTERM:{ self::safe_quit(); break; } } } /** * 安全退出,删除PID文件 */ public function safe_quit() { if (file_exists($this->pid_file)) { $pid = intval(posix_getpid()); $file_pid = intval(file_get_contents($this->pid_file)); if($pid == $file_pid){ unlink($this->pid_file); } } posix_kill(0, SIGKILL); exit(0); } /** * 析构函数,删除PID文件 */ public function __destruct(){ $this->safe_quit(); } }