java - 消息仅发布到 RabbitMQ Fanout 交换中的一个队列 (java)

Question

所以，我有 2 个队列，outboundEmailQueue 和 storeEmailQueue:

<rabbit:queue name="outboundEmailQueue"/>
<rabbit:queue name="storeEmailQueue"/>

绑定(bind)到名为integrationExchange的扇出交换:

<rabbit:fanout-exchange name="integrationExchange" auto-declare="true">
    <rabbit:bindings>
        <rabbit:binding queue="outboundEmailQueue"/>
        <rabbit:binding queue="storeEmailQueue"/>
    </rabbit:bindings>
</rabbit:fanout-exchange>

模板:

<rabbit:template id="integrationRabbitTemplate"
    connection-factory="connectionFactory" exchange="integrationExchange"
    message-converter="jsonMessageConverter" return-callback="returnCallback"
    confirm-callback="confirmCallback" />

我如何向交易所发送对象:

integrationRabbitTemplate.convertAndSend("integrationExchange", "", outboundEmail);

但是，消息仅发布到 storeEmailQueue:

我的配置有什么问题吗？为什么消息没有排队到 outboundEmailQueue？

Answer 1

从屏幕截图来看，您的配置似乎没问题，并且消息已到达两个队列。但每个队列上的consumer配置并不相同:

• storeEmailQueue 已配置消费者确认
• outboundEmailQueue 已配置自动确认

如果您有疑问:

• 检查交换器或队列的绑定(bind)部分，以确认链接是否存在(但从您的屏幕截图来看，似乎很可能存在)
• 停止使用者并将消息推送到交换器，您应该会看到两个队列上的消息就绪计数(和总计数)都增加。