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信息。
  • 相关阅读:
    排序-希尔排序
    排序-选择排序
    排序-插入排序
    排序-冒泡排序
    微服务容错处理—Hystrix初探
    声明式REST调用—Feign初探
    linux常用搜索文件命令
    Volecity模板引擎学习笔记
    页面间传递前端请求参数和获取参数:Model model,HttpServletRequest request, ModelMap map参数使用与区别
    httpServeltRequest和Model传值的区别
  • 原文地址:https://www.cnblogs.com/diandiandidi/p/15343204.html
Copyright © 2011-2022 走看看