首页 / PHP / php amqp 消息队列 RabbitMQ 基本概念(二)

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

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了php amqp 消息队列 RabbitMQ 基本概念(二)，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2914字，纯文字阅读大概需要5分钟。

内容图文

连接：AMQPConnection

先看服务器现有的链接

rabbitmqctl.bat -q list_connections 显示为空



运行下面代码再查看链接

connect.php

<?php

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

while (true) {
    
}


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



信道：AMQPChannel

rabbitmqctl.bat -q list_channels 显示为空


运行代码channel.php

<?php

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

$channel = new AMQPChannel($connect);

while (true) {
    
}

rabbitmqctl.bat -q list_channels 显示如下


交换机：Exchange

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


运行exchange.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();

while (true) {
    
}

rabbitmqctl.bat -q list_exchanges 显示如下


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


队列：AMQPQueue

rabbitmqctl.bat -q list_queues 显示如下


我们继续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



绑定和路由键：bind & routing_key

rabbitmqctl.bat -q list_bindings 显示如下


我们运行如下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 显示如下


信息：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中运行 如下


我们再写个发送端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后可以看见接收端收到了信息


原文：http://blog.csdn.net/starparker/article/details/19159931

内容总结

以上是互联网集市为您收集整理的php amqp 消息队列 RabbitMQ 基本概念(二)全部内容，希望文章能够帮你解决php amqp 消息队列 RabbitMQ 基本概念(二)所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1269090.html

来源：【匿名】