0

だから私はPHPでRabbitMqを使用しています。RabbitMqと2つのVms（ubuntuサーバー）を含むサーバーがあります。詳細については、これが私のコードです。

RabbitmQ サーバー: send.php:

require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPConnection;
use PhpAmqpLib\Message\AMQPMessage;

//here when i use localhost i don't get error
$connection = new AMQPConnection('192.168.33.10', 5672, 'root', 'root');
$channel = $connection->channel();


$channel->queue_declare('hello', false, false, false, false);

$msg = new AMQPMessage('Hello World PI');
$channel->basic_publish($msg, '', 'hello');

echo " [x] Sent 'Hello World!'\n";

$channel->close();
$connection->close();

これは最初の Vm のコードです: recive.php :

require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPConnection;

$connection = new AMQPConnection('192.168.33.12', 5672, 'root', 'root');
$channel = $connection->channel();


$channel->queue_declare('hello', false, false, false, false);

echo ' [*] Waiting for messages. To exit press CTRL+C', "\n";

$callback = function($msg) {
  echo " [x] Received ", $msg->body, "\n";
};

$channel->basic_consume('hello', '', false, true, false, false, $callback);

while(count($channel->callbacks)) {
    $channel->wait();
}

$channel->close();
$connection->close();

NB: 私の RobbitmQ では、localhost を使用するとエラーは発生しませんが、localhost を使用すると、Vm の制御を制御できず、メッセージが送信されます

4

2 に答える 2

0

必要な IP をルーティング キーに追加して利用しますtopic(またはdirect)電力を交換します。IP をメッセージ ヘッダーに追加し、headers交換ロジックでリレーすることもできます。

于 2014-03-20T09:37:17.310 に答える
0

@ zaq178miami のソリューションは確かに機能しますが、専用キューを使用することもできます。これにより、キューが単一の接続を排他的にします。

于 2014-03-20T15:48:56.850 に答える