PHP操作のrabbitmqチュートリアル

1: Rabbitmq に接続し、新しい Exchange と Queue を作成します

amqp_manager.php

$conn_args = array('host' => 'localhost', 'port' => '5672', 'ログイン' => 'ゲスト', 'パスワード' => 'ゲスト');
$conn = new AMQPConnection($conn_args);
if ($conn->connect()) {
echo "ブローカー n への接続";
}
else {
echo "ブローカー n に接続できません ";
exit(0);
}

$channel = new AMQPChannel($conn);

$exchange = new AMQPExchange( $channel);
$exchange->setName('lizhifeng');
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->setFlags(AMQP_DURABLE | AMQP_AUTODELETE) ;
$exchange->declare () ; // lizhifeng という名前のルーターを宣言します

// queue1 という名前のキューを追加し、key1 をバインドします
$queue = new AMQPQueue($channel);
$queue->setName('queue1'); >setFlags(AMQP_DURABLE | AMQP_AUTODELETE);
$queue->declare();
$queue->bind('lizhifeng','key1')// queue2 Queue という名前のキューを追加し、key2 をバインドします
$queue = new AMQPQueue($channel);
$queue->setName('queue2');
$queue->setFlags(AMQP_DURABLE | AMQP_AUTODELETE);
$queue->declare( ; new AMQPQueue($) channel);
$queue->setName('queue1');
##$queue->setFlags(AMQP_DURABLE | AMQP_AUTODELETE); キュー queue1 のプロパティを繰り返し設定する必要はありません
##$queue-> (); ここで再度宣言する必要はありません
$queue->bind('lizhifeng','key3');


/*
// Exchange を削除します
$exchange = new AMQPExchange($channel);
$exchange ->setName('lizhifeng');
$exchange->delete();

// キューを削除します
$queue = new AMQPQueue($channel);
$queue->setName('queue1' );
$queue->delete();
$queue = new AMQPQueue($channel);
$queue->setName('queue2');
$queue->delete();
*/
?> ;

2: Rabbitmq に接続し、交換するメッセージを書き込みます

amqp_server.php

$routingkey='key1';

$conn_args = array('host' => 'localhost', 'port ' => '5672', 'ログイン' => 'ゲスト', 'パスワード' => 'ゲスト');

if ($conn-> )) {

}

echo "ブローカー n に接続できません ";
}

$channel = new AMQPChannel($conn);
$exchange = new AMQPExchange($channel);
$exchange->setName('lizhifeng');

for($i=0;$i{
if($routingkey=='key1' ; / / キュー queue1 へのルーティング
} }
else
$i ;
$メッセージ = json_encode($tmp);
if($exchange->publish($message,$routingkey))
{
print $routingkey." tokn";
}
else
{
print "errorn" ;
}
}

3: Rabbitmq を接続してメッセージを消費します

amqp_client.php

//RabbitMQ に接続します
$conn_args = array( 'host'=>'127.0.0.1' , 'port'=> '5672', 'login'=>'guest' , 'パスワード'=>'ゲスト','vhost' =>'/');
$conn = new AMQPConnection($conn_args);

if ($conn->connect()) {
echo "ブローカー n への接続";
}
else {
echo "ブローカー n に接続できません ";
exit();
}


$channel = new AMQPChannel($conn);
$q = new AMQPQueue( $channel);
$q->setName('queue1');
// これは新しいキューを作成しているのではなく、quene1 という名前のキューに接続しているだけです
// 私の理解では、キューは実際にはサーバー、メッセージは別のキューにルーティングされています。必要なのはメッセージを取得することだけです
while($messages = $q->get(AMQP_AUTOACK))
{
var_dump(json_decode($messages->getBody() 、 true ));
}

$q = new AMQPQueue($channel);
$q->setName('queue2');
while($messages = $q->get(AMQP_AUTOACK))
var_dump(json_decode( $messages->getBody(), true ));
}

$conn->disconnect()
?>