如何用php amqplib实现消息队列

要使用 PHP 和 amqplib 实现消息队列，首先确保你已经安装了 RabbitMQ 服务器并运行在本地或远程服务器上

1. 安装 amqplib：

通过 Composer 安装 amqplib。在你的项目根目录下运行以下命令：

composer require php-amqplib/php-amqplib

2. 创建生产者（producer）：

生产者将消息发送到消息队列中。创建一个名为 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. 创建消费者（consumer）：

消费者从消息队列中接收并处理消息。创建一个名为 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. 运行生产者和消费者：

首先，运行消费者（consumer.php）以便它开始等待消息：

php consumer.php

然后，运行生产者（producer.php）以发送消息：

php producer.php

当生产者发送消息时，消费者应该会接收并显示消息。

这就是使用 PHP 和 amqplib 实现消息队列的基本方法。你可以根据需要扩展这些示例，例如添加更多的生产者和消费者，或使用不同的交换器和队列。