zoukankan      html  css  js  c++  java
  • rabbit服务器挂掉以后,保证队列消息还存在(tp框架)(第三篇)

    上接 第二篇 : http://www.cnblogs.com/spicy/p/7921870.html

    第二篇解决了 如果其中一个worker挂掉了啦,如何保证消息不丢掉,并重新分发给其他worker

    现在要解决: 如果rabbitmq服务器挂掉了的话,如果保证队列里面的消息还在

    方案:

    第一步 : 必须保证publisher 和 consumer 下面都保持一致,第三个参数都是true 

     

     第二步: 新建消息的时候 增加一个选项,让消息传递模式为persisitent

      

      但是官方也说了:这样也不能完全保证消息不能丢失

      

    实验: 发布10条消息:然后重启rabbitmq, 然后打开worker 发现消息在存在 并且分发给了worker去处理掉了

    实验问题一: 如果消息正在消费的时候去关闭rabbitmq服务器,这个时候再重启的时候发现 所有的消息都没有了,原因就是开启了auto_delete

    导致,只要一开起以后,服务器就会把消息一次性分发出去,然后删除掉

    解决方案:在publisher 和 worker 二边都关闭掉auto_delete

    实验问题二: 如果开启多个worker 会发现服务器会平均分发比如(1,3,5,7,9给worker1,  2 ,4,6,8,10 给worker2),而不是根据每个worker的busy程度来分发消息

    解决方案: 在消费前面加上的一个配置

      

      

  • 相关阅读:
    Visio2019专业版激活方法
    I2C总线协议
    latch-up和Antenna-effect
    读--数字集成电路物理设计
    数字IC设计流程与工具
    读--FPGA设计指导原则
    读--数字集成电路设计与实现
    FIFO
    半导体存储器
    触发器
  • 原文地址:https://www.cnblogs.com/spicy/p/7927872.html
Copyright © 2011-2022 走看看