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

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

      

      

  • 相关阅读:
    Rpc简单入门
    对话Task
    对话线程
    译MassTransit 生产消息
    MassTransit 实现应用程序间交互
    译MassTransit 消息契约
    轻松理解AOP思想(面向切面编程)
    Elasticsearch 全教程
    Elasticsearch 教程--搜索
    Elasticsearch 教程--数据
  • 原文地址:https://www.cnblogs.com/spicy/p/7927872.html
Copyright © 2011-2022 走看看