RabbitMQ 交换机、队列、消息持久化

• 交换器持久化
  Durable：是否持久化参数设为True即可 channel.exchangeDeclare(exchangeName, type, true);
• 队列持久化 channel.queueDeclare("A",true,false,false,null).getQueue();
• 消息持久化

  • 在之前，消息分发给consumer后立即就会被标记为已消费，这时候如果consumber接到了一个消息但是还没有来的及处理就异常退出,那么这个消息的状态是已被消费的，于是就会造成消息丢失的问题。

      channel.basic_publish('',
                  'hello',
                  'hello',
                  properties=pika.BasicProperties(
                      delivery_mode=2,  # make message persistent
                  ))
    
      #增加properties，这个properties 就是消费端 callback函数中的properties
      #delivery_mode = 2  持久化消息
    

个人总结：
一般持久化需要交换器、队列、消息都要开启，当然也是默认开启的。 consumer要关闭自动应答，需要采用手动应答。