zoukankan      html  css  js  c++  java
  • 简单描述Rocket Mq的架构

    Rocket Mq的架构描述:

    1. Name Server:

      • Name Server可以做为一个集群部署,集群中的各 Name Server 是独立的,节点间无任何同步信息;
      • Name Server 用于管理 Broker 实时配置信息和 Topic queue 的路由配置;
      • Broker与Name Server集群中的所有服务器保持长连接, 并且Broker 每隔30秒向 Name Server 集群上传心跳信息,包括 Topic 信息和Broker实时信息;Name Server 主动间隔10秒扫描所有的 Broker 心跳上报时间间隔是否超过2分钟,如果超过则主动断开超时的Broker的长连接,并更新Topic信息,但是不会通知生产者和消费者。
    2. Broker:

      • Broker 主要用存储数据,处理Consumer、Producer的请求;Broker 分为 Master 和Slave,Broker Master组成集群,而Broker Slave与某台 Broker Master 组成主从结构,对Broker Master的数据备份,这样一个Broker Master和Broker Slave 组成一个Broker 组。

      • 通过使用 brokerName 来区别是否属于一个Broker 组,brokerId 来指定Broker组中的主从(0为主,大于0为从)。

      • 高可用性:
        Producer端:Topic的Queue会平均分布在集群中的多个Broker Master上,如果一台Broker Master挂了后,Topic Queue的消息可以发送到其他的Broker Master 的Topic Queue中。
        Consumer端:如果某一台Broker Master宕机,消费者可以从这台Broker Master对应的Broker Slave上进行消息消费。

      • Broker 宕机后,Producer和Consumer需要30s间隔时间才能感知到,因为间隔30s从NameServer获取Topic最新的队列信息。

    3. Producer(生产者):

      • 单个Producer与集群中的一台NameServer保持长连接,如果该NameServer挂掉,则会自动连接到下一台NameServer,直到有可用的连接为止,并且这个Producer会与相关联的Broker保持长连接。
        Producer会间隔30s从NameServer拉取所有的Topic最新的Queue信息。
    4. Consumer(消费者):

      • 单个Consumer与一台NameServer保持长连接,当NameServer挂掉后,则会自动连接到下一台NameServer,并且Consumer会与相关联的Broker保持长连接。
        Consumer会间隔30s从NameServer拉取最新的Topic Queue信息。
  • 相关阅读:
    会话执行存储过程,等待被阻塞,Kill session场景模拟
    会话断开数据保存情况
    Linux关闭透明大页配置
    ORA16019搭建DG设置归档线程参数报错
    如何将openssl、uuid和crypto的库文件放到本地指定库目录
    cscope中这样生成cscope.files
    使用kdesvn完成tags和branch功能
    ubuntu中设定ibus自启动
    使用kdesvn提交文件出现Aborting commit:'.lcd1602.ko.cmd' remains in conflict错误提示
    error: dereferencing pointer to incomplete type的解决办法
  • 原文地址:https://www.cnblogs.com/diandiandidi/p/15343204.html
Copyright © 2011-2022 走看看