php rabbitmq

<?php

// 引入 RabbitMQ 的 PHP 客户端库
require_once __DIR__ . '/vendor/autoload.php';

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

// 创建到 RabbitMQ 服务器的连接
$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();

// 声明一个队列
$channel->queue_declare('hello', false, false, false, false);

// 发送消息到队列
$msg = new AMQPMessage('Hello World!');
$channel->basic_publish($msg, '', 'hello');

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

// 关闭通道和连接
$channel->close();
$connection->close();

解释说明：

1. 引入 RabbitMQ 的 PHP 客户端库：通过 require_once 引入了 RabbitMQ 的 PHP 客户端库。
2. 创建连接：使用 AMQPStreamConnection 类创建到 RabbitMQ 服务器的连接，参数分别为主机名、端口、用户名和密码。
3. 声明队列：使用 queue_declare 方法声明一个名为 hello 的队列。如果队列不存在，则会创建它。
4. 发送消息：创建一个 AMQPMessage 对象，并使用 basic_publish 方法将消息发布到指定的队列中。
5. 关闭连接：最后关闭通道和连接以释放资源。

这个示例展示了如何使用 PHP 向 RabbitMQ 队列发送一条简单的消息。