Rabbitmq 队列为空，尽管队列中有消息

Question

我正在从 Java Spring Boot 应用程序向消费者（即 Python 应用程序）发送消息。

一切正常，除了当我输入命令时rabbitmqctl list_queues 它显示这video_queue 0意味着队列中没有消息。

Consumer正在接收消息并进行一些漫长的过程；因此，如果我连续发送多条消息，应该有一些消息在队列中等待。我对吗？

制作人：

@Component

public class VideoProducer {

    private Logger logger = LoggerFactory.getLogger(VideoProducer.class);

    private final static String BROKER_EXCHANGE_NAME = "video_exchange";

    private final static String ROUTING_KEY = "video_routing_key";

    @Autowired

    private RabbitTemplate rabbitTemplate;

    @Autowired

    private VideoService videoService;

    @Autowired

    private Gson gson;

    public void produceVideo(VideoDTO video) {

            rabbitTemplate.convertAndSend(BROKER_EXCHANGE_NAME, ROUTING_KEY, gson.toJson(video));

        }

    }

}

消费者

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))

channelConsumer = connection.channel()

# Video Consumer Settings

channelConsumer.exchange_declare(exchange='video_exchange',

                                 exchange_type='direct')

channelConsumer.queue_declare(queue="video_queue")

channelConsumer.queue_bind(queue="video_queue",

                           exchange="video_exchange",

                           routing_key="video_routing_key")

# Consumer Listener

def callback(ch, method, properties, body): 

   video_dto = eval(json.loads(body))  

   ##Something long process here

   print("Done..  ")    

channelConsumer.basic_consume(queue='video_queue',

                              auto_ack=True,

                              on_message_callback=callback)

print(' [*] Waiting for messages. To exit press CTRL+C')

channelConsumer.start_consuming()

在哪里可以看到我声明的队列上的消息？因为虽然我知道队列中有消息，但我无法使用上述命令看到它们。

我也在使用 RabbitMQ 管理门户。

Answer 1

您可以使用RMQ管理控制台查看RMQ的消息和其他信息。消费者可能会消费多个消息并将它们放入内部队列中。为避免这种情况，请将 QOS 设置为 1，并将 ack required 设置为 true。

Answer 2

您可以从访问 localhost:15672 的rabbitMQ 管理端口检查和管理队列，一旦任何接收者收到来自队列的消息，它将自动从队列中删除。因此，如果您想查看您的消息，您最好通过管理门户进行检查，一旦任何收件人收到这些消息，这些消息就会被删除。