PHP 마이크로서비스를 사용하여 분산 작업 예약 및 디스패치를 ​​구현하는 방법

PHP 마이크로서비스를 사용하여 분산 작업 예약 및 발송을 구현하는 방법

개요:
인터넷의 급속한 발전으로 인해 작업을 효율적으로 예약하고 발송하는 방법은 많은 기업과 개발자가 직면한 중요한 문제가 되었습니다. 마이크로서비스 아키텍처를 채택한 애플리케이션은 분산 작업 예약 및 파견을 더 잘 처리할 수 있습니다. 이 문서에서는 PHP를 사용하여 분산 작업 예약 및 디스패치를 ​​위한 마이크로서비스 아키텍처를 구현하는 방법을 소개하고 구체적인 코드 예제를 제공합니다.

1. RabbitMQ 설치 및 구성
   RabbitMQ는 분산 애플리케이션이 메시지의 비동기 전송 및 처리를 쉽게 구현할 수 있게 해주는 강력한 메시지 대기열 시스템입니다. 먼저 RabbitMQ를 설치하고 필요한 사용자 권한과 가상 호스트를 구성해야 합니다.
2. 작업 스케줄러 및 작업 실행기 생성
   마이크로 서비스 아키텍처에서는 두 개의 서로 다른 PHP 애플리케이션을 생성합니다. 하나는 작업 예약, 즉 작업 스케줄러를 담당하고 다른 하나는 특정 작업의 실행을 담당합니다. 즉, 작업 실행자입니다.

작업 스케줄러의 코드 예:

<?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. 작업 스케줄러와 작업 실행기 시작 및 테스트
   작업 스케줄러와 작업 실행기를 각각 명령줄에서 시작합니다. 다른 터미널 창을 사용할 수 있습니다. . 예를 들어, 작업 스케줄러의 터미널 창에서 실행:

$ php scheduler.php First task

작업 실행기의 터미널 창에서 실행:

$ php worker.php

두 애플리케이션은 서로 통신하고 작업 예약 및 발송 프로세스를 완료합니다.

결론:
이 기사에서는 PHP 마이크로서비스를 사용하여 분산 작업 예약 및 파견을 구현하는 방법을 소개합니다. RabbitMQ 메시지 큐 시스템을 사용하면 작업의 비동기 처리와 별도의 작업 예약 및 작업 실행을 쉽게 구현할 수 있어 시스템의 확장성과 유지 관리성이 향상됩니다. 이 기사가 도움이 되기를 바랍니다.

위 내용은 PHP 마이크로서비스를 사용하여 분산 작업 예약 및 디스패치를 ​​구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!