PHP 및 RabbitMQ : 고급 예

파트 1에서 우리는 PHP의 AMQP 프로토콜의 이론과 간단한 사용 사례를 RabbitMQ로 브로커로 다루었습니다. 이제 몇 가지 고급 예를 들어 봅시다.

키 테이크 아웃

PHP 및 RabbitMQ를 사용하여 여러 작업자들 사이에서 데이터를 비동기 적으로 처리하여 고전력이 높은 환경에서 효율성을 높입니다. 는 'Delivery_Mode'메시지를 2로 설정하고 큐를 내구성있는 것으로 선언하여 서버 충돌 중에 데이터 손실을 방지하기 위해 RabbitMQ에서 지속적인 메시지를 구현합니다. RabbitMQ에서 서비스 품질 (QOS) 설정을 사용하여 근로자 간의 메시지 분포를 제어하여 단일 근로자가 압도되지 않도록합니다. 사용자 인증과 같은 작업에 유용한 응답이 필요한 메시지를 보내서 RPC (원격 프로 시저 호출)에 RPC (원격 프로 시저 호출)를 활용합니다. 클라이언트와 서버간에 메시지가 올바르게 단단히 지시되도록 RPC 응답을위한 독점적 인 임시 대기열을 설정합니다. 요청과의 응답에서 'Correlation_id'를 일치시켜 RPC 응답을 효과적으로 처리하여 답장의 올바른 처리 및 처리를 보장합니다.

예 1 : 여러 근로자들 사이에서 비동기 적으로 데이터를 처리하도록 요청 보내기

이전 부분의 예에서, 우리는 한 명의 생산자, 하나의 소비자가있었습니다. 소비자가 죽으면 소비자가 다시 시작할 때까지 메시지가 줄에 계속 쌓일 것입니다. 그런 다음 모든 메시지를 하나씩 처리합니다.

이것은 분당 상당한 양의 요청이있는 동시 사용자 환경에서 이상적이지 않을 수 있습니다. 다행히 소비자를 확장하는 것은 매우 쉽지만 또 다른 예를 구현합시다.

