时间戳

首页 > 解决方案 > nodejs RabbitMQ新消费者未收到消息

node.js - nodejs RabbitMQ新消费者未收到消息

问题描述

我使用 amqplib 通过 nodejs ( v14.16.1 ) 连接到 RabbitMQ

我用这个选项创建频道

channel.assertQueue(davari_config.rabbitmq.queue_name, {
  durable: true,
  autoDelete: false,
  autoAck: false,
  prefetchCount: 20
});

我从发布者向这个频道发送了 10000 条消息

我从一开始就有 6 个消费者

我停止发布新消息，然后我开始运行新的消费者

但是新的消费者没有收到消息

我尝试更改选项 ack:true 和 queueMode:'lazy' ， noAck: true 但不起作用

我如何强制 rabbtmq 也将旧消息发送给新消费者？

标签： node.jsrabbitmq

解决方案

推荐阅读