PHP を使用して Cron ジョブを管理する

crontab または cron テーブルは、繰り返しのタスクをスケジュールするのに役立つ Linux システム プロセス/デーモンであり、それによって日常の作業が簡素化されます。このチュートリアルでは、安全な接続を使用して crontab を操作できるようにする動的 PHP クラスを作成します。

背景: Crontab の概要 タスクをバックグラウンドで実行するようにスケジュールできるのは素晴らしいことです。 SQL データベースのバックアップ、電子メールの送受信、クリーンアップ タスクの実行、パフォーマンスの分析、さらには RSS フィードの収集など、cron ジョブは素晴らしいものです。

新しい割り当てをスケジュールするための構文は、最初は難しそうに思えるかもしれませんが、一度分解して理解すると比較的簡単です。 cron ジョブには常に 5 つの列があり、各列は時系列の演算子を表し、その後に完全パスと実行するコマンドが続きます。 リーリー

各時間列は、タスク スケジュールと特定の関連性を持っています。それらは次のとおりです:

Minutes は、特定の時間の分数をそれぞれ 0 ～ 59 の範囲で表します。 Hours 指定された日付の時間数をそれぞれ 0 ～ 23 で表します。 Days は、特定の月の日数を 1 ～ 31 の範囲で表します。 Month は、特定の年の月をそれぞれ 1 ～ 12 で表します。 曜日 は日曜日から土曜日までの曜日を示し、数字はそれぞれ0から6です。 リーリー たとえば、毎月 1 日の午前 12 時にタスクをスケジュールしたい場合は、次のようになります: リーリー

一方、毎週土曜日の午前 8 時 30 分にタスクを実行するようにスケジュールしたい場合は、次のように記述します。 リーリー スケジュールをさらにカスタマイズするために利用できるオペレーターも多数あります:

カンマは、任意の cron 列の値のカンマ区切りリストを作成するために使用されます。 ダッシュは値の範囲を指定するために使用されます。 アスタリスクは、 all または each 値を指定するために使用されます。 デフォルトでは、crontab はスケジュールされたタスクが実行されるたびに電子メール通知を送信します。しかし、多くの場合、これは必要ありません。このコマンドの標準出力を blackhole または /dev/null デバイスにリダイレクトすることで、この機能を簡単に抑制できます。基本的に、これは書き込まれた内容をすべて破棄するファイルです。出力のリダイレクトは、 > 演算子を介して実行されます。毎週土曜日の午前 8 時 30 分にスケジュールされたタスクを実行するサンプル cron ジョブを使用して、標準出力をブラック ホールにリダイレクトする方法を見てみましょう。 リーリー さらに、標準出力を null デバイスにリダイレクトする場合は、標準エラーもリダイレクトする必要がある場合があります。これは、標準出力がすでにリダイレクトされている場所 (空のデバイス) に標準エラーをリダイレクトするだけで実行できます。 リーリー

PHP を使用して crontab を管理する: ブループリント

PHP を使用して crontab を管理するには、編集中の crontab のユーザーとしてリモート サーバー上でコマンドを実行できる必要があります。 PHP が提供する SSH2 ライブラリを使用することもできますが、リモート サーバーとの通信にさまざまなプロトコルをサポートする phpseclib ライブラリを使用します。 phpseclib ライブラリをインストールして使用する方法

phpseclib ライブラリ (PHP セキュア通信ライブラリ) は、SSH、SFTP、SSL/TLS などの安全な通信プロトコル用のメソッドとクラスのセットを提供する PHP ライブラリです。これにより、外部のコマンド ライン ツールや拡張機能に依存せずに、安全な通信機能をアプリケーションに組み込むことができます。 PHP が提供するコア SSH2 機能の代わりに phpseclib を使用する理由を疑問に思っている場合は、phpseclib ライブラリの利点を見てみましょう。

SSH2 ライブラリは機能が限定されており、すべての SSH 機能をサポートしているとは限りません

