0

我已经使用 RabbitMQ 和 NodeJs 开发了一个 PHP 应用程序。然后我在同一台服务器上制作了该应用程序的副本。问题是在任何应用程序中发送任何消息,另一个应用程序也在列表中,所以我希望每个应用程序都在隔离通道上工作。

发送.php

$channel = $connection->channel();
$channel->exchange_declare($job, 'fanout', false, false, false);
$msg = new AMQPMessage($jsonData, array( 'delivery_mode' => 2 ));
$channel->basic_publish($msg, $job);

接收.php

$channel = $connection->channel();
$channel->exchange_declare($job, 'fanout', false, false, false);
list($queue_name,, ) = $channel->queue_declare("", false, false, true, false);
$channel->queue_bind($queue_name, $job);
4

0 回答 0