向windows rabbitmq broker循环发送消息时出现问题

Question

>

我有这样一种情况，即通过RabbitMQ从一台机器向另一台机器循环发送大约15条消息。

在发送和接收计算机之间有NAT设置。

我将spring rabbitmq用于所有rabbitmq操作。

• 如果我在循环中向rabbitmq发送消息，如果它不能处理，它是否有可能拒绝某些消息？15条消息的总大小接近8MB.

即使在执行向RabbitMQ发送消息之后，我也没有看到任何异常。

发送机器码

@Override
    public boolean send(final Message message, final String routingKey)
            throws SinecnmsMessagingException {
        private RabbitTemplate rabbitTemplate = null;
        rabbitTemplate.send(routingKey, message);

    }

<rabbit:listener-container
            connection-factory="connectionFactory">
            <rabbit:listener ref="onMessageCommand"
                queue-names="TestQueue" />
        </rabbit:listener-container>
        <bean id="onMessageCommand"
            class="com.test.OnMessageListner">
            <property name="callBackObject" ref="callbackEvent" />
            <property name="template" ref="amqpTemplate" />
        </bean>

        <bean id="callbackEvent" class="com.test.SettingsListener"></bean>

Answer 1

这是否意味着publisher确认引入了概念，因为有时rabbitmq可能“拒绝/不接受”消息。通过publisher确认，我们可以知道rabbitmq broker是否接收了第一条消息，然后发送第二条消息。

我们能得出结论吗？

不，你不能；等待每次确认会减慢发布速度；确认的设计是为了让您发送一堆消息，然后等待确认。