程式碼

<?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的沒收到訊息 

說明交換機轉發到佇列的時候,是根據路由來得,至於佇列無所謂,只要路由交換機綁定了的相同的路由的佇列都會轉發