So greifen Sie mit PHP auf die RabbitMQ-Nachrichtenwarteschlange zu

In diesem Artikel wird hauptsächlich die Methode zur Verwendung von PHP für den Zugriff auf die RabbitMQ-Nachrichtenwarteschlange vorgestellt. Er analysiert die zugehörige Erweiterungsinstallation, die Warteschlangeneinrichtung, die Warteschlangenbindung, das Senden von Nachrichten, den Nachrichtenempfang und andere verwandte Betriebsfähigkeiten der RabbitMQ-Nachrichtenwarteschlange Die erforderlichen Freunde finden Sie unter

Das Beispiel in diesem Artikel beschreibt, wie Sie mit PHP auf die RabbitMQ-Nachrichtenwarteschlange zugreifen. Teilen Sie es als Referenz mit allen. Die Details lauten wie folgt:

Erweiterungsinstallation

PHP verwendet tatsächlich das AMQP-Protokoll, um auf RabbitMQ zuzugreifen, sodass wir es nur installieren müssen php- in der Epel-Bibliothek Das pecl-amqp-Paket kann

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

Börseneinrichtung

<?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();

sein

Warteschlangeneinrichtung

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

Warteschlangenbindung

<?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');

Nachricht gesendet

<?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");
}

Nachricht erhalten

<?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);
}

Verwandte Empfehlungen:

PHP Message Queuing Service

Das obige ist der detaillierte Inhalt vonSo greifen Sie mit PHP auf die RabbitMQ-Nachrichtenwarteschlange zu. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!