### 如何避免消息丢失？ ``` 1.消费者ACK机制 2.持久化 ``` ### 交换机持久化 ``` channel.exchangeDeclare(EXCHANGE_NAME, "topic", true); ``` ### 队列持久化 ``` channel.queueDeclare(QUEUE_NAME, true, false, false, null); ``` ### 消息持久化 ``` channel.basicPublish(EXCHANGE_NAME, "item.insert", MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes()); ```