amqp 相关问题

我在broker.xml中定义了一个地址和一个队列，如下所示： ... 假我有一个地址和一个队列，在broker.xml中定义如下： <address-settings> ... <auto-create-queues>false</auto-create-queues> <auto-create-addresses>false</auto-create-addresses> </address-settings> <addresses> <address name="news.world"> <multicast> <queue name="america.sport"/> </multicast> </address> ... 我旋转两个消费者（不同的会话/连接）来监听 news.world::america.sport 并向其发送消息。但只有一个消费者收到该消息。通过自动创建的地址/队列，每个消费者都会获得自己的队列（以 uuid 命名），并且消息似乎被克隆到每个消费者，因此两者都会收到它。我想避免由于存储限制而进行消息克隆，并认为通过使用非自动创建的地址/队列来实现这一点。我想知道为什么单个“硬编码”多播队列实际上表现得像任播队列。根据您的描述，我认为一切都按设计进行。由于您有 2 个消费者共享同一个队列（即地址上的america.sportnews.world），他们当然会共享相同的消息。换句话说，队列中的消息将分发给一个消费者或另一个消费者，而不是同时分发给两者。这符合队列的基本语义。队列是多播这一事实并不会改变队列中的消息分发给消费者的方式。多播是一种路由类型，因此仅影响消息从地址路由到队列的方式。此外，当发送到某个地址的消息被放置在每个多播队列上时，您观察到的消息“克隆”实际上只有很少的开销。您似乎认为每个队列上的消息都是独立存储的，就好像发送到同一地址上的 100 个多播队列的一条消息被存储了 100 次一样。事实并非如此。实际的消息（即正文、标头和属性）仅存储一次，然后每个队列都会获得对该消息的“引用”。为了不浪费资源（即内存或磁盘），该引用的开销故意非常小。如果您有“存储限制”，那么在单个多播队列上使用多个使用者并不是解决它们的方法。

amqp activemq-artemis

回答 1 投票 0

通过 AMQP 1.0 协议连接到 RabbitMQ 持久队列失败 - Protonj2

我正在尝试连接我的 AMQP 1.0 使用者（使用 Apache ProtonJ2 库）。但我的连接失败并出现以下错误 org.apache.qpid.protonj2.client.exceptions.ClientSessionRemotelyClosedExcep...

rabbitmq amqp qpid qpid-proton

回答 1 投票 0

AMQP RabbitMQ 消费者被杀死且未重新启动

我正在尝试解决 Springboot RabbitMQ AMQP 场景中的一个棘手问题。我有多个队列，并发度设置为 2：应用程序正常启动并消费消息。我有3个

java spring-boot rabbitmq amqp

回答 1 投票 0

Golang：在不知道 RoutingKey 的情况下删除 AMQP 绑定

我有一个应用程序，其中包含要为其创建绑定的“ID”列表。例如：输入：1,2,3,4 创建的绑定（从交换 foo 到队列栏）： foo -> 1 -> 酒吧 [..] foo -> 4 -> ...