異なるプロトコル間を簡単に切り替えることができる抽象化を提供します 基盤となるプロトコルの複雑さを抽象化する 使いやすく直感的 外部の依存関係や拡張機能は必要ありません SSH、SFTP、SCP、FTPS、SSL/TLS などの複数の安全な通信プロトコルをサポートします。 完全なドキュメント、積極的な開発、コミュニティサポート ご覧のとおり、phpseclib ライブラリは、安全な通信のニーズに対して、より包括的で強力なソリューションを提供できます。 インストール方法を見てみましょう。次のコード スニペットに示すように、Composer を使用して phpseclib ライブラリをインストールできます。 リーリー

インストールしたら、次のコード スニペットに示すように、PHP スクリプトの先頭にオートローダー スクリプトを含めることで、PHP コードで phpseclib ライブラリの使用を開始できます。 リーリー

リモート SSH2 ログインを行う方法を簡単に見てみましょう。 リーリー

これは phpseclib ライブラリの簡単な紹介です。

Ssh2_crontab_manager

クラス テンプレート このセクションでは、クラスにどのメソッドを実装する必要があるかについて説明します。 我们的类必须能够作为适当的用户进行连接和身份验证，以便执行命令并有权访问用户的 crontab。因此，我们将建立一个 SSH2 连接并在构造函数本身内对其进行身份验证。

建立经过身份验证的连接后，我们需要一种方法来处理我们将要运行的各种命令的执行。我们将使用 phpseclib 库提供的 exec() 方法。一般来说，当我们需要在远程服务器上执行命令时，我们会从类的其他方法中调用此方法。

接下来，我们需要能够将 crontab 写入文件，以便我们能够切实访问它。当我们完成这个文件时，我们还需要一种方法来删除它。我们将处理将 crontab 输出到文件的方法定义为 write_to_file() ，并将删除该文件的方法定义为 remove_file() 。

当然，我们还需要一种创建和删除 cron 作业的方法。因此，我们将分别定义 append_cronjob() 和 remove_cronjob() 方法。

如果我们删除了唯一的或最后一个 crontab 作业，我们应该可以选择删除整个 crontab，而不是尝试创建一个空的 crontab。为了处理这种情况，我们可以使用 remove_crontab() 方法。

最后，我们将为我们的类创建两个辅助方法。第一个方法将返回一个布尔值，将简单地检查临时 cron 文件是否存在。后者将用于在发生错误时显示错误消息。我们将这些方法分别命名为 crontab_file_exists() 和 error_message() 。

我们的准系统 PHP 类应该如下所示：

<?php use phpseclib3NetSSH2; Class Ssh2_crontab_manager { private $connection; private $path; private $handle; private $cron_file; public function __construct() {...} public function exec() {...} public function write_to_file() {...} public function remove_file() {...} public function append_cronjob() {...} public function remove_cronjob() {...} public function remove_crontab() {...} private function crontab_file_exists() {...} private function error_message() {...} } ?> 实现 Ssh2_crontab_manager 类 在本节中，我们将实现类的各种方法。

构造函数 类构造函数主要负责建立和验证 SSH2 连接。

让我们看一下 __construct 方法。

public function __construct($host = null, $port = null, $username = null, $password = null) { $path_length = strrpos(__FILE__, "/"); $this->path = substr(__FILE__, 0, $path_length) . '/'; $this->handle = 'crontab.txt'; $this->cron_file = "{$this->path}{$this->handle}"; try { if (is_null($host) || is_null($port) || is_null($username) || is_null($password)) { throw new Exception("Please specify the host, port, username, and password!"); } $this->connection = new SSH2($host, $port); if (!$this->connection->login($username, $password)) { throw new Exception("Could not authenticate '{$username}' using password: '{$password}'."); } } catch (Exception $e) { $this->error_message($e->getMessage()); } } 首先，它需要四个参数，每个参数都有一个默认值 NULL ：

$host ： 代表我们要连接的远程服务器的IP地址。 $port ： 用于 SSH2 连接的端口。 $username ： 代表服务器的用户登录名。 $password ： 代表服务器的用户密码。 首先，它计算当前文件的路径并将其设置为 $this->path 变量。它还设置要在 $this->handle 中使用的 cron 文件的名称，并在 $this->cron_file 中构造 cron 文件的完整路径。 p>

然后，我们检查是否缺少任何必需的参数，如果缺少，则会引发异常并附带相应的错误消息。

接下来，它通过传入 $host 和 $port 值来创建 SSH2 类的实例，以建立 SSH 连接。

