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

谁借莪１个温暖的怀抱￠ 2022-10-02 06:00 318阅读 0赞

2019独角兽企业重金招聘Python工程师标准>>> hot3.png

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

  • 消息持久化

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

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

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

转载于:https://my.oschina.net/edisonOnCall/blog/3044845

发表评论

表情：
评论列表 （有 0 条评论，318人围观）

还没有评论，来说两句吧...

相关阅读