Java使用RabbitMQ（四）–消息持久化

消息持久化
消息确认，保证了消费者die时，消息不丢失。
而消息持久化，则是为了保证RabbitMQ 怠机时，消息不丢失。

消息持久化需要以下操作：

1
2
3
1boolean durable = true;

2channel.queueDeclare("hello", durable, false, false, null);

3

需要注意的是，RabbitMQ不允许修改已经定义过的队列的属性，所以队列已经被声明过的话，就不能再修改它的持久化策略。

以上操作是保证队列 是持久化的，但是重启rabbitMQ后会发现，消息丢失了，队列还在。所以还需要对消息持久化。

1
2
1channel.basicPublish("",queueName, MessageProperties.PERSISTENT_TEXT_PLAIN,(i+++message).getBytes("utf-8"));

2

这样即使rabbitMQ 在运行时down了，也不会丢失消息。

生产消息放到 queue声明必须和消费方的queue声明一致，不然消费方获取消息时会报错。