PHP를 사용하여 RabbitMQ 메시지 큐에 액세스하는 방법

이 기사에서는 주로 RabbitMQ 메시지 큐에 액세스하기 위해 PHP를 사용하는 방법을 소개합니다. RabbitMQ 메시지 큐의 관련 확장 설치, 큐 설정, 큐 바인딩, 메시지 전송, 메시지 수신 및 기타 관련 작업 기술을 예제 형식으로 분석합니다. .필요한 친구는 참고할 수 있습니다

이 기사의 예에서는 PHP를 사용하여 RabbitMQ 메시지 대기열에 액세스하는 방법을 설명합니다. 참고할 수 있도록 모든 사람과 공유하세요. 세부 사항은 다음과 같습니다.

확장 설치

PHP는 실제로 AMQP 프로토콜을 사용하여 RabbitMQ에 액세스하므로 epel 라이브러리에 php-pecl-amqp 패키지만 설치하면 됩니다

rpm -ivh http://mirror.neu.edu.cn/fedora/epel/6/x86_64/epel-release-6-8.noarch.rpm
yum install php-pecl-amqp

교환 설정

<?php
$connection = new AMQPConnection();
$connection->connect();
$channel = new AMQPChannel($connection);
$exchange = new AMQPExchange($channel);
$exchange->setName(&#39;exchange1&#39;);
$exchange->setType(&#39;fanout&#39;);
$exchange->declare();

큐 설정

<?php
$connection = new AMQPConnection();
$connection->connect();
$channel = new AMQPChannel($connection);
$queue = new AMQPQueue($channel);
$queue->setName(&#39;queue1&#39;);
$queue->declare();

큐 바인딩

<?php
$connection = new AMQPConnection();
$connection->connect();
$channel = new AMQPChannel($connection);
$queue = new AMQPQueue($channel);
$queue->setName(&#39;queue1&#39;);
$queue->declare();
$queue->bind('exchange1', 'routekey');

메시지 보내기

<?php
$connection = new AMQPConnection();
$connection->connect();
$channel = new AMQPChannel($connection);
$exchange = new AMQPExchange($channel);
$exchange->setName(&#39;exchange5&#39;);
$exchange->setType(&#39;fanout&#39;);
$exchange->declare();
for($i = 0; $i < 2000000; $i++) {
 $exchange->publish("message $i", "routekey");
}

메시지 수신

<?php
$connection = new AMQPConnection();
$connection->connect();
$channel = new AMQPChannel($connection);
$queue = new AMQPQueue($channel);
$queue->setName(&#39;queue1&#39;);
$queue->declare();
$queue->bind('exchange1', 'routekey');
while (true) {
  $queue->consume(function($envelope, $queue){
   echo $envelope->getBody(), PHP_EOL;
  }, AMQP_AUTOACK);
}

관련 권장 사항:

PHP 메시지 대기열 서비스

위 내용은 PHP를 사용하여 RabbitMQ 메시지 큐에 액세스하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!