当前位置：Gxlcms > PHP教程 > PHP守护进程类

PHP守护进程类

时间：2021-07-01 10:21:17 帮助过：23人阅读

用 PHP 实现的 Daemon 类。可以在服务器上实现队列或者脱离 crontab 的计划任务。
使用的时候，继承于这个类，并重写 _doTask 方法，通过 main 初始化执行。
  2. class Daemon {
  4. const DLOG_TO_CONSOLE = 1;
  5. const DLOG_NOTICE = 2;
  6. const DLOG_WARNING = 4;
  7. const DLOG_ERROR = 8;
  8. const DLOG_CRITICAL = 16;
  10. const DAPC_PATH = '/tmp/daemon_apc_keys';
  12. /**
  13. * User ID
  14. *
  15. * @var int
  16. */
  17. public $userID = 65534; // nobody
  19. /**
  20. * Group ID
  21. *
  22. * @var integer
  23. */
  24. public $groupID = 65533; // nobody
  26. /**
  27. * Terminate daemon when set identity failure ?
  28. *
  29. * @var bool
  30. * @since 1.0.3
  31. */
  32. public $requireSetIdentity = false;
  34. /**
  35. * Path to PID file
  36. *
  37. * @var string
  38. * @since 1.0.1
  39. */
  40. public $pidFileLocation = '/tmp/daemon.pid';
  42. /**
  43. * processLocation
  44. * 进程信息记录目录
  45. *
  46. * @var string
  47. */
  48. public $processLocation = '';
  50. /**
  51. * processHeartLocation
  52. * 进程心跳包文件
  53. *
  54. * @var string
  55. */
  56. public $processHeartLocation = '';
  58. /**
  59. * Home path
  60. *
  61. * @var string
  62. * @since 1.0
  63. */
  64. public $homePath = '/';
  66. /**
  67. * Current process ID
  68. *
  69. * @var int
  70. * @since 1.0
  71. */
  72. protected $_pid = 0;
  74. /**
  75. * Is this process a children
  76. *
  77. * @var boolean
  78. * @since 1.0
  79. */
  80. protected $_isChildren = false;
  82. /**
  83. * Is daemon running
  84. *
  85. * @var boolean
  86. * @since 1.0
  87. */
  88. protected $_isRunning = false;
  90. /**
  91. * Constructor
  92. *
  93. * @return void
  94. */
  95. public function __construct() {
  97. error_reporting(0);
  98. set_time_limit(0);
  99. ob_implicit_flush();
  101. register_shutdown_function(array(&$this, 'releaseDaemon'));
  102. }
  104. /**
  105. * 启动进程
  106. *
  107. * @return bool
  108. */
  109. public function main() {
  111. $this->_logMessage('Starting daemon');
  113. if (!$this->_daemonize()) {
  114. $this->_logMessage('Could not start daemon', self::DLOG_ERROR);
  116. return false;
  117. }
  119. $this->_logMessage('Running...');
  121. $this->_isRunning = true;
  123. while ($this->_isRunning) {
  124. $this->_doTask();
  125. }
  127. return true;
  128. }
  130. /**
  131. * 停止进程
  132. *
  133. * @return void
  134. */
  135. public function stop() {
  137. $this->_logMessage('Stoping daemon');
  139. $this->_isRunning = false;
  140. }
  142. /**
  143. * Do task
  144. *
  145. * @return void
  146. */
  147. protected function _doTask() {
  148. // override this method
  149. }
  151. /**
  152. * _logMessage
  153. * 记录日志
  154. *
  155. * @param string 消息
  156. * @param integer 级别
  157. * @return void
  158. */
  159. protected function _logMessage($msg, $level = self::DLOG_NOTICE) {
  160. // override this method
  161. }
  163. /**
  164. * Daemonize
  165. *
  166. * Several rules or characteristics that most daemons possess:
  167. * 1) Check is daemon already running
  168. * 2) Fork child process
  169. * 3) Sets identity
  170. * 4) Make current process a session laeder
  171. * 5) Write process ID to file
  172. * 6) Change home path
  173. * 7) umask(0)
  174. *
  175. * @access private
  176. * @since 1.0
  177. * @return void
  178. */
  179. private function _daemonize() {
  181. ob_end_flush();
  183. if ($this->_isDaemonRunning()) {
  184. // Deamon is already running. Exiting
  185. return false;
  186. }
  188. if (!$this->_fork()) {
  189. // Coudn't fork. Exiting.
  190. return false;
  191. }
  193. if (!$this->_setIdentity() && $this->requireSetIdentity) {
  194. // Required identity set failed. Exiting
  195. return false;
  196. }
  198. if (!posix_setsid()) {
  199. $this->_logMessage('Could not make the current process a session leader', self::DLOG_ERROR);
  201. return false;
  202. }
  204. if (!$fp = fopen($this->pidFileLocation, 'w')) {
  205. $this->_logMessage('Could not write to PID file', self::DLOG_ERROR);
  206. return false;
  207. } else {
  208. fputs($fp, $this->_pid);
  209. fclose($fp);
  210. }
  212. // 写入监控日志
  213. $this->writeProcess();
  215. chdir($this->homePath);
  216. umask(0);
  218. declare(ticks = 1);
  220. pcntl_signal(SIGCHLD, array(&$this, 'sigHandler'));
  221. pcntl_signal(SIGTERM, array(&$this, 'sigHandler'));
  222. pcntl_signal(SIGUSR1, array(&$this, 'sigHandler'));
  223. pcntl_signal(SIGUSR2, array(&$this, 'sigHandler'));
  225. return true;
  226. }
  228. /**
  229. * Cheks is daemon already running
  230. *
  231. * @return bool
  232. */
  233. private function _isDaemonRunning() {
  235. $oldPid = file_get_contents($this->pidFileLocation);
  237. if ($oldPid !== false && posix_kill(trim($oldPid),0))
  238. {
  239. $this->_logMessage('Daemon already running with PID: '.$oldPid, (self::DLOG_TO_CONSOLE | self::DLOG_ERROR));
  241. return true;
  242. }
  243. else
  244. {
  245. return false;
  246. }
  247. }
  249. /**
  250. * Forks process
  251. *
  252. * @return bool
  253. */
  254. private function _fork() {
  256. $this->_logMessage('Forking...');
  258. $pid = pcntl_fork();
  260. if ($pid == -1) {
  261. // 出错
  262. $this->_logMessage('Could not fork', self::DLOG_ERROR);
  264. return false;
  265. } elseif ($pid) {
  266. // 父进程
  267. $this->_logMessage('Killing parent');
  269. exit();
  270. } else {
  271. // fork的子进程
  272. $this->_isChildren = true;
  273. $this->_pid = posix_getpid();
  275. return true;
  276. }
  277. }
  279. /**
  280. * Sets identity of a daemon and returns result
  281. *
  282. * @return bool
  283. */
  284. private function _setIdentity() {
  286. if (!posix_setgid($this->groupID) || !posix_setuid($this->userID))
  287. {
  288. $this->_logMessage('Could not set identity', self::DLOG_WARNING);
  290. return false;
  291. }
  292. else
  293. {
  294. return true;
  295. }
  296. }
  298. /**
  299. * Signals handler
  300. *
  301. * @access public
  302. * @since 1.0
  303. * @return void
  304. */
  305. public function sigHandler($sigNo) {
  307. switch ($sigNo)
  308. {
  309. case SIGTERM: // Shutdown
  310. $this->_logMessage('Shutdown signal');
  311. exit();
  312. break;
  314. case SIGCHLD: // Halt
  315. $this->_logMessage('Halt signal');
  316. while (pcntl_waitpid(-1, $status, WNOHANG) > 0);
  317. break;
  318. case SIGUSR1: // User-defined
  319. $this->_logMessage('User-defined signal 1');
  320. $this->_sigHandlerUser1();
  321. break;
  322. case SIGUSR2: // User-defined
  323. $this->_logMessage('User-defined signal 2');
  324. $this->_sigHandlerUser2();
  325. break;
  326. }
  327. }
  329. /**
  330. * Signals handler: USR1
  331. * 主要用于定时清理每个进程里被缓存的域名dns解析记录
  332. *
  333. * @return void
  334. */
  335. protected function _sigHandlerUser1() {
  336. apc_clear_cache('user');
  337. }
  339. /**
  340. * Signals handler: USR2
  341. * 用于写入心跳包文件
  342. *
  343. * @return void
  344. */
  345. protected function _sigHandlerUser2() {
  347. $this->_initProcessLocation();
  349. file_put_contents($this->processHeartLocation, time());
  351. return true;
  352. }
  354. /**
  355. * Releases daemon pid file
  356. * This method is called on exit (destructor like)
  357. *
  358. * @return void
  359. */
  360. public function releaseDaemon() {
  362. if ($this->_isChildren && is_file($this->pidFileLocation)) {
  363. $this->_logMessage('Releasing daemon');
  365. unlink($this->pidFileLocation);
  366. }
  367. }
  369. /**
  370. * writeProcess
  371. * 将当前进程信息写入监控日志，另外的脚本会扫描监控日志的数据发送信号，如果没有响应则重启进程
  372. *
  373. * @return void
  374. */
  375. public function writeProcess() {
  377. // 初始化 proc
  378. $this->_initProcessLocation();
  380. $command = trim(implode(' ', $_SERVER['argv']));
  382. // 指定进程的目录
  383. $processDir = $this->processLocation . '/' . $this->_pid;
  384. $processCmdFile = $processDir . '/cmd';
  385. $processPwdFile = $processDir . '/pwd';
  387. // 所有进程所在的目录
  388. if (!is_dir($this->processLocation)) {
  389. mkdir($this->processLocation, 0777);
  390. chmod($processDir, 0777);
  391. }
  393. // 查询重复的进程记录
  394. $pDirObject = dir($this->processLocation);
  395. while ($pDirObject && (($pid = $pDirObject->read()) !== false)) {
  396. if ($pid == '.' || $pid == '..' || intval($pid) != $pid) {
  397. continue;
  398. }
  400. $pDir = $this->processLocation . '/' . $pid;
  401. $pCmdFile = $pDir . '/cmd';
  402. $pPwdFile = $pDir . '/pwd';
  403. $pHeartFile = $pDir . '/heart';
  405. // 根据cmd检查启动相同参数的进程
  406. if (is_file($pCmdFile) && trim(file_get_contents($pCmdFile)) == $command) {
  407. unlink($pCmdFile);
  408. unlink($pPwdFile);
  409. unlink($pHeartFile);
  411. // 删目录有缓存
  412. usleep(1000);
  414. rmdir($pDir);
  415. }
  416. }
  418. // 新进程目录
  419. if (!is_dir($processDir)) {
  420. mkdir($processDir, 0777);
  421. chmod($processDir, 0777);
  422. }
  424. // 写入命令参数
  425. file_put_contents($processCmdFile, $command);
  426. file_put_contents($processPwdFile, $_SERVER['PWD']);
  428. // 写文件有缓存
  429. usleep(1000);
  431. return true;
  432. }
  434. /**
  435. * _initProcessLocation
  436. * 初始化
  437. *
  438. * @return void
  439. */
  440. protected function _initProcessLocation() {
  442. $this->processLocation = ROOT_PATH . '/app/data/proc';
  443. $this->processHeartLocation = $this->processLocation . '/' . $this->_pid . '/heart';
  444. }
  445. }

人气教程排行

本站所有资源全部来源于网络，若本站发布的内容侵害到您的隐私或者利益，请联系我们删除！