PHP マイクロサービスを使用して分散タスクのスケジューリングとディスパッチを実装する方法

PHP マイクロサービスを使用して分散タスクのスケジューリングとディスパッチを実装する方法

概要:
インターネットの急速な発展に伴い、タスクを効率的にスケジュールおよびディスパッチする方法これは多くの企業や開発者が直面する重要な問題です。マイクロサービス アーキテクチャを採用したアプリケーションは、分散タスクのスケジューリングとディスパッチをより適切に処理できます。この記事では、PHP を使用して分散タスクのスケジューリングとディスパッチのためのマイクロサービス アーキテクチャを実装する方法を紹介し、具体的なコード例を示します。

1. インストールと構成 RabbitMQ
   RabbitMQ は、分散アプリケーションがメッセージの非同期送信と処理を簡単に実装できるようにする強力なメッセージ キュー システムです。まず、RabbitMQ をインストールし、必要なユーザー権限と仮想ホストを構成する必要があります。
2. タスク スケジューラとタスク エグゼキュータを作成する
   マイクロサービス アーキテクチャでは、2 つの異なる PHP アプリケーションを作成します。1 つはタスク スケジューリング、つまりタスク スケジューラを担当し、もう 1 つは実行を担当します。特定のタスクの担当者、つまりタスク実行者。

タスク スケジューラのコード例:

<?php
require_once __DIR__ . '/vendor/autoload.php';

use PhpAmqpLibConnectionAMQPStreamConnection;
use PhpAmqpLibMessageAMQPMessage;

// 连接到RabbitMQ主机
$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();

// 定义任务队列
$channel->queue_declare('task_queue', false, true, false, false);

// 从命令行参数中获取任务参数
$data = implode(' ', array_slice($argv, 1));
if(empty($data)) {
    $data = "Hello World!";
}

// 创建消息对象
$msg = new AMQPMessage($data, ['delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT]);

// 发送消息到任务队列
$channel->basic_publish($msg, '', 'task_queue');

echo " [x] Sent '$data'
";

$channel->close();
$connection->close();

タスク エグゼキュータのコード例:

<?php
require_once __DIR__ . '/vendor/autoload.php';

use PhpAmqpLibConnectionAMQPStreamConnection;
use PhpAmqpLibMessageAMQPMessage;

// 连接到RabbitMQ主机
$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();

// 定义任务队列
$channel->queue_declare('task_queue', false, true, false, false);

echo " [*] Waiting for messages. To exit press CTRL+C
";

// 回调函数，用于处理任务消息
$callback = function ($msg) {
    echo " [x] Received ", $msg->body, "
";

    // 模拟任务执行过程
    sleep(substr_count($msg->body, '.'));

    echo " [x] Done
";

    // 显式确认任务消息已完成
    $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
};

// 每次只接受一个任务消息
$channel->basic_qos(null, 1, null);
$channel->basic_consume('task_queue', '', false, false, false, false, $callback);

while (count($channel->callbacks)) {
    $channel->wait();
}

$channel->close();
$connection->close();

3. タスク スケジューラとタスク エグゼキュータの起動とテスト
   Startタスク スケジューラとタスク エグゼキュータをコマンド ラインで個別に実行できるため、異なるターミナル ウィンドウを使用できます。たとえば、タスク スケジューラのターミナル ウィンドウで実行します:

$ php scheduler.php First task

タスク実行プログラムのターミナル ウィンドウで実行します:

$ php worker.php

2 つのアプリケーションは相互に通信し、完了します。タスク スケジュールとディスパッチのプロセス。

結論:
この記事では、PHP マイクロサービスを使用して分散タスクのスケジューリングとディスパッチを実装する方法を紹介します。 RabbitMQ メッセージキューシステムを利用することで、タスクの非同期処理やタスクのスケジューリングとタスクの実行を分離することが容易に実現でき、システムの拡張性や保守性が向上します。この記事がお役に立てば幸いです。

以上がPHP マイクロサービスを使用して分散タスクのスケジューリングとディスパッチを実装する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。