1

システム内のすべてのノードにブロードキャスト メッセージングを設定しようとしています。新しいノードがシステムに参加すると、他のすべての人にメッセージを発行して、そのエントリを発表します。私が設計した方法は、すべてのノードが独自のキューをバインドする交換が存在することです。新しいノードがシステムに参加するたびに、そのキューも交換にバインドし、メッセージを交換に公開します。すべてのノードがこのメッセージを受信し (それ自体を含む)、他のすべてのノード (このメッセージを除く) は「ack」メッセージを送信して、新しいノードがシステムで使用可能なノードを認識できるようにします。しかし、どういうわけか私はこれを機能させることができませんでした。ブロードキャスト メッセージがシステム内のすべてのノードに伝播されません。シンプルな 1 つのノードの公開と残りの消費が機能しています。しかし、同じノードのパブリッシングと消費は、どういうわけかどこかで台無しになっています。

上記のロジックとは別に、これを行う他の効率的な方法はありますか? または、上記を達成するためのrabbitmqの観点からの制限はありますか、それともコードにバグがあり、詳しく調べる必要がありますか?

4

2 に答える 2

0

ブロードキャスト メッセージのプロパティで識別したコールバック キューを使用して、RPC スタイルのメッセージを試しましたか? rabbitmq チュートリアルのように。

于 2013-09-17T14:52:04.967 に答える