最后，它尝试通过调用 SSH2 连接对象的 login() 方法，使用提供的 $username 和 $password 进行身份验证。如果身份验证成功，则建立连接。如果失败，则会抛出异常。

exec 方法 exec 方法负责在远程服务器上执行命令。它类似于手动将命令输入到 shell（例如 PuTTY）中。为了获得更大的灵活性，我们将公开此方法，以便用户可以实际执行他们可能需要运行的任何其他命令。

让我们看一下 exec 方法。

public function exec() { $argument_count = func_num_args(); try { if (!$argument_count) { throw new Exception("There is nothing to execute, no arguments specified."); } $arguments = func_get_args(); $command_string = ($argument_count > 1) ? implode(" && ", $arguments) : $arguments[0]; $stream = $this->connection->exec($command_string); if (!$stream) { throw new Exception("Unable to execute the specified commands: {$command_string}"); } } catch (Exception $e) { $this->error_message($e->getMessage()); } return $this; } 我们的 exec() 方法使用 phpseclib 库的 exec 方法来执行命令。

我们在此方法中要做的第一件事是定义一个变量，表示传递的参数总数。我们将使用 PHP 的 func_num_args() 函数来获取此计数。接下来，在 try 块中，我们将检查是否有任何参数传递给此方法。如果参数计数为 0，我们将抛出一个带有适当消息的新异常。

接下来，使用 func_get_args() 函数，我们将创建一个包含传递给此方法的所有参数的数组。然后，我们将使用三元运算符定义一个新变量 $command_string ，作为我们将执行的实际 Linux 命令的单行字符串表示形式。

如果我们确实要执行多个命令，我们将使用 PHP 的 implode() 函数将参数数组解析为字符串。我们将向 implode() 传递两个参数： 粘合 或分隔符，它基本上只是一个将插入到数组元素和数组本身之间的字符串。我们将使用 Linux 运算符 && 分隔每个元素，这允许我们在一行上顺序执行多个命令！

准备好命令并将其解析为字符串后，我们现在可以尝试使用 SSH2 类中的 exec() 方法通过已建立的 SSH 连接执行命令字符串。返回的值存储在 $stream 变量中。 write_to_file 方法 下一个方法， write_to_file() ，将负责将现有的 crontab 写入临时文件，或者在不存在 cron 作业的情况下创建一个空白临时文件。它需要两个参数：

我们将创建的临时文件的路径 我们在创建它时应该使用的名称 write_to_file 方法应如下所示。

public function write_to_file($path=NULL, $handle=NULL) { if (! $this->crontab_file_exists()) { $this->handle = (is_null($handle)) ? $this->handle : $handle; $this->path = (is_null($path)) ? $this->path : $path; $this->cron_file = "{$this->path}{$this->handle}"; $init_cron = "crontab -l > {$this->cron_file} && [ -f {$this->cron_file} ] || > {$this->cron_file}"; $this->exec($init_cron); } return $this; } 首先，我们使用布尔型 crontab_file_exists() 方法检查 cron 文件是否已存在，我们很快就会创建该方法。如果该文件存在，则无需继续。如果不是，我们将使用三元运算符来检查 $path 和 $handle 属性以确定它们是否为 NULL 代码>.如果它们中的任何一个为 NULL ，我们将使用构造函数中预定义的回退来定义它们。

然后，我们将这些属性连接在一起形成一个新属性，它表示临时 cron 文件的完整路径和文件名。

接下来，我们使用带有 -l 参数的 Linux 命令 crontab 将用户 crontab 显示为标准输出。然后，使用 Linux 的 > 运算符，我们将标准输出或 STDOUT 重定向到我们的临时 cron 文件，而不是连接 $this->cron_file 进入命令字符串！使用 > 运算符将输出重定向到文件将始终创建该文件（如果该文件不存在）。

这非常有效，但前提是 crontab 中已经安排了作业。如果没有 cron 作业，则永远不会创建此文件！不过，使用 && 运算符，我们可以向该字符串附加其他命令/表达式。因此，让我们附加一个条件表达式来检查 cron 文件是否存在。如果文件不存在，则该表达式的计算结果为 false。因此，如果需要，我们可以在此条件后使用 || 或 or 运算符来创建新的空白文件。

