rabbitmq 交换机模式一直连模式 direct

代码

<?php

require_once "./vendor/autoload.php";

use PhpAmqpLibConnectionAMQPStreamConnection;
use PhpAmqpLibMessageAMQPMessage;


$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的没收到消息

说明交换机转发到队列的时候,是根据路由来得,至于队列无所谓,只要路由交换机绑定了的相同的路由的队列都会转发

rabbitmq 交换机模式一 直连模式 direct

rabbitmq 交换机模式一直连模式 direct