rabbitmq 交换机模式一 直连模式 direct
2024-10-19 23:29:51
代码
<?php require_once "./vendor/autoload.php"; use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage; $conf = [
'host' => '192.168.33.50',
'port' => 5672,
'user' => 'admin',
'pwd' => 'password',
'vhost' => '/',
]; $exchangeName = 'ttt'; //交换机名
//$queueName = 'ttt'; //队列名称
$routingKey = 'ttt'; //路由关键字(也可以省略) $conn = new AMQPStreamConnection( //建立生产者与mq之间的连接
$conf['host'], $conf['port'], $conf['user'], $conf['pwd'], $conf['vhost']
);
$channel = $conn->channel(); //在已连接基础上建立生产者与mq之间的通道 $channel->exchange_declare($exchangeName, 'direct', false, true, false); //声明初始化交换机
//$channel->queue_declare($queueName, false, true, false, false); //声明初始化一条队列
//$channel->queue_bind($queueName, $exchangeName, $routingKey); //将队列与某个交换机进行绑定,并使用路由关键字 $msgBody = json_encode(["name" => "iGoo", "age" => 22]);
$msg = new AMQPMessage($msgBody, ['content_type' => 'text/plain', 'delivery_mode' => 2]); //生成消息
$r = $channel->basic_publish($msg, $exchangeName, $routingKey); //推送消息到某个交换机
$channel->close();
$conn->close();
我把队列声明注释 目前代码只是声明交换机 发送消息
目前交换机 和队列都为空
执行代码
[root@localhost mq]# php pub.php
[root@localhost mq]#
查看结果
[root@localhost mq]# php pub.php
[root@localhost mq]#
执行后并没有看到队列,因为我都没声明用代码 建立,所以需要手动建立 为了测试才这样
建立队列 a b c
点击交换机 把这三个绑定路由
a 绑定路由r
b 绑定路由r
c 绑定路由rr
改下代码
$routingKey = 'r'; //路由关键字(也可以省略)
执行代码 发现结果 跟代码路由一样的r都收到消息了,路由rr的没收到消息
说明交换机转发到队列的时候,是根据路由来得,至于队列无所谓,只要路由交换机绑定了的相同的路由的队列都会转发
最新文章
- 从源码看Azkaban作业流下发过程
- Atitit.http代理的实现 代码java php c# python
- ios 弹出不同的键盘
- 如何获取hibernate代理类代理的实际对象实例?
- Kafka剖析(一):Kafka背景及架构介绍
- 一种javascript链式多重继承的方式(__proto__原型链)
- ADO.NET常用对象的基础概念强化
- 2016 系统设计第一期 (档案一)MVC ajax 获取json数据
- HTML_常见命令学习笔记
- centos乱码问题解决
- show_space.sql.txt
- Coursera-AndrewNg(吴恩达)机器学习笔记——第二周
- kubernetes-整体概述和架构
- Task 异步编程测试案例及基础应用说明
- Dictionary CPU 100%
- 归并排序(Merging Sort)
- .NET Core 常用加密和Hash工具NETCore.Encrypt
- Unity3D-RPG项目实战(4):角色性能測试
- Python之数据库模块安装 MySQLdb
- Easing圆环动画