PHPデーモンクラス-PHPチュートリアル-php.cn

PHPデーモンクラス

WBOY

リリース： 2016-07-25 09:06:45

オリジナル

820 人が閲覧しました

PHPで実装されたDaemonクラス。サーバー上の crontab からキューやスケジュールされたタスクを実装できます。
使用する場合は、このクラスを継承し、_doTaskメソッドをオーバーライドし、main経由で初期化して実行します。

クラスデーモン{
const DLOG_TO_CONSOLE = 1;
const DLOG_NOTICE = 2;
const DLOG_WARNING = 4;
const DLOG_ERROR = 8;
const DLOG_CRITICAL = 16;
const DAPC_PATH = ' /tmp/daemon_apc_keys';
/**
* ユーザーID
*
* @var int
*/
public $userID = 65534; // 誰も
/**
* グループID
*
* @var integer
*/
public $groupID = 65533; // 誰も
/**
* ID 設定失敗時にデーモンを終了します ?
*
* @var bool
* @since 1.0.3
*/
public $requireSetIdentity = false;
/**
* PID ファイルへのパス
*
* @var string
* @since 1.0.1
*/
public $pidFileLocation = '/tmp/daemon.pid';
/**
* processLocation
* プロセス情報記録ディレクトリ
*
* @var string
*/
public $processLocation = '';
/**
* processHeartLocation
* プロセスハートビートパケットファイル
*
* @var string
*/
public $processHeartLocation = '';
/**
* ホームパス
*
* @var string
* @since 1.0
*/
public $homePath = '/';
/**
* 現在のプロセス ID
*
* @var int
* @since 1.0
*/
protected $_pid = 0;
/**
* このプロセスは子供ですか
*
* @var boolean
* @since 1.0
*/
protected $_isChildren = false;
/**
* デーモンは実行されていますか
*
* @var boolean
* @since 1.0
*/
protected $_isRunning = false;
/**
* コンストラクター
*
* @return void
*/
public function __construct() {
error_reporting(0);
set_time_limit(0);
ob_implicit_flush();
register_shutdown_function(array(&$this, 'releaseDaemon')) ;
}
/**
* プロセス開始
*
* @return bool
*/
public function main() {
$this->_logMessage('デーモンの起動');
if (!$this->_daemonize()) {
$this->_logMessage('デーモンを起動できませんでした', self::DLOG_ERROR);
return false;
}
$this->_logMessage('実行中...');
$this- >_isRunning = true;
while ($this->_isRunning) {
$this->_doTask();
}
return true;
}
/**
* プロセスを停止します
*
* @return void
*/
public function stop() {
$this->_logMessage('デーモンの停止');
$this->_isRunning = false;
}
/**
* タスクを実行します
*
* @return void
*/
保護された関数 _doTask() {
// このメソッドをオーバーライドします
}
/**
* _logMessage
* ログを記録します
*
* @param 文字列メッセージ
* @param 整数レベル
* @return void
*/
protected function _logMessage($msg, $level = self::DLOG_NOTICE) {
// このメソッドをオーバーライドします
}
/**
* デーモン化
*
* ほとんどのデーモンが持ついくつかのルールまたは特性:
* 1) デーモンが既に実行されているかどうかを確認する
* 2) 子プロセスをフォークする
* 3) ID を設定する
* 4) 現在のプロセスをセッションレイヤーにする
* 5) プロセスIDをファイルに書き込む
* 6) ホームパスを変更する
* 7) umask(0)
*
* @access private
* @since 1.0
* @return void
*/
プライベート関数 _daemonize() {
ob_end_flush();
if ($this->_isDaemonRunning()) {
// デーモンはすでに実行されています。終了します
return false;
}
if (!$this->_fork()) {
// フォークできませんでした。 Exiting.
return false;
}
if (!$this->setIdentity() && $this->gt;requireSetIdentity) {
// 必要な ID セットが失敗しました。終了中
return false;
}
if (!posix_setsid()) {
$this->_logMessage('現在のプロセスをセッションリーダーにできませんでした', self::DLOG_ERROR);
return false;
}
if (!$fp = fopen($this->pidFileLocation, 'w')) {
$this->_logMessage('PID ファイルに書き込めませんでした', self::DLOG_ERROR);
return false;
} else {
fputs($fp, $this->_pid);
fclose($fp);
}
// 書入监控日志
$this->writeProcess();
chdir($this->homePath);
umask(0);
declare(ticks = 1);
pcntl_signal(SIGCHLD 、array(&$this, 'sigHandler'));
pcntl_signal(SIGTERM, array(&$this, 'sigHandler'));
pcntl_signal(SIGUSR1, array(&$this, 'sigHandler'));
pcntl_signal( SIGUSR2, array(&$this, 'sigHandler'));
return true;
}
/**
* Cheks はデーモンがすでに実行されています
*
* @return bool
*/
プライベート関数 _isDaemonRunning() {
$oldPid = file_get_contents($this-> pidFileLocation);
if ($oldPid !== false && posix_kill(trim($oldPid),0))
{
$this->_logMessage('デーモンはすでに PID で実行中です: '.$oldPid, (self: :DLOG_TO_CONSOLE self::DLOG_ERROR));
return true;
}
else
{
return false;
}
}
/**
* フォークプロセス
*
* @return bool
*/
プライベート関数 _fork() {
$this ->_logMessage('フォーク中...');
$pid = pcntl_fork();
if ($pid == -1) {
// 出错
$this->_logMessage('フォークできませんでした', self::DLOG_ERROR);
return false;
} elseif ($pid) {
// 父进程
$this->_logMessage('親殺し');
exit();
} else {
// フォーク的な子手続き
$this->_isChildren = true;
$this->_pid = posix_getpid();
return true;
}
}
/**
* デーモンの ID を設定し、結果を返します
*
* @return bool
*/
private function _setIdentity() {
if (!posix_setgid($this->groupID) || !posix_setuid($this->userID))
{
$this->_logMessage('ID を設定できませんでした', self::DLOG_WARNING);
return false;
}
else
{
return true;
}
}
/**
* シグナルハンドラー
*
* @access public
* @since 1.0
* @return void
*/
public function sigHandler($sigNo) {
switch ($sigNo)
{
case SIGTERM: // Shutdown
$this->_logMessage('Shutdown signal' );
exit();
Break;
case SIGCHLD: // Halt
$this->_logMessage('Halt signal');
while (pcntl_waitpid(-1, $status, WNOHANG) > 0);
Break;
case SIGUSR1: // ユーザー定義
$this->_logMessage('ユーザー定義シグナル 1');
$this->_sigHandlerUser1();
Break;
case SIGUSR2: // ユーザー-定義済み
$this->_logMessage('ユーザー定義シグナル 2');
$this->_sigHandlerUser2();
Break;
}
}
/**
* シグナルハンドラー: USR1
* 主に、各プロセスでキャッシュされたドメイン名の DNS 解決レコードを定期的にクリーンアップするために使用されます
*
* @return void
*/
protected function _sigHandlerUser1( ) {
apc_clear_cache('user');
}
/**
* シグナルハンドラー: USR2
* ハートビートパケットファイルの書き込みに使用されます
*
* @return void
*/
protected function _sigHandlerUser2() {
$this->_initProcessLocation();
file_put_contents($this->processHeartLocation 、 time());
return true;
}
/**
* デーモンの PID ファイルを解放します
* このメソッドは終了時に呼び出されます (デストラクターのような)
*
* @return void
*/
public function releaseDaemon() {
if ($this->_isChildren && is_file($this->pidFileLocation) ) {
$this->_logMessage('デーモンの解放');
unlink($this->pidFileLocation);
}
}
/**
* writeProcess
* 現在のプロセス情報を監視ログに書き込みます。別のスクリプトが監視ログのデータをスキャンし、応答がない場合はプロセスを再起動します
*
* @return void
*/
public function writeProcess() {
// proc を初期化します
$this->_initProcessLocation();
$command = trim(implode(' ', $_SERVER['argv ']));
// プロセスのディレクトリを指定します
$processDir = $this->processLocation . $this->_pid;
$processCmdFile = $processDir ;
$processPwdFile = $processDir . '/pwd';
// すべてのプロセスが配置されているディレクトリ
if (!is_dir($this->processLocation)) {
mkdir($this->processLocation, 0777);
chmod($ processDir, 0777);
}
// 重複したプロセスレコードをクエリします
$pDirObject = dir($this->processLocation);
while ($pDirObject && (($pid = $pDirObject->read ()) !== false)) {
if ($pid == '.' || $pid == '..' || intval($pid) != $pid) {
continue;
}
$pDir = $this->processLocation . $pid;
$pCmdFile = $pDir ;
$pPwdFile = '/pwd';
$pHeartFile . heart';
// cmd check に基づいて同じパラメータでプロセスを開始します if (is_file($pCmdFile) &&rim(file_get_contents($pCmdFile)) == $command) {
unlink($pCmdFile);
unlink ($pPwdFile);
unlink($pHeartFile);
// 削除されたディレクトリにはキャッシュがあります
usleep(1000);
rmdir($pDir);
}
}
// 新しいプロセスディレクトリ
if (!is_dir ($processDir)) {
mkdir($processDir, 0777);
chmod($processDir, 0777);
}
// コマンドパラメータを書き込みます
file_put_contents($processCmdFile, $command);
file_put_contents($processPwdFile, $ _SERVER['PWD' ]);
// 書き込みファイルはキャッシュされます
usleep(1000);
return true;
}
/**
* _initProcessLocation
* 初期化
*
* @return void
*/
protected function _initProcessLocation() {
$this ->processLocation = ROOT_PATH . '/app/data/proc';
$this->processHeartLocation = $this->processLocation '/heart';
}
}