如果条件评估为 false，则将执行位于 or 之后的命令。现在，通过再次使用 > 运算符，这次无需在其前面添加特定命令，我们可以创建一个新的空白文件。所以本质上，这串命令会将 crontab 输出到一个文件，然后检查该文件是否存在，这将表明 crontab 中有条目，然后创建一个新的空白文件（如果不存在）。

最后，我们调用了 exec() 方法并将命令字符串作为唯一的参数传递给它。然后，为了使该方法也可链接，我们将返回 $this 。

remove_file 方法 让我们快速浏览一下 remove_file 方法。

public function remove_file() { if ($this->crontab_file_exists()) $this->exec("rm {$this->cron_file}"); return $this; } 在此方法中，我们使用辅助方法 crontab_file_exists() 来检查临时 cron 文件是否存在，然后执行 Linux 命令 rm 如果有则将其删除。像往常一样，我们还将返回 $this 以保持可链接性。

append_cronjob 方法 append_cronjob 方法通过向临时 cron 文件添加新作业/行，然后在该文件上执行 crontab 命令来创建新的 cron 作业，该命令将安装所有这些工作作为新的 crontab。

看起来像这样：

public function append_cronjob($cron_jobs=NULL) { if (is_null($cron_jobs)) $this->error_message("Nothing to append! Please specify a cron job or an array of cron jobs."); $append_cronfile = "echo '"; $append_cronfile .= (is_array($cron_jobs)) ? implode("n", $cron_jobs) : $cron_jobs; $append_cronfile .= "' >> {$this->cron_file}"; $install_cron = "crontab {$this->cron_file}"; $this->write_to_file()->exec($append_cronfile, $install_cron)->remove_file(); return $this; } append_cronjob() 方法采用一个参数 $cron_jobs ，该参数可以是一个字符串，也可以是表示要附加的 cron 作业的字符串数组。

我们将通过确定 $cron_jobs 参数是否为 NULL 来启动此方法。如果是，我们将调用 error_message() 方法来停止任何进一步的执行并向用户显示错误消息。

接下来，我们将一个新变量 $append_cronfile 定义为字符串，文本 echo 后跟一个空格，末尾有一个单引号。我们将立即用我们添加的各种 cron 作业以及结束引号填充此字符串。我们将使用字符串连接运算符 .= 构建此字符串。

接下来，使用三元运算符，我们确定 $cron_jobs 是否是数组。如果是，我们将使用换行符 n 对该数组进行内爆，以便每个 cron 作业都在 cron 文件中写入自己的行。如果 $cron_jobs 参数不是数组，我们只需将该作业连接到 $append_cron 字符串，而不进行任何特殊处理。

本质上，我们可以通过再次将标准输出重定向到文件中来将我们的任务回显到 cron 文件中。因此，通过使用字符串连接运算符，我们将在命令字符串中附加右单引号，以及 Linux 运算符 >> ，后跟 cron 文件的完整路径和文件名。 >> 运算符与始终覆盖文件的 > 运算符不同，它将输出附加到文件末尾。因此，通过使用此运算符，我们不会覆盖任何现有的 cron 作业。

接下来，我们将变量定义为字符串，并使用我们将用来安装即将创建的新 cron 文件的命令。这就像调用 crontab 命令一样简单，后跟 cron 文件的路径和文件名。

最后，在通过 exec() 方法执行这些命令之前，我们首先调用 write_to_file() 方法来创建临时 cron 文件。然后，在链中，我们将执行这些命令并调用remove_file()方法来删除临时文件。最后，我们将返回 $this ，以便 append_cronjob() 方法可链接。

remove_cronjob 方法 既然我们可以创建新的 cron 作业，那么我们也有能力删除它们，这是合乎逻辑的！这就是 remove_cronjob 方法的目的。

让我们来看看。

