RabbitMQ队列问题。 Message Listener 不消费前两条消息

Question

你好，我从应用程序 A 创建了 RabbitMQ 队列。我想从该队列获取消息，所以我使用此依赖项在 spring 启动应用程序中创建了消息侦听器：

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>

之后我做了这个场景： 1.启动spring启动应用 2.发送消息到队列

问题是前两条消息没有被监听器监听。所以这就是为什么我只在 Java 中创建一个消息侦听器，但我遇到了同样的问题。在 RabbitMQ 管理中我可以看到消息已经发布并且没有被消费...... 我尝试了许多不同的配置，但没有一个成功。当我手动创建队列时，一切正常。所以我怀疑应用程序 A 没有正确创建队列或没有使用某些参数（即使在 RabbitMQ 管理器中，Args 策略没有停留在队列名称附近）

成功消费消息的消息属性：这些是成功消费消息的消息属性：

MessageProperties [headers={}, correlationId= TODO_requestID, replyTo=ME, contentType=application/json, contentLength=0, redelivered=false, receivedExchange=me-exchange, receivedRoutingKey=from-me, deliveryTag=1, consumerTag=amq.ctag-vPDSoiCHmWcb0v0NrINbIg, consumerQueue=from-me])

Answer 1

到RabbitMQ Mannagment打开队列，看看是否还有其他消费者。也许其他一些消费者正在收集前两条消息。

我遇到过类似的问题..

RabbitMQ队列问题。 Message Listener 不消费前两条消息

RabbitMQ queue problem. Message Listener does not consume first two messages

java

spring-boot

rabbitmq

spring-amqp