發布 ／ 訂閱模式可以理解為廣播模式：即exchange會將消息轉發到所有綁定到這個exchange的隊列上。針對這種廣播模式，RabbitMQ增加了exchange Type的選項 AMQP_EX_TYPE_FANOUT，這種類型在發送消息，queue bind時，都將忽略route key，也就是說不需要設置 route key。 應用的場景，比方說用戶注冊（注銷，更改姓名等）新浪，同時需要開通微博、博客、郵箱等等，如果不采用隊列，按照常規的線性處理，可能注冊用戶會特別的慢，因為在注冊的時候，需要調各種其他服務器接口，如果服務很多的話，可能客戶端就超時了。如果采用普通的隊列，可能在處理上也會特別的慢（不是最佳方案）。如果采用訂閱模式，則是最優的選擇。 ~~~ fanoutsend.php <?php $exchangeName = 'logs'; $message = empty($argv[1]) ? 'info:Hello World!' : ' '.$argv[1]; $connection = new AMQPConnection(array('host' => '127.0.0.1', 'port' => '5672', 'vhost' => '/', 'login' => 'guest', 'password' => 'guest')); $connection->connect() or die("Cannot connect to the broker!\n"); $channel = new AMQPChannel($connection); $exchange = new AMQPExchange($channel); $exchange->setName($exchangeName); $exchange->setType(AMQP_EX_TYPE_FANOUT); $exchange->declare(); $exchange->publish($message, ''); var_dump("[x] Sent $message"); $connection->disconnect(); fanoutreceive.php <?php $exchangeName = 'logs'; $connection = new AMQPConnection(array('host' => '127.0.0.1', 'port' => '5672', 'vhost' => '/', 'login' => 'guest', 'password' => 'guest')); $connection->connect() or die("Cannot connect to the broker!\n"); $channel = new AMQPChannel($connection); $exchange = new AMQPExchange($channel); $exchange->setName($exchangeName); $exchange->setType(AMQP_EX_TYPE_FANOUT); $exchange->declare(); $queue = new AMQPQueue($channel); $queue->setFlags(AMQP_EXCLUSIVE); $queue->declare(); $queue->bind($exchangeName, ''); var_dump('[*] Waiting for messages. To exit press CTRL+C'); while (TRUE) { $queue->consume('callback'); } $connection->disconnect(); function callback($envelope, $queue) { $msg = $envelope->getBody(); var_dump(" [x] Received:" . $msg); $queue->nack($envelope->getDeliveryTag()); } fanoutreceive.php 和 fanoutreceive1.php同時能收到訂閱的消息 ~~~