连接：AMQPConnection 先看服务器现有的链接
rabbitmq
ctl.bat -q list_connections 显示为空 运行下面代码再查看链接 connect.
php
?php$connect = new AMQPConnection();$connect-connect();while (true) { } rabbitmqctl.bat -q list_connections 现在服务
连接：AMQPConnection
先看服务器现有的链接
rabbitmqctl.bat -q list_connections 显示为空
运行下面代码再查看链接
connect.php
rabbitmqctl.bat -q list_connections 现在服务器的链接
立即学习
“
PHP免费学习笔记（深入）
”；
信道：AMQPChannel
rabbitmqctl.bat -q list_channels 显示为空
运行代码channel.php
rabbitmqctl.bat -q list_channels 显示如下
交换机：Exchange
rabbitmqctl.bat -q list_exchanges 显示如下 下面是系统默认交换机
运行exchange.php
PHP 8.5.5
PHP 8.5.5 是 PHP 8.5 分支的维护更新版本。该版本延续了“小步快跑”的迭代逻辑，通过深度错误修复、底层性能微调以及安全加固，旨在为开发者提供一个更健壮、更高效的运行环境。该版本严格遵守语义化版本规范，不包含破坏性变更。
下载
rabbitmqctl.bat -q list_exchanges 显示如下
队列服务不重启那么这个exchange_name交换机就会一直存在
队列：AMQPQueue
rabbitmqctl.bat -q list_queues 显示如下
我们继续cmd运行 queue.php
再运行 rabbitmqctl.bat -q list_queues
绑定和路由键：bind & routing_key
rabbitmqctl.bat -q list_bindings 显示如下
我们运行如下php代码 bind.php
再次运行rabbitmqctl.bat -q list_bindings 显示如下
信息：Envelope
下面我们把上面的bind.php改一下变成一个接收端(
处理信息端
)
在dos中运行 如下
我们再写个发送端envelope.php
运行envelope.php后可以看见接收端收到了信息
connect();
while (true) {
}connect();
$channel = new AMQPChannel($connect);
while (true) {
}connect();
$channel = new AMQPChannel($connect);
$exchange = new AMQPExchange($channel);
$exchange->setName('exchange_name');
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->declare();
while (true) {
}connect();
$channel = new AMQPChannel($connect);
$exchange = new AMQPExchange($channel);
$exchange->setName('exchange_name');
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->declare();
$queue = new AMQPQueue($channel);
$queue->setName('queue_name');
$queue->declare();
while (true) {
}connect();
$channel = new AMQPChannel($connect);
$exchange = new AMQPExchange($channel);
$exchange->setName('exchange_name');
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->declare();
$queue = new AMQPQueue($channel);
$queue->setName('queue_name');
$queue->declare();
$queue->bind('exchange_name', 'routing_key');
while (true) {
}connect();
$channel = new AMQPChannel($connect);
$exchange = new AMQPExchange($channel);
$exchange->setName('exchange_name');
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->declare();
$queue = new AMQPQueue($channel);
$queue->setName('queue_name');
$queue->declare();
$queue->bind('exchange_name', 'routing_key');
while (true) {
$queue->consume('functionName');
}
function functionName($envelope,$queue) {
var_dump($envelope->getBody());
}connect();
$channel = new AMQPChannel($connect);
$exchange = new AMQPExchange($channel);
$exchange->setName('exchange_name');
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->declare();
$exchange->publish('hello world','routing_key');
$connect->disconnect();