Java使用Rabbitmq惊喜队列queue和消息内容的本地持久化核心方法。(内容存储在硬盘)

_Channel.queueDeclare(queue, true, false, false, null);
_Channel.basicPublish(_ExchangeName, queue,MessageProperties.MINIMAL_PERSISTENT_BASIC, bodyBytes);

常常遇到rabbitmq service停止以后,重启,发现mq里的东西也丢失了。

_Channel.queueDeclare(queue, true, false, false, null);  //标红的参数表示要持久化queue。durable = true
_Channel.basicPublish(_ExchangeName, queue,MessageProperties.MINIMAL_PERSISTENT_BASIC, bodyBytes); //表示消息需要持久化到硬盘

好消息,

程序员专用早餐机。和掌柜说 ideaam,可以节省20元。 点击链接  或復·制这段描述¥k3MbbVKccMU¥后到淘♂寳♀

或者 淘宝扫码 支持下同行哈

原文地址:https://www.cnblogs.com/haoliansheng/p/6650504.html