117笔记问答要使用 PHP 和 amqplib 实现消息队列，首先确保你已经安装了 RabbitMQ 服务器并运行在本地或远程服务器上
- 安装 amqplib：
通过 Composer 安装 amqplib。在你的项目根目录下运行以下命令：
composer require php-amqplib/php-amqplib
- 创建生产者（producer）：
生产者将消息发送到消息队列中。创建一个名为 producer.php 的文件，然后添加以下代码：
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();
- 创建消费者（consumer）：
消费者从消息队列中接收并处理消息。创建一个名为 consumer.php 的文件，然后添加以下代码：
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();
- 运行生产者和消费者：
首先，运行消费者（consumer.php）以便它开始等待消息：
php consumer.php
然后，运行生产者（producer.php）以发送消息：
php producer.php
当生产者发送消息时，消费者应该会接收并显示消息。
这就是使用 PHP 和 amqplib 实现消息队列的基本方法。你可以根据需要扩展这些示例，例如添加更多的生产者和消费者，或使用不同的交换器和队列。