php amqp 消息队列 RabbitMQ 基本概念(二)-php手册-PHP中文网

php amqp 消息队列 RabbitMQ 基本概念(二)

php中文网

发布： 2016-06-06 19:43:57

原创

1358人浏览过

连接：AMQPConnection 先看服务器现有的链接 rabbitmqctl.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 显示为空

php amqp 消息队列 RabbitMQ 基本概念(二)

运行下面代码再查看链接

connect.php

<?php

$connect = new AMQPConnection();
$connect->connect();

while (true) {
    
}

登录后复制

php amqp 消息队列 RabbitMQ 基本概念(二)

rabbitmqctl.bat -q list_connections 现在服务器的链接

立即学习“PHP免费学习笔记（深入）”；

php amqp 消息队列 RabbitMQ 基本概念(二)

信道：AMQPChannel

rabbitmqctl.bat -q list_channels 显示为空

php amqp 消息队列 RabbitMQ 基本概念(二)

运行代码channel.php

<?php

$connect = new AMQPConnection();
$connect->connect();

$channel = new AMQPChannel($connect);

while (true) {
    
}

登录后复制

rabbitmqctl.bat -q list_channels 显示如下

php amqp 消息队列 RabbitMQ 基本概念(二)

交换机：Exchange

rabbitmqctl.bat -q list_exchanges 显示如下下面是系统默认交换机

php amqp 消息队列 RabbitMQ 基本概念(二)

运行exchange.php

火山写作

字节跳动推出的中英文AI写作、语法纠错、智能润色工具，是一款集成创作、润色、纠错、改写、翻译等能力的中英文 AI 写作助手。

166

查看详情

<?php

$connect = new AMQPConnection();
$connect->connect();

$channel = new AMQPChannel($connect);

$exchange = new AMQPExchange($channel);
$exchange->setName('exchange_name');
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->declare();

while (true) {
    
}

登录后复制

rabbitmqctl.bat -q list_exchanges 显示如下

php amqp 消息队列 RabbitMQ 基本概念(二)

队列服务不重启那么这个exchange_name交换机就会一直存在

队列：AMQPQueue

rabbitmqctl.bat -q list_queues 显示如下

php amqp 消息队列 RabbitMQ 基本概念(二)

我们继续cmd运行 queue.php

<?php

$connect = new AMQPConnection();
$connect->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) {
    
}

登录后复制

再运行 rabbitmqctl.bat -q list_queues

php amqp 消息队列 RabbitMQ 基本概念(二)

绑定和路由键：bind & routing_key

rabbitmqctl.bat -q list_bindings 显示如下

php amqp 消息队列 RabbitMQ 基本概念(二)

我们运行如下php代码 bind.php

<?php

$connect = new AMQPConnection();
$connect->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) {
    
}

登录后复制

再次运行rabbitmqctl.bat -q list_bindings 显示如下

php amqp 消息队列 RabbitMQ 基本概念(二)

信息：Envelope

下面我们把上面的bind.php改一下变成一个接收端(处理信息端)

<?php

$connect = new AMQPConnection();
$connect->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());
}

登录后复制

在dos中运行如下

php amqp 消息队列 RabbitMQ 基本概念(二)

我们再写个发送端envelope.php

<?php

$connect = new AMQPConnection();
$connect->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();

登录后复制

运行envelope.php后可以看见接收端收到了信息

php amqp 消息队列 RabbitMQ 基本概念(二)