1

我正在使用 RabbitMQ 来存储和检索数据。我提到了这篇文章。我已将durable标志设置为 true 并将noAck标志设置为 false（即使在消费后我也需要将消息存储在队列中）。

我创建了这些场景：

我在消费者关闭状态（非活动）的情况下更新了 3 次库存数据。然后我激活了消费者。它消耗了队列中的所有三个消息。[效果很好。]

现在我再次产生了三条消息（消费者再次处于非活动状态），然后我关闭了 rabbitmq 服务器。当我重新启动服务器并激活消费者时。它似乎没有消耗数据（队列中的消息是否已丢失？）

消费者 ：

connection.createChannel(function (error1, channel) {
if (error1) {
  throw error1;
}
var queue = "updateStock2";

channel.assertQueue(queue, {
  durable: true,
});

console.log(
  " [*] Waiting for stockData messages in %s. To exit press CTRL+C",
  queue
);

channel.consume(
  queue,
  function (data) {
    stock = JSON.parse(data.content.toString());
    console.log(" [x] Received Stock:", stock.name + " : " + stock.value);
  },
  {
    noAck: false,
  }
);

制片人：

  connection.createChannel(function (error1, channel) {
  if (error1) {
    throw error1;
  }

  var queue = "updateStock2";

  channel.assertQueue(queue, {
    durable: true,
  });
  channel.sendToQueue(queue, Buffer.from(data));

  console.log(" [x] Sent %s", data);
});
setTimeout(function () {
  connection.close();
  //process.exit(0);
}, 500);});

他们不是很执着吗？如果服务器崩溃，队列中的所有消息都会永远消失？

服务器崩溃时如何检索队列中的数据？

提前致谢。

4

1 回答 1

0

为什么你的消息丢失了？

{persistent: true}很遗憾的说，你发消息的时候没有声明。检查https://www.rabbitmq.com/tutorials/tutorial-two-javascript.html，所以你应该使用channel.sendToQueue(queue, Buffer.from(msg), {persistent: true});

他们不是很执着吗？

持久队列将在节点启动时恢复，包括其中发布为持久的消息。作为瞬态发布的消息将在恢复期间被丢弃，即使它们存储在持久队列中。

哪个中间件可能更适合您？

如果您想要一个即使被消费者消费也可以持久保存消息的中间件，您可能需要kafka

于 2020-09-27T11:33:14.470 回答