如何用php amqplib實現(xiàn)消息隊列

要使用 PHP 和 amqplib 實現(xiàn)消息隊列，首先確保你已經(jīng)安裝了 RabbitMQ 服務(wù)器并運行在本地或遠程服務(wù)器上

1. 安裝 amqplib：

通過 Composer 安裝 amqplib。在你的項目根目錄下運行以下命令：

composer require php-amqplib/php-amqplib

2. 創(chuàng)建生產(chǎn)者（producer）：

生產(chǎn)者將消息發(fā)送到消息隊列中。創(chuàng)建一個名為 producer.php 的文件，然后添加以下代碼：

<?php
require_once __DIR__ . '/vendor/autoload.php';

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

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

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

$msg = new AMQPMessage('Hello World!');
$channel->basic_publish($msg, '', 'hello');

echo " [x] Sent 'Hello World!'\n";

$channel->close();
$connection->close();

3. 創(chuàng)建消費者（consumer）：

消費者從消息隊列中接收并處理消息。創(chuàng)建一個名為 consumer.php 的文件，然后添加以下代碼：

<?php
require_once __DIR__ . '/vendor/autoload.php';

use PhpAmqpLib\Connection\AMQPStreamConnection;

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

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

echo " [*] Waiting for messages. To exit press CTRL+C\n";

$callback = function ($msg) {
    echo ' [x] Received ', $msg->body, "\n";
};

$channel->basic_consume('hello', '', false, true, false, false, $callback);

while ($channel->is_consuming()) {
    $channel->wait();
}

$channel->close();
$connection->close();

4. 運行生產(chǎn)者和消費者：

首先，運行消費者（consumer.php）以便它開始等待消息：

php consumer.php

然后，運行生產(chǎn)者（producer.php）以發(fā)送消息：

php producer.php

當(dāng)生產(chǎn)者發(fā)送消息時，消費者應(yīng)該會接收并顯示消息。

這就是使用 PHP 和 amqplib 實現(xiàn)消息隊列的基本方法。你可以根據(jù)需要擴展這些示例，例如添加更多的生產(chǎn)者和消費者，或使用不同的交換器和隊列。