public function remove_cronjob($cron_jobs=NULL) { if (is_null($cron_jobs)) $this->error_message("Nothing to remove! Please specify a cron job or an array of cron jobs."); $this->write_to_file(); $cron_array = file($this->cron_file, FILE_IGNORE_NEW_LINES); if (empty($cron_array)) $this->error_message("Nothing to remove! The cronTab is already empty."); $original_count = count($cron_array); if (is_array($cron_jobs)) { foreach ($cron_jobs as $cron_regex) $cron_array = preg_grep($cron_regex, $cron_array, PREG_GREP_INVERT); } else { $cron_array = preg_grep($cron_jobs, $cron_array, PREG_GREP_INVERT); } return ($original_count === count($cron_array)) ? $this->remove_file() : $this->remove_crontab()->append_cronjob($cron_array); } 它需要一个参数，它是一个（简单的）正则表达式。它将用于在 crontab 中查找匹配的作业并相应地删除它们。

创建 cron 文件后，我们现在将使用 PHP 的 file() 函数将其读入数组。该函数将给定的文件解析为一个数组，每一行作为一个数组元素。我们将 cron 文件作为第一个参数传递给此函数，然后设置一个特殊标志 FILE_IGNORE_NEW_LINES，这将强制 file() 忽略所有新行。因此，我们有一个仅包含 cron 作业本身的数组。如果没有安排 cron 作业，该数组将为空。以后就没有继续下去的理由了。因此，我们检查了 $cron_array 是否为空，如果是则停止执行。

现在，我们确定 $cron_jobs 参数是否是一个数组。如果它是一个数组，我们使用 foreach 循环对其进行迭代。在该循环中，我们执行函数 preg_grep() 。这个漂亮的函数与 preg_match() 不同，将返回与指定的正则表达式匹配的所有数组元素的数组。然而，在这种情况下，我们想要不匹配的数组元素。换句话说，我们需要一个包含要保留的所有 cron 作业的数组，以便我们可以仅使用这些作业来初始化 crontab。因此，我们将在此处设置一个特殊标志 PREG_GREP_INVERT ，这将导致 preg_grep() 返回一个包含所有不匹配元素的数组。 正则表达式。因此，我们将拥有一个包含我们想要保留的所有 cron 作业的数组。

如果 $cron_jobs 参数不是数组，我们将以相同的方式继续，但不进行任何迭代。同样，我们将 $cron_array 重新定义为设置了 PREG_GREP_INVERT 标志的 preg_grep() 函数的结果数组。

通过我们的 $cron_array 设置，现在我们将该数组的当前长度与其原始长度进行比较，原始长度缓存在变量 $original_count 中。如果长度相同，我们将简单地返回 remove_file() 方法来删除临时 cron 文件。如果它们不匹配，我们将删除现有的 crontab，然后安装新的。

remove_crontab 方法 删除整个 crontab 相对容易实现，如以下代码片段所示。

public function remove_crontab() { $this->exec("crontab -r")->remove_file(); return $this; } 其他辅助方法 随着 cron 管理类的编写，我们现在来看看我们在整个类中使用的两个小但有用的方法， crontab_file_exists() 和 error_message () .

crontab_file_exists 方法 此方法返回 PHP 的 file_exists() 方法的结果， true 或 false ，具体取决于临时 cron 文件是否存在.

private function crontab_file_exists() { return file_exists($this->cron_file); } error_message 方法 此方法采用单个参数（一个字符串），表示我们要显示的错误消息。然后，我们将调用 PHP 的 die() 方法来停止执行并显示此消息。字符串本身将连接到

e03b848252eb9375d56be284e690e873 元素中，并应用简单的样式。

private function error_message($error) { die(" ERROR: {$error} "); } 完整的类如下所示：

