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￥后到淘♂寳♀

或者 淘寶掃碼 支持下同行哈