PHP で記述された DAEMON を実行する PHP ファイルを実行する cronjob がありますが、DAEMON の他のインスタンスが実行されていない場合にのみ DAEMON を実行したいと考えています。 DAEMON が実行されています。配列に格納できるリストを生成するある種の exec について考えました。何か案は？ありがとう
質問する
12431 次
2 に答える
4
PHP プロセスのリストを取得するには、次の質問を参照してください。
PHP exec() を使用して実行中の php スクリプトのリストを取得するには?
もう 1 つのオプションは、ファイルのロックを取得し、実行前に確認することです。次に例を示します。
$thisfilepath = $_SERVER['SCRIPT_FILENAME'];
$thisfilepath = fopen($thisfilepath,'r');
if (!flock($thisfilepath,LOCK_EX | LOCK_NB))
{
customlogfunctionandemail("File is Locked");
exit();
}
elseif(flock($thisfilepath,LOCK_EX | LOCK_NB)) // Acquire Lock
{
// Write your code
// Unlock before finish
flock($thisfilepath,LOCK_UN); // Unlock the file and Exit
customlogfunctionandemail("Process completed. File is unlocked");
exit();
}
基本的に、上記の例では、最初にファイルがロックされているかどうかを確認し、ロックされていない場合 (プロセスが完了したことを意味します)、ロックを取得してコードを開始できます。
ありがとう
于 2013-06-27T07:05:04.807 に答える
0
これは、構成とロギングのためにmysql dbを含むphpスクリプトを使用してcronを制御するための私の完全なソリューションです。ソース コードで質問に対する回答を見つける必要があります。
Cron_Job クラス:
class Cron_Job
{
/**
* check if job is still running
* @param int $pid
* @return boolean
*/
public function isJobRunning($pid)
{
try
{
$result = shell_exec(sprintf("ps %d", $pid));
if (count(preg_split("/\n/", $result)) > 2)
{
return true;
}
} catch (Exception $e)
{
}
return false;
}
/**
* deletes job from run stack
* @param int $pid
*/
public function deleteRunningJob($pid)
{
$sql = "delete from croner_running_pids where pid = '$pid'";
$ret = framework_Database::getInstance("****")->delete($sql);
}
/**
* adds job into run stack
* @param int $pid
*/
public function addRunningJob($pid, $outputfile)
{
$sql = "insert into croner_running_pids (pid, `outfile`) values ('$pid', '$outputfile')";
$id = framework_Database::getInstance("****")->insert_db($sql);
}
}
クラス Cron_Log:
class Cron_Log
{
public static function setRunLog($jobid, $message)
{
$date = date("Y-m-d H:i:s");
$sql = "insert into croner_run_log (jobid, cas, message) values ('$jobid', '$date', '$message')";
framework_Database::getInstance("****")->insert($sql);
}
/**
* sets first run of job log
* @param int $jobid
* @param int $pid
*
* @return $id
*/
public static function setJobLogStart($jobid, $pid)
{
$start = date("Y-m-d H:i:s");
$sql = "insert into croner_log (job_id, start_run, pid) values ('$jobid', '$start', '$pid')";
$id = framework_Database::getInstance("****")->insert_db($sql);
return $id;
}
/**
* finalize log for specified run
* @param int $logid
*/
public static function setJobLogEnd($pid, $endRunTime, $message)
{
$endRunTime = date("Y-m-d H:i:s", $endRunTime);
$message = mysql_real_escape_string($message);
$sql = "update croner_log set end_run = '$endRunTime', output = '$message' where pid = '$pid' and end_run is null";
framework_Database::getInstance("****")->update($sql);
}
}
実行中のスクリプト:
$sql = "select id, runtime, execute_path from croner where runtime is not null and execute_path is not null";
//I am using database wrapper
$ret = framework_Database::getInstance("****")->select($sql);
$cj = new Cron_Job();
//echo date('d.m.Y.N.W H:i:s');
echo "<br>";
if(count($ret['id']) > 0)
{
foreach($ret['id'] as $key=>$id)
{
$runtime = $ret['runtime'][$key];
if(empty($runtime))
continue;
$cmd = $ret['execute_path'][$key];
$outputfile = "/var/www-intranet/croner/outputs/" . $id . "_" . time();
//echo $runtime;
//if pregmatch than get details
if(preg_match($runtime, date('d.m.Y.N.W H:i'), $matches))
{
Cron_Log::setRunLog($id, "Starting job $cmd");
$cmd = sprintf("%s > %s 2>&1 & echo $!", $cmd, $outputfile);
exec($cmd, $pid);
$pid = $pid[0];
//add log that job has started
$cj->addRunningJob($pid, $outputfile);
Cron_Log::setJobLogStart($id, $pid);
usleep(2000);
}
else {
continue;
}
}
}
sleep(1);
//check running pids
$sql = "SELECT * FROM croner_running_pids";
$ret = framework_Database::getInstance("****")->select($sql);
//print_r($ret);
if(isset($ret['pid']) && count($ret['pid']))
{
foreach($ret['pid'] as $key=>$pid)
{
if(is_numeric($pid) && !$cj->isJobRunning($pid) && file_exists($ret['outfile'][$key]))
{ //delete pid from run table
$cj->deleteRunningJob($pid);
$outfile = $ret['outfile'][$key];
$endRunTime = filemtime($outfile);
//echo $endRunTime;
$message = file_get_contents($outfile);
Cron_Log::setJobLogEnd($pid, $endRunTime, $message);
@unlink($outfile);
}
}
}
DB テーブル:
クロナー表:
Field Type Null Key Default Extra
id int(11) NO PRI NULL auto_increment
jobname varchar(250) NO NULL
descr text NO NULL
runtime varchar(150) NO NULL
execute_path text NO NULL
creator int(11) NO NULL
last_run_time timestamp NO CURRENT_TIMESTAMP on update CURRENT_TIMESTAMP
Croner_log テーブル:
Field Type Null Key Default Extra
id int(11) NO PRI NULL auto_increment
job_id int(11) NO NULL
start_run timestamp YES NULL
end_run timestamp YES NULL
pid int(11) NO NULL
output longtext NO NULL
croner_run_log テーブル:
Field Type Null Key Default Extra
id int(11) NO PRI NULL auto_increment
jobid int(11) NO NULL
cas timestamp NO CURRENT_TIMESTAMP on update CURRENT_TIMESTAMP
message varchar(255) NO NULL
croner_running_pids テーブル:
Field Type Null Key Default Extra
id int(11) NO PRI NULL auto_increment
pid int(11) NO NULL
pidfile varchar(250) NO NULL
outfile varchar(250) NO NULL
アイデアは、特定の形式 ( date('dmYNW H:i:s') )で preg_match のパターンを保存したデータベースに構成を設定することです。このスクリプトは、毎分実行するようにスケジュールされています。
次に、常にすべてのパターンを選択し、日付関数の結果と照合しています。
一致が見つかった場合は、そのジョブ用に保存されたコマンドを実行します - バックグラウンドに置き、その pid をデータベースに保存します - ジョブからのすべての出力が保存される別のテーブル。
最後に、実行中としてマークされているジョブをデータベースでチェックし、それらがまだプロセス リストにあるかどうかを調べています。
于 2013-06-27T08:40:24.027 に答える