1

だから私はこのチュートリアルに従っています:http://www.rabbitmq.com/tutorials/tutorial-six-java.html、しかし直接交換で動作させることはできません。

直接交換で動作するようにコードを変更して、誰かが私を助けてくれませんか。

私の目的: ユーザーは、送信先のマシンを選択できます。選択すると、そのマシンにバインドして、そのマシンに送信するだけです。しかし、キュー宣言を交換宣言に変​​更すると、機能していないようです。どんな助けでも大歓迎です!!!

ありがとう

4

1 に答える 1

0

RabbitMQ では、メッセージを取引所に公開するため、チュートリアルで表示されているコード:は、ルーティング キーを使用channel.basicPublish("", "rpc_queue", props, message.getBytes());して取引所にメッセージを送信することを意味します。これは、チュートリアル 1 で説明したデフォルトまたは anon 交換です。"""rpc_queue"

したがって、ダイレクト エクスチェンジにメッセージを送信する場合は、空のエクスチェンジ名を自分のエクスチェンジ名に変更するだけです。

では、なぜそのようにしたいのでしょうか。"rpc_queue"を宣言する代わりに、マシンごとにキューを宣言し、名前でそれらをアドレス指定できないのはなぜbasicPublishですか?

于 2014-06-26T13:00:21.777 に答える