RabbitMQ消息持久化

为什么需要消息持久化？

之前在消息队列RabbitMQ之基本消息模型中曾经谈过RabbitMQ的手动Ack机制，手动Ack机制可以很好的保证消息被正常消费，即使程序发生异常，消息依然可以保存在消息队列中。

但是如果是消费者还没有消费数据，但是消息队列发生了宕机，导致消息队列中的消息丢失，那又该怎么办呢？
于是就衍生出来了RabbitMQ的持久化机制。

怎么设置消息持久化？

消息队列进行持久化，前提是交换机和队列都需要进行持久化设置。

JavaAPI设置持久化属性

通道声明交换机的时候，最后一个属性为是否持久化，属性值为true即可设置交换机持久化。

1
2

//声明交换机exchange，指定类型为fanout，BuiltinExchangeType是一个枚举类，最后一个参数为指定交换机的持久化属性
channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.TOPIC,true);

通道声明队列的时候，第二个属性为是否持久化，属性值为true即可设置队列持久化。

1
2

 //使用通道声明一个队列，参数分别为：队列名称，是否持久化，是否为排他队列，是否自动删除，其他属性
channel.queueDeclare(QUEUE_NAME, true, false, false, null);

生产者发送消息的时候，第三个属性为其他属性，可以选择值MessageProperties.PERSISTENT_TEXT_PLAIN来进行消息持久化。

MessageProperties.PERSISTENT_TEXT_PLAIN属性的意思是：消息属性：普通持久化文本。

1
2

//使用通道发送消息到交换机，参数分别为：交换机名称，路由Key，其他属性，消息正文
channel.basicPublish(EXCHANGE_NAME, "insert.user.data", MessageProperties.PERSISTENT_TEXT_PLAIN, insert_message.getBytes());