rabbitmq之Message durability

消息持久性，通过consumer的ack机制，可以保证在message没有完全处理完之前，就出现consumer crash/ connection，channel close的场景下，message不会从queue里删掉，requeue，redeliver给下一个valId binding的consumer。

但是当broker server crash或者RabbitMQ server stopped了，通过什么样的机制能保证message不会丢失呢：

丢失的message分两类：一试exchange 正在转发的message，二是queue里保存的messages。

解决方法是同时保证message和queue的durable持久性。

1. declare queue为durable，通过

boolean durable = true;
channel.queueDeclare("hello", durable, false, false, null);

这样保证queue里面的message保存到disk，不会丢失，注意：对于已经定义好的queue，不能通过再declare来修改durable，rabbitmq会报错

RabbitMQ doesn't allow you to redefine an existing queuewith different parameters and will return an error to any programthat tries to do that. But there is a quick workaround - let's declarea queue with different name

2. publish message as persistent, 通过设置MessageProperties (which implements BasicProperties)to the value PERSISTENT_TEXT_PLAIN.

import com.rabbitmq.client.MessageProperties;
channel.basicPublish("", "task_queue",
            MessageProperties.PERSISTENT_TEXT_PLAIN,
            message.getBytes());

message persistent不能完全100%保证message不丢失，比如，message还没来得及保存到disk的情况，还有就是rabbitmq不会对每条收到的message立马保存到disk，它会先保存到cache，等达到一定数量的message时，一次性写入到disk，来减少disk的io操作。

为了达到更加安全的保证，可以通过publisher confirms.