PHP에서 작업 예약 및 대기열 관리를 위해 RabbitMQ를 사용하는 방법

PHP에서 작업 예약 및 대기열 관리를 위해 RabbitMQ를 사용하는 방법

1. 소개
웹 애플리케이션을 개발할 때 이메일 보내기, 보고서 생성, 대용량 데이터 처리 등과 같이 시간이 많이 걸리는 작업을 처리해야 하는 경우가 종종 있습니다. . 이러한 작업이 웹 요청에서 직접 실행되면 응답 시간이 느려지고 사용자 경험에 영향을 미칠 수 있습니다. 이 문제를 해결하기 위해 작업 예약 및 대기열 관리에 메시지 대기열을 사용할 수 있습니다. RabbitMQ는 PHP에서 쉽게 사용할 수 있는 풍부한 API를 제공하는 강력한 메시지 대기열 시스템입니다.

2. RabbitMQ 설치
먼저 서버에 RabbitMQ를 설치해야 합니다. 공식 웹사이트에서 제공하는 설치 튜토리얼에 따라 설치하거나, ​​Docker를 사용하여 RabbitMQ 컨테이너를 직접 실행할 수 있습니다. 설치가 완료되면 RabbitMQ 관리 페이지에 접속하여 큐의 상태를 확인하고 큐를 관리할 수 있습니다.

3. PHP-amqplib 라이브러리를 사용하여 작동
PHP에서 RabbitMQ를 사용하려면 PHP-amqplib와 같은 타사 라이브러리를 사용해야 합니다. 이 라이브러리는 Composer를 통해 도입할 수 있습니다.

composer require php-amqplib/php-amqplib

설치가 완료된 후 코드에 라이브러리 파일을 도입합니다.

use PhpAmqpLibConnectionAMQPStreamConnection;
use PhpAmqpLibMessageAMQPMessage;

IV. RabbitMQ를 사용하기 전에 먼저 연결해야 합니다. RabbitMQ 서버:

$host = 'localhost';
$port = 5672;
$user = 'guest';
$pass = 'guest';
$connection = new AMQPStreamConnection($host, $port, $user, $pass);
$channel = $connection->channel();

여기에서 사용됩니다. 기본 RabbitMQ 호스트, 포트, 사용자 이름 및 비밀번호입니다. 사용자 정의된 요구사항이 있는 경우 이러한 매개변수는 실제 상황에 따라 수정될 수 있습니다.

5. 대기열에 메시지 보내기

작업 예약에서는 일반적으로 백그라운드 작업자가 사용할 수 있도록 작업을 메시지 대기열로 보냅니다. 다음 코드를 사용하여 메시지를 대기열로 보낼 수 있습니다.

$message = new AMQPMessage('hello world');
$channel->basic_publish($message, '', 'task_queue');

여기서 AMQPMessage 인스턴스를 만들고 보낼 메시지 본문을 설정합니다. 그런 다음 basic_publish 메서드를 사용하여 task_queue라는 대기열에 메시지를 보냅니다.

6. 대기열에서 메시지 사용

대기열에서 메시지를 사용하려면 처리를 위해 백그라운드에서 하나 이상의 작업자 프로세스를 시작해야 합니다. 작업자 프로세스는 대기열에서 메시지를 검색하고 해당 작업을 수행합니다. 다음 코드를 사용하여 대기열의 메시지를 사용할 수 있습니다.

$callback = function ($message) {
    echo "Received: " . $message->body . "
";
    usleep(100000);
    echo "Done
";
    $message->ack();
};
$channel->basic_consume('task_queue', '', false, false, false, false, $callback);
while (count($channel->callbacks)) {
    $channel->wait();
}

여기서 익명 함수 $callback을 메시지 처리 논리로 정의합니다. 이 함수에서는 특정 작업 처리를 수행한 다음 $message->ack() 메서드를 호출하여 작업이 완료되었음을 나타낼 수 있습니다. ack 메소드를 호출하는 이유는 RabbitMQ는 기본적으로 작업이 성공적으로 실행되었는지 알 수 없기 때문에 작업의 실행 결과를 수동으로 확인해야 하기 때문입니다.

7. 메시지 지속성

위의 예에서는 RabbitMQ 서버가 다시 시작되면 메시지 지속성이 꺼집니다. 서버가 다시 시작된 후 메시지가 자동으로 복원되도록 하려면 메시지 지속성을 수행해야 합니다. 다음 코드로 설정할 수 있습니다.

$channel->queue_declare('task_queue', false, true, false, false);

세 번째 매개변수를 true로 설정합니다. 이는 대기열이 영구 대기열로 설정됨을 의미합니다.

8. 지연된 작업

때로는 지연된 작업을 구현하고 지정된 시간 이후에 작업을 실행해야 할 때도 있습니다. RabbitMQ 자체에서는 작업 지연 기능을 지원하지 않지만, 플러그인을 추가하면 가능합니다. 일반적으로 사용되는 플러그인은 Rabbitmq_delayed_message_exchange이며 다음과 같은 방법으로 설치할 수 있습니다.

rabbitmq-plugins enable rabbitmq_delayed_message_exchange

설치 후 메시지 전송 시 AMQPMessage 속성을 다음과 같이 설정합니다.

$message->set('application_headers', ['x-delay' => 3000]);

위 코드는 1시간의 지연을 두고 실행됩니다. 메시지 전송 후 3초.

9. 요약

이번 글의 소개를 통해 우리는 PHP에서 작업 스케줄링과 큐 관리를 위해 RabbitMQ를 사용하는 방법을 배웠습니다. 위 단계를 연습한 후에는 RabbitMQ를 쉽게 사용하여 시간이 많이 걸리는 작업을 처리하고 애플리케이션 성능과 안정성을 향상시킬 수 있습니다. 동시에 메시지 지속성 및 지연된 작업 처리 방법도 도입하여 다양한 요구 사항을 더 잘 충족할 수 있습니다. 이 글이 실제 프로젝트에서 RabbitMQ를 사용하는 데 도움이 되기를 바랍니다.

참고자료:

RabbitMQ 공식 홈페이지: https://www.rabbitmq.com/
1. PHP-amqplib 공식 문서: https://github.com/php-amqplib/php-amqplib

위 내용은 PHP에서 작업 예약 및 대기열 관리를 위해 RabbitMQ를 사용하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!