rabbitmq - 在 RabbitMQ 中将消息保存到磁盘，关机后加载

Question

我如何配置将所有插入的消息保存到插入到 RabbitMQ 的磁盘中以防 RabbitMQ 服务器在服务器启动以从磁盘加载消息后停机？

Answer 1

您需要将队列设置为持久，并将消息设置为持久。

channel.queueDeclare(<queueName>, true,true,true,null);


channel.basicPublish(<exchangeName>, <routingKey>, MessageProperties.PERSISTENT_BASIC, msg.toBytes());