사용자가 송장 번호를 제공 해야하는 송장 생성 서비스가 있다고 가정 해 봅시다. 시스템은 자동으로 PDF 파일을 생성하여 사용자에게 이메일을 보냅니다. 생성 프로세스가 실행되는 서버가 리소스 제한 인 경우 이메일 생성 및 전송에 몇 초가 걸릴 수 있습니다. 이제 초당 여러 거래를 지원해야한다고 가정 해 봅시다. 서버를 압도하지 않고 어떻게이를 달성 할 수 있습니까?
• 우리는 다음 패턴을 구현해야합니다 프로듀서 수업을 살펴 ​​보겠습니다 :
workersender :: execute () 메소드는 송장 번호를받습니다. 다음으로 우리는 평소와 같이 연결, 채널 및 큐를 만듭니다.
이번에는 메시지 객체를 작성하는 동안 생성자는 두 번째 매개 변수를 수신합니다. 배열 ( 'delatip_mode'=> 2). 이 경우 RabbitMQ 서버가 충돌하면 메시지가 손실되지 않아야한다고 말하고 싶습니다. 이것이 작동하기 위해서는 대기열도 내구성이 뛰어나야합니다.
• . 다음 코드는 양식 데이터를 수신하고 생산자를 실행하는 데 사용될 수 있습니다.

  <span><span><?php
  </span></span><span><span>namespace Acme<span>\AmqpWrapper</span>;
  </span></span><span>
  </span><span><span>use PhpAmqpLib<span>\Connection\AMQPConnection</span>;
  </span></span><span><span>use PhpAmqpLib<span>\Message\AMQPMessage</span>;
  </span></span><span>
  </span><span><span>class WorkerSender
  </span></span><span><span>{
  </span></span><span>    <span>/* ... SOME OTHER CODE HERE ... */
  </span></span><span>    
  </span><span>    <span>/**
  </span></span><span><span>     * Sends an invoice generation task to the workers
  </span></span><span><span>     * 
  </span></span><span><span>     * <span>@param <span>int</span> $invoiceNum
  </span></span></span><span><span>     */ 
  </span></span><span>    <span>public function execute($invoiceNum)
  </span></span><span>    <span>{
  </span></span><span>        <span>$connection = new AMQPConnection('localhost', 5672, 'guest', 'guest');
  </span></span><span>        <span>$channel = $connection->channel();
  </span></span><span>        
  </span><span>        <span>$channel->queue_declare(
  </span></span><span>            <span>'invoice_queue',    #queue - Queue names may be up to 255 bytes of UTF-8 characters
  </span></span><span>            <span>false,              #passive - can use this to check whether an exchange exists without modifying the server state
  </span></span><span>            <span>true,               #durable, make sure that RabbitMQ will never lose our queue if a crash occurs - the queue will survive a broker restart
  </span></span><span>            <span>false,              #exclusive - used by only one connection and the queue will be deleted when that connection closes
  </span></span><span>            <span>false               #auto delete - queue is deleted when last consumer unsubscribes
  </span></span><span>            <span>);
  </span></span><span>            
  </span><span>        <span>$msg = new AMQPMessage(
  </span></span><span>            <span>$invoiceNum,
  </span></span><span>            <span>array('delivery_mode' => 2) # make message persistent, so it is not lost if server crashes or quits
  </span></span><span>            <span>);
  </span></span><span>            
  </span><span>        <span>$channel->basic_publish(
  </span></span><span>            <span>$msg,               #message 
  </span></span><span>            <span>'',                 #exchange
  </span></span><span>            <span>'invoice_queue'     #routing key (queue)
  </span></span><span>            <span>);
  </span></span><span>            
  </span><span>        <span>$channel->close();
  </span></span><span>        <span>$connection->close();
  </span></span><span>    <span>}
  </span></span><span><span>}</span></span>

  편안한 소독/검증을 사용하십시오 소비자 측면에서 상황이 조금 흥미로워집니다.
  평소와 같이, 우리는 연결을 만들고, 채널을 도출하고, 큐를 선언해야합니다 (큐의 매개 변수는 생산자와 동일해야합니다).

  .

  작업자 행동 (여러 프로세스간에 메시지를 발송)을 갖기 위해서는 $ Channel-> Basic_Qos () : 로 서비스 품질 (QOS) 매개 변수를 선언해야합니다.

  <span><span><?php
  </span></span><span><span>/* ... SOME CODE HERE ... */
  </span></span><span>
  </span><span>        <span>$msg = new AMQPMessage(
  </span></span><span>            <span>$invoiceNum,
  </span></span><span>            <span>array('delivery_mode' => 2) # make message persistent, so it is not lost if server crashes or quits
  </span></span><span>            <span>);
  </span></span><span>
  </span><span><span>/* ... SOME CODE HERE ... */</span></span>

  프리 페치 크기

  : 특정 제한 없음, 우리는 필요한만큼 많은 근로자를 가질 수 있습니다. prefetch count

  : 승인을 다시 보내기 전에 작업자 당 얼마나 많은 메시지가 있는지. 이렇게하면 작업자가 한 번에 1 개의 메시지를 처리하게됩니다.

  <span><span><?php
  </span></span><span><span>chdir(dirname(__DIR__));
  </span></span><span><span>require_once('vendor/autoload.php');
  </span></span><span>
  </span><span><span>use Acme<span>\AmqpWrapper\WorkerSender</span>;
  </span></span><span>
  </span><span><span>$inputFilters = array(
  </span></span><span>    <span>'invoiceNo' => FILTER_SANITIZE_NUMBER_INT,
  </span></span><span><span>);
  </span></span><span><span>$input = filter_input_array(INPUT_POST, $inputFilters);
  </span></span><span><span>$sender = new WorkerSender();
  </span></span><span><span>$sender->execute($input['invoiceNo']);</span></span>

  Global

  : NULL은 위의 설정 이이 소비자에게만 적용됨을 의미합니다.

  다음으로, 우리는 매개 변수의 주요 차이점으로 소비를 시작할 것입니다. 우리는 자동 ACK를 끄겠습니다. 우리는 메시지 처리를 마치면 RabbitMQ 서버에 알리고 새 메시지를받을 준비가되기 때문입니다.
  이제, 우리는 그 ACK를 어떻게 보내나요? WorkErreceiver :: Process () 메소드 (메시지를 수신 할 때 콜백 메소드로 선언)를 살펴보십시오. GeneratedPdf () 및 SendEmail () 메소드에 대한 호출은 두 작업을 수행하는 데 소요 된 시간을 시뮬레이션하는 더미 메소드입니다. $ msg 매개 변수에는 생산자로부터 보낸 페이로드가 포함되어있을뿐만 아니라 생산자가 사용하는 개체에 대한 정보도 포함되어 있습니다. 우리는 $ msg-> delivery_info [ 'channel'] ($ connection-> 채널 ()을 사용하여 소비자를 위해 열린 채널과 동일한 객체 유형과 함께 생산자가 사용하는 채널에 대한 정보를 추출 할 수 있습니다. 프로덕션 채널을 프로세스를 완료했다는 승인을 보내야하므로 Basic_ack () 메소드를 사용하여 매개 변수로 전송 태그 ($ msg-> delivery_info [ 'delative_tag']) RabbitMQ가 자동으로 생성됩니다. ACK가 속한 메시지를 올바르게 연관시키기 위해.
  • 우리는 어떻게 노동자들을 해고합니까? workerreceiver :: listen () 메소드를 호출하여 다음과 같은 파일을 만듭니다. 이제 PHP 명령 (예 : PHP Worker.php 또는 위의 파일에 제공 한 이름)을 사용하여 작업자를 해고하십시오. 그러나 잠깐만, 목적은 두 명 이상의 노동자를 갖는 것이 아니 었습니까? 문제 없음, 동일한 파일의 여러 프로세스를 갖기 위해 같은 방식으로 더 많은 작업자를 발사하면 RabbitMQ는 소비자를 등록하고 QoS 매개 변수에 따라 작업을 배포합니다. . 예제 2 : RPC 요청을 보내고 회신을 기대하십시오 지금까지, 우리는 사용자가 답장을 기다릴 필요없이 RabbitMQ 서버에 메시지를 보내고 있습니다. 이는 사용자가 'OK'메시지를 보려고 기꺼이 지출하는 것보다 더 많은 시간이 걸릴 수있는 비동기 프로세스에서도 괜찮습니다. 그러나 실제로 답장이 필요하다면 어떻게해야합니까? 복잡한 계산으로 인한 결과를 가정 해 봅시다. 그래서 우리는 사용자에게 보여줄 수 있습니까?

    다른 응용 프로그램에서 격리 된 인증 메커니즘으로 작동하는 중앙 집중식 로그인 서버 (단일 부호 켜기)가 있다고 가정 해 봅시다. 이 서버에 도달하는 유일한 방법은 Rabbitmq를 통한 것입니다. 로그인 자격 증명을이 서버로 보내고 보조금/거부 액세스 응답을 기다리는 방법을 구현해야합니다.

    우리는 다음 패턴을 구현해야합니다

    평소와 같이, 먼저 프로듀서를 살펴 보겠습니다 :

    rpcsender :: execute 메소드를 살펴보면 $ credentials 매개 변수는 [ 'username'=> 'x', 'password'=> 'y'] 형식의 배열입니다. 다시, 우리는 새로운 연결을 열고 평소와 같이 채널을 만듭니다.

    첫 번째 차이점은 대기열을 선언하는 것입니다. 먼저 $ Channel-> queue_declare ()의 결과를 포착하기 위해 List () 구조를 사용하고 있음을 주목하십시오. 큐 이름을 명시 적으로 보내지 않기 때문에이 대기열이 식별되는 방법을 찾아야하기 때문입니다. 우리는 결과 배열의 첫 번째 요소에만 관심이 있습니다.이 요소는 큐의 고유 식별자가 될 것입니다 (AMQ.GEN-_U0KJVM8HELFZQKKKK9P0Z9GG와 같은). 두 번째 변경 사항은이 대기열을 독점적으로 선언해야한다는 것입니다. 따라서 다른 동시 프로세스의 결과에는 혼합이 없습니다.

    . 또 다른 큰 변화는 프로듀서가 대기열의 소비자가 될 것이라는 점입니다. $ Channel-> Basic_Consume ()을 실행할 때 큐를 선언하는 동안받은 $ Callback_queue 값을 제공하고 있음을 알 수 있습니다. 그리고 모든 소비자와 마찬가지로 프로세스가 응답을받을 때 실행할 콜백을 선언합니다.
    다음, 메시지에 대한 상관 ID를 만들어야합니다. 이것은 각 메시지에 대한 고유 식별자에 지나지 않습니다. 예에서는 Uniqid ()의 출력을 사용하고 있지만 선호하는 메커니즘을 사용할 수 있습니다 (레이스 조건을 만들지 않는 한 강력하고 암호화 된 RNG가 될 필요는 없습니다).

    .

    이제 메시지를 만들어 봅시다. 메시지를 만들어 봅시다. 메시지를 만들어 봅시다.이 메시지를 만들어 봅시다.이 메시지를 만들어 봅시다.이 메시지를 작성하겠습니다.이 예제는 처음 두 예제에서 사용했던 것과 비교하여 중요한 변경 사항이 있습니다. 인증하려는 자격 증명이 포함 된 JSON 인코딩 문자열을 할당하는 것 외에도 AMQPMESSAGE 생성자에게 두 개의 속성이 정의 된 배열을 제공해야합니다.

    Correlation_id
    • : 메시지의 태그 Reply_to : 큐를 선언하면서 큐 식별자가 생성되었습니다 메시지를 게시 한 후, 우리는 처음에 비어있을 응답을 평가할 것입니다. 응답 값은 비어 있지만 $ Channel-> Wait ();. 채널에서 응답을 받으면 콜백 메소드가 호출됩니다 (rpcsender :: onresponse ()). 이 방법은 수신 된 상관 ID와 생성 된 상관 ID와 일치하며 동일하면 응답 본문을 설정하여 while 루프를 깨뜨립니다. RPC 소비자는 어떻습니까? 여기 :
    동일한 오래된 연결 및 채널 생성 :) 큐를 선언하는 것과 동일하지만이 대기열은 사전 정의 된 이름 (‘ rpc_queue 마법은 선언 된 콜백 내에서 나옵니다. 자격 증명을 인증하면 (예, 프로세스가 정적 사용자 이름/암호 값에 대해 프로세스가 수행된다는 것을 알고 있습니다.이 자습서는 자격 증명을 인증하는 방법에 관한 것이 아닙니다.) 생성. 우리는 $ req-> get ( 'correlation_id')를 사용하여 요청 메시지에서 이것을 추출 할 수 있으며,이 값을 제작자에서 수행 한 것과 같은 방식으로 전달합니다. 이제 우리는이 메시지를 프로듀서에서 만들어진 동일한 대기열 ( '랜덤'이름을 가진 것)에 게시해야합니다. 우리는 $ req-> get ( 'Reply_to')로 큐의 이름을 추출하고 basic_publish ()의 라우팅 키로 사용합니다. 일단 메시지를 게시 한 후에는 $ req-> delation_info [ 'channel']-> basic_ack ()로 ACK 통지를 채널로 보내야합니다. ] 따라서 생산자는 대기를 멈출 수 있습니다. 다시, 청취 과정을 발사하면 갈 준비가되어 있습니다. 예제 2와 3을 결합하여 여러 근로자를 해고하는 것만으로도 스케일링 할 수있는 것보다 인증 요청을 수행하기 위해 다중 작업자 RPC 프로세스를 수행 할 수도 있습니다. 가상 호스트, 교환 유형, 서버 관리 등과 같은 RabbitMQ 및 AMQP에 대해 더 많은 말이 있습니다. 여기 및 문서 페이지에서 더 많은 응용 프로그램 패턴 (라우팅, 주제)을 찾을 수 있습니다. RabbitMQ와 웹 기반 인터페이스를 관리하기위한 명령 줄 도구도 있습니다. 이 튜토리얼 시리즈를 좋아하고 MQ 및 더 많은 실제 사용 사례에 대해 더보고 싶다면 아래 의견에 알려주십시오! PHP RabbitMQ 고급 예제 에 대한 자주 묻는 질문 (FAQ) PHP에서 RabbitMQ의 역할은 무엇입니까?

    RabbitMQ는 응용 프로그램이 서로 비동기 적으로 통신 할 수있는 메시지 중개인입니다. PHP 응용 프로그램에서 높은 부하와 복잡한 작업을보다 효율적으로 처리 할 수있게함으로써 중요한 역할을합니다. RabbitMQ는 AMQP (Advanced Message Queuing Protocol)를 사용하여 응용 프로그램의 다른 부분 간의 메시지 교환을 용이하게합니다. 이를 통해 프로세스의 분리가 가능하고 응용 프로그램을보다 확장 가능하고 탄력적으로 만들 수 있습니다.

    PHP 용 RabbitMQ를 설치하려면 PHP 용 RabbitMQ를 설치하려면 먼저 RabbitMQ 서버를 설치해야합니다. 당신의 기계. 이것은 공식 RabbitMQ 웹 사이트를 통해 수행 할 수 있습니다. 서버가 설치된 후 PHP AMQP 확장자를 설치하여 RabbitMQ와 상호 작용하는 데 필요한 기능을 제공 할 수 있습니다. 이것은 pecl install amqp를 사용하여 pecl 설치 프로그램을 사용하여 수행 할 수 있습니다.
    php에서 php에서 Rabbitmq 교환을 어떻게 만들 수 있습니까?

    php에서 exchange_declare 메소드를 사용하여 RabbitMQ 교환을 만들 수 있습니다. AMQPCHANNAL 클래스의. 이 메소드는 교환 이름, 교환 유형 (직접, 주제, 팬 아웃 또는 헤더) 및 수동, 내구성, auto_delete 및 인수와 같은 선택적 매개 변수를 포함하여 여러 매개 변수를 사용합니다. PHP의 RabbitMQ 대기열에 메시지를 보내십니까?

    PHP의 RabbitMQ 대기열에 메시지를 보내려면 먼저 인스턴스를 만들어야합니다. 메시지 내용이있는 amqpmessage 클래스의 그런 다음 AMQPCHANNAL 클래스의 BASIC_PUBLISH 메소드를 사용하여 메시지를 대기열로 보낼 수 있습니다. Basic_publish 메소드는 메시지, 교환 및 라우팅 키를 매개 변수로 가져옵니다.

    php의 RabbitMQ 대기열에서 메시지를 어떻게 소비 할 수 있습니까? amqpchannel 클래스의 Basic_Consume 메소드를 사용한 RabbitMQ 대기열. 이 메소드는 큐 이름, 소비자 태그, no_local, no_ack, 독점 및 메시지가 수신 될 때 실행될 콜백 함수를 포함한 여러 매개 변수를 사용합니다.

    PHP로 RabbitMQ에서 오류를 처리하는 방법 ?

    PHP를 사용한 RabbitMQ에서 오류 처리는 시도 트리 캐치 블록을 사용하여 수행 할 수 있습니다. PHP AMQP 확장은 오류가 발생할 때 AMQPException 클래스의 예외를 제외합니다. 이러한 예외를 포착하고 응용 프로그램의 요구에 따라 처리 할 수 ​​있습니다.

    PHP를 사용하여 RabbitMQ에서 메시지 내구성을 보장하려면 PHP를 사용하여 RabbitMQ에서 메시지 내구성을 확인하려면 다음을 설정할 수 있습니다. AMQPMESSAGE 클래스의 AMPERE_MODE 속성 2 대 또는 다시 시작합니다. RabbitMQ에서 PHP에서 우선 순위 큐를 구현할 수있는 방법?

    RabbitMQ의 우선 순위 대기열은 대기열을 선언 할 때 x-max-creatity 인수를 설정하여 PHP에서 구현할 수 있습니다. 그런 다음 메시지를 보낼 때 AMQPMESSAGE 클래스의 우선 순위 속성을 지정한 0과 최대 우선 순위 사이의 값으로 설정할 수 있습니다. > RabbitMQ는 콜백 대기열에 설정된 응답 속성이있는 메시지를 보내서 PHP의 원격 프로 시저 호출 (RPC)에 사용할 수 있습니다. 서버는 콜백 큐에 응답을 보낼 수 있으며 클라이언트는 PHP에서 RabbitMQ를 모니터링하는 방법을 사용하여 수행 할 수 있습니다. RabbitMQ 관리 플러그인은 RabbitMQ 서버를 모니터링하고 관리하기위한 웹 기반 인터페이스를 제공합니다. AMQPCHANNAL 클래스의 메소드를 사용하여 채널 상태에 대한 정보를 얻을 수 있습니다.

위 내용은 PHP 및 RabbitMQ : 고급 예의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!