java - 具有多线程的 RabbitMQ RPC 生产者

Question

如何在多线程环境下实现RPC调用？在此处的基本教程中:https://www.rabbitmq.com/tutorials/tutorial-six-java.html ，在多线程环境中，我看到两个问题:

-如果所有内容都在不同的线程中(包括构造函数)，我们为每个线程创建一个回复队列，我不认为这是一个好主意(不是？)

-如果只有 fibonacciRpc.call("4") 在不同的线程中，则回复队列的消费者可以消费错误的回复，而该回复的原始消费者将无限期地等待。

我暂时没有找到任何解决方案，但也许我不明白一些事情。

Answer 1

就我而言:channel.basicConsume(replyQueueName, true, new DefaultConsumer(channel) {} 导致内存中出现大量堆大小，只要我不删除 channel ，它就不会被清除。

根据互联网，您应该创建一个连接。每个线程创建 channel 并为每个 channel 创建单独的队列，并在读取响应后删除队列，如果不这样做，它将在同一 channel 中不断创建新队列。

但是新的 DefaultConsumer 正在创建大量堆内存。

看来要摆脱这个我必须删除 channel 。