PHP および MySQL でのキュー遅延タスクとスケジュールされたタスクのアプリケーション シナリオ

PHP および MySQL でのキュー遅延タスクとスケジュールされたタスクのアプリケーション シナリオ

はじめに:
インターネットの発展に伴い、リアルタイムかつ高い同時実行性を実現要求はますます高くなっており、これらの要求に対処するために、多くの場合、キューに入れられた遅延タスクやスケジュールされたタスクを使用する必要があります。この記事では、PHP および MySQL でキュー遅延タスクとスケジュールされたタスクを適用する方法に焦点を当て、具体的なコード例を示します。

1. キュー内の遅延タスクのアプリケーション シナリオ:
キュー内の遅延タスクとは、タスクをキューに入れ、遅延時間を設定し、一定時間後にタスクを実行することを指します。この方法は、SMS 確認コードの送信、電子メールの送信、レポートの生成など、遅延処理が必要なシナリオでよく使用されます。

PHP では、Redis をキュー サービスとして使用し、PHP の Redis 拡張ライブラリと組み合わせて、キューに遅延タスクを実装できます。

コード例:

// 连接Redis服务器
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// 将任务放入队列，设置延迟时间为60秒
$job = ['to' => 'example@example.com', 'subject' => 'Test Email', 'content' => 'Hello, World!'];
$delay = 60;
$redis->zAdd('delayed_queue', time() + $delay, json_encode($job));

// 从队列中取出延迟时间已到的任务，并执行
while (true) {
    $jobs = $redis->zRangeByScore('delayed_queue', 0, time(), ['limit' => [0, 1]]);
    if (!empty($jobs)) {
        $job = array_shift($jobs);
        // 执行任务
        sendEmail(json_decode($job, true));
        // 从队列中删除已执行的任务
        $redis->zRem('delayed_queue', $job);
    }
    // 休眠1秒后再继续检查队列
    sleep(1);
}

?>

上記のコードは、まず Redis サーバーに接続し、次にタスクを配置します。遅延キューの遅延時間を 60 秒に設定します。その後ループでキューを継続的にチェックし、遅延時間が経過したタスクがあればそのタスクを実行し、実行されたタスクはキューから削除されます。

2. スケジュールされたタスクの適用シナリオ:
スケジュールされたタスクとは、1 日に 1 回、1 時間に 1 回など、あらかじめ決められた時間間隔に従ってタスクを実行することを指します。この方法は、データのバックアップやログのクリーニングなど、定期的な実行が必要なシナリオでよく使用されます。

PHP では、crontab コマンドを使用してスケジュールされたタスクをスケジュールできます。

コード例:

// 执行定时任务
function doTask() {
    // 固定时间点执行的任务
    echo "Fixed time task executed.

";

}

// 执行周期性任务
function doPeriodicTask() {
    // 周期性执行的任务
    echo "Periodic task executed.

";

}

// 指定固定时间点的定时任务（例如每天凌晨执行）
$cron = '0 0 * * *';
exec("crontab -l > tmpcron");
file_put_contents("tmpcron", "$cron php -f /path/to/task.php >> /path/to/output.log 2>&1

", FILE_APPEND);

exec("crontab tmpcron");

// 间隔一小时执行一次的定时任务（每小时的第5分钟执行）
$cron = '5 * * * *';
exec("crontab -l > tmpcron");
file_put_contents("tmpcron", "$cron php -f /path/to/task.php >> /path/to/output.log 2>&1

", FILE_APPEND);

exec("crontab tmpcron");

// 执行任务
doTask();
doPeriodicTask();

?>

上記のコードでは、固定時間を表す doTask() と doPeriodicTask() という 2 つの関数が最初に定義されています。ポイント実行タスクと定期実行タスク。

次に、コマンド ラインから crontab コマンドを呼び出して、スケジュールされたタスクをシステムのスケジュールされたタスク リストに追加します。このうち cron パラメータは、タスクの実行時間ルールを指定するために使用されます。つまり、タスクは毎朝 1 回、毎時 5 分に 1 回実行されます。 php コマンドは、スケジュールされたタスクが配置されているスクリプト ファイルを実行し、出力を出力ログ ファイルにリダイレクトするために使用されます。

最後に、2 つの関数 doTask() と doPeriodicTask() がコード内で呼び出され、タスクの実際の実行が表現されます。

概要:
キュー遅延タスクとスケジュールされたタスクには、PHP と MySQL の幅広いアプリケーション シナリオがあります。キュー内の遅延タスクを使用することにより、遅延処理が必要な一部のタスクを実装し、システムのリアルタイム パフォーマンスを向上させることができます。スケジュールされたタスクを使用すると、定期的に実行する必要があるタスクを実装し、システムの自動化を向上させることができます。上記では、読者の参考のために、PHP および MySQL でキュー遅延タスクとスケジュールされたタスクを適用するための具体的なコード例を示しています。

以上がPHP および MySQL でのキュー遅延タスクとスケジュールされたタスクのアプリケーション シナリオの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。