<?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 = 'fff'; //交換機名
//$queueName = 'ttt'; //佇列名稱
$routingKey = 'rt'; //路由關鍵字(也可以省略)

$conn = new AMQPStreamConnection( //建立生產者與mq之間的連線
	$conf['host'], $conf['port'], $conf['user'], $conf['pwd'], $conf['vhost']
);
$channel = $conn->channel(); //在已連線基礎上建立生產者與mq之間的通道


$channel->exchange_declare($exchangeName, 'fanout', 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();

執行程式碼 php pub.php 檢視後臺 已經生成了 交換機 但是目前沒有設定路由繫結到交換機 手動建立幾個佇列

佇列 a b c

交換機繫結到這三個佇列,通過路由

rt rt rt1

進行推送,看結果是推送到三個佇列上還是兩個佇列上, 程式碼寫了route是rt

結果三個佇列都收到訊息了, 是不是說明廣播模式的只要綁定了佇列,不管路由什麼樣子都會轉發過去

$routingKey = 'rt1'; //路由關鍵字(也可以省略)
改下這個 路由 在執行一遍

php pub.php 發現 也是一樣 

$routingKey = ''; //路由關鍵字(也可以省略)
 

在執行一次 結果也是都轉發了

分發訊息到與之繫結的所有佇列，傳送訊息到交換器時會忽略routing key（路由），我們可以稱它為廣播訊息