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程度来分发消息

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

      

      

  • 相关阅读:
    攻城狮在路上(肆)How tomcat works(一) 简单的web服务器
    攻城狮在路上(肆)How tomcat works(零) 前言说明
    font-face使用备忘
    subversion安装使用
    判断一个类到底是从哪个jar包中调用的工具类
    JavaScript实例
    Nginx(一)
    PHP面向对象(七)
    PHP面向对象(六)
    PHP面向对象(五)
  • 原文地址:https://www.cnblogs.com/spicy/p/7927872.html
Copyright © 2011-2022 走看看