LabbitMQ消息不会被侦听器按顺序累犯

Question

这些消息的大小不同。12条消息的总体大小接近8MB。

一旦这12条消息发送完毕，我最后也会向机器B发送“完整消息”。

机器B：

    <rabbit:listener-container
        connection-factory="connectionFactory">
        <rabbit:listener ref="onMessageCommand"
            queue-names="CommandQueue" />
    </rabbit:listener-container>
    <bean id="onMessageCommand"
        class="com.mypackage.command.messaging.OnMessageListner">
        <property name="callBackObject" ref="callbackDisEvent" />
        <property name="template" ref="amqpTemplate" />
    </bean>

    <bean id="callbackDisEvent" class="com.mypackage.command.OperationSettingsListener"></bean>

问题：有些时候，我观察到一个“发送完成”被机器B在一些设置之前重复。理想情况下，“发送完成”应该始终是机器B接收的最后一条消息。

我能知道这里有什么问题吗。

Answer 1

你能提供一些链接，让样例程序以正确的方式实现作用域操作吗。或者示例代码也足够了

我提供给您的链接有以下示例：

Collection<?> messages = getMessagesToSend();
Boolean result = this.template.invoke(t -> {
    messages.forEach(m -> t.convertAndSend(ROUTE, m));
    t.waitForConfirmsOrDie(10_000);
    return true;
});

您只需确保所有发送都在invoke调用的范围内执行...

Boolean result = this.template.invoke(t -> {
    ...
    t.send(...)
    ...
    t.send(...)
    ...
    return true;
}

this.template.invoke(t -> {
    ...
    t.send(...)
    ...
    t.send(...)
    ...
    return null;
}