path = substr(__FILE__, 0, $path_length) . '/'; $this->handle = 'crontab.txt'; $this->cron_file = "{$this->path}{$this->handle}"; try { if (is_null($host) || is_null($port) || is_null($username) || is_null($password)) { throw new Exception("Please specify the host, port, username, and password!"); } $this->connection = new SSH2($host, $port); if (!$this->connection->login($username, $password)) { throw new Exception("Could not authenticate '{$username}' using password: '{$password}'."); } } catch (Exception $e) { $this->error_message($e->getMessage()); } } public function exec() { $argument_count = func_num_args(); try { if (!$argument_count) { throw new Exception("There is nothing to execute, no arguments specified."); } $arguments = func_get_args(); $command_string = ($argument_count > 1) ? implode(" && ", $arguments) : $arguments[0]; $stream = $this->connection->exec($command_string); if (!$stream) { throw new Exception("Unable to execute the specified commands: {$command_string}"); } } catch (Exception $e) { $this->error_message($e->getMessage()); } return $this; } public function write_to_file($path=NULL, $handle=NULL) { if (! $this->crontab_file_exists()) { $this->handle = (is_null($handle)) ? $this->handle : $handle; $this->path = (is_null($path)) ? $this->path : $path; $this->cron_file = "{$this->path}{$this->handle}"; $init_cron = "crontab -l > {$this->cron_file} && [ -f {$this->cron_file} ] || > {$this->cron_file}"; $this->exec($init_cron); } return $this; } public function remove_file() { if ($this->crontab_file_exists()) $this->exec("rm {$this->cron_file}"); return $this; } public function append_cronjob($cron_jobs=NULL) { if (is_null($cron_jobs)) $this->error_message("Nothing to append! Please specify a cron job or an array of cron jobs."); $append_cronfile = "echo '"; $append_cronfile .= (is_array($cron_jobs)) ? implode("n", $cron_jobs) : $cron_jobs; $append_cronfile .= "' >> {$this->cron_file}"; $install_cron = "crontab {$this->cron_file}"; $this->write_to_file()->exec($append_cronfile, $install_cron)->remove_file(); return $this; } public function remove_cronjob($cron_jobs=NULL) { if (is_null($cron_jobs)) $this->error_message("Nothing to remove! Please specify a cron job or an array of cron jobs."); $this->write_to_file(); $cron_array = file($this->cron_file, FILE_IGNORE_NEW_LINES); if (empty($cron_array)) $this->error_message("Nothing to remove! The cronTab is already empty."); $original_count = count($cron_array); if (is_array($cron_jobs)) { foreach ($cron_jobs as $cron_regex) $cron_array = preg_grep($cron_regex, $cron_array, PREG_GREP_INVERT); } else { $cron_array = preg_grep($cron_jobs, $cron_array, PREG_GREP_INVERT); } return ($original_count === count($cron_array)) ? $this->remove_file() : $this->remove_crontab()->append_cronjob($cron_array); } public function remove_crontab() { $this->exec("crontab -r")->remove_file(); return $this; } private function crontab_file_exists() { return file_exists($this->cron_file); } private function error_message($error) { die(" ERROR: {$error} "); } } ?> 将它们放在一起 现在我们已经完成了 cron 管理类，让我们看一些如何使用它的示例。

实例化类并建立经过身份验证的连接 首先，让我们创建一个新的类实例。请记住，我们需要将 IP 地址、端口、用户名和密码传递给类构造函数。

附加单个 Cron 作业 建立经过身份验证的连接后，让我们看看如何创建一个新的单一 cron 作业。

append_cronjob('30 8 * * 6 home/path/to/command/the_command.sh >/dev/null 2>&1'); 附加 Cron 作业数组 附加多个 cron 作业与附加单个 cron 作业一样简单。我们只需将一个数组传递给 append_cronjob() 方法即可。

/dev/null 2>&1' ); $crontab->append_cronjob($new_cronjobs); 删除单个 Cron 作业 与创建单个 cron 作业的方式类似，我们现在将删除一个。不过，这一次，我们将使用正则表达式来查找适当的任务。该正则表达式可以根据您的需要简单或复杂。事实上，有多种方法可以通过正则表达式来执行您正在寻找的任务。例如，如果您需要删除的任务是唯一的，因为正在运行的命令未在 crontab 中的其他任何地方使用，则您可以简单地将命令名称指定为正则表达式。此外，如果您想删除某个月份的所有任务，您可以简单地编写一个正则表达式来查找给定月份的所有作业的匹配项。

remove_cronjob($cron_regex); 删除 Cron 作业数组 删除多个 cronjob 的处理方式与删除单个 cronjob 的方式相同，但有一个例外：我们将向 remove_cronjob() 方法传递一个 cron job 正则表达式数组。 p>

remove_cronjob($cron_regex); 结论 就这些了，伙计们！我希望您喜欢阅读这篇文章，就像我喜欢写这篇文章一样，并且您对 crontab 以及使用 PHP 管理它有了新的见解。非常感谢您的阅读。

PHP を使用して Cron ジョブを管理する

関連記事