RabbitMQ消息持久化 设置Queue持久化 在RabbitMQ的Web界面创建Queue时,设置“durable”为“true”,如图3所示,设置成功后如图4所示。 图3 设置Queue持久化 图4 持久化的Queue 设置Message持久化 Queue设置为持久化后,通过设置“MessageProperties”为“PERSISTENTTEXTPLAIN”来向Queue发送持久消息。 以下示例演示在Java客户端设置Message持久化 import com.rabbitmq.client.MessageProperties; channel.basicPublish("", "myqueue",MessageProperties.PERSISTENTTEXTPLAIN, message.getBytes());