RabbitMQの公式Webサイトでは、クライアントごとに1つのコールバックキューを作成してRPCパターンを実装することを推奨しています。
次のようにクライアントのサンプルコードは(プロデューサー)は次のようになります。SpringブートによるRabbit MQ(Aysnchronous)RPCの実装
public RPCClient() throws Exception {
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
connection = factory.newConnection();
channel = connection.createChannel();
replyQueueName = channel.queueDeclare().getQueue();
consumer = new QueueingConsumer(channel);
channel.basicConsume(replyQueueName, true, consumer);
をしかし、私はすべての例は単なる送受信順次(または言う、春ブーツ-AMQPでこれを実装する任意の記事を見つけることができません同期的に)。
ただ1つの要求キューと応答キューで非同期メッセージ通信を実現する方法を知っています。
p.s.私も "AsyncRabbitTemplete"を試しましたが、うまくいきませんでした。