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

代码

<?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();

我把队列声明注释目前代码只是声明交换机发送消息

目前交换机和队列都为空

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

执行代码

[root@localhost mq]# php pub.php
[root@localhost mq]#

查看结果

[root@localhost mq]# php pub.php
[root@localhost mq]#

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

执行后并没有看到队列,因为我都没声明用代码建立,所以需要手动建立为了测试才这样

建立队列 a b c

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

点击交换机把这三个绑定路由

a 绑定路由r

b 绑定路由r

c 绑定路由rr

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

改下代码

$routingKey = 'r'; //路由关键字(也可以省略)

执行代码 发现结果 跟代码路由一样的r都收到消息了,路由rr的没收到消息

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

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

交换机

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

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