RocketMQ架构
概述
RocketMQ是一个分布式消息和流处理平台,具有低延迟、高性能和高可靠、万亿级容量和灵活的可扩展性。它由四部分组成:name servers,brokers,生产者和消费者。它们中的每一个都可以水平扩展,而没有单一的故障节点。
NameServer 集群
Name Servers提供了轻量级的服务发现和路由。每个Name Server记录全部的路由信息,提供相应的读和写服务,并支持快速存储扩展。
Broker 集群
Brokers通过轻量级的TOPIC和QUEUE机制处理消息存储。支持Push和Pull模式,包含故障容忍机制(2或3份),提供强大的峰值填充和以原始时间顺序累积千亿条消息的能力。
另外,Brokers提供灾难恢复,丰富的度量统计和警告机制,这些都是传统消息系统缺少的。
生产者集群
生产者支持分布式部署。分布式生产者通过多种负载均衡模式发送消息到Broker集群,发送过程支持快速故障并具有低延迟。
消费者集群
消费者也支持以Push和Pull模式的分布式部署。
它也支持分布式消费和消息广播。
它提供实时消息订阅机制,可以满足大部分消费者的需求。
NameServer
NameServer is a fully functional server, which mainly includes two features:
- Broker 管理,NameServer 接收来自Broker集群的注册,提供心跳机制来检测broker是否存活。
- 路由管理,每个NameServer都持有有关broker集群的整个路由信息和客户端查询的队列信息。
我们都指定,RocketMQ客户端(生产者/消费组)通过NameServer查询队列信息,但客户端怎么查找NameServer 地址呢?
将客户端地址列表加入NameServer有四种方式:
- 编码方式,如producer.setNamesrvAddr("ip:port")。
- Java选项, 使用 rocketmq.namesrv.addr.
- 环境变量, 使用 NAMESRV_ADDR.
- HTTP Endpoint.
Broker Server
Broker服务 负责消息存储和传递,消息查询,保证HA等。
Broker 服务有些重要的子模块:
- 远程处理模块,broker的入口,处理来自客户端的请求。
- 客户端管理器,管理客户端(生产者/消费者),维护消费组的订阅主题。
- 存储服务,提供简单的APIs来存储或查询物理磁盘中的消息。
- HA 服务, 提供主broker和从broker的数据同步
- 索引服务, 通过指定键建立消息索引,提供快速的消息查询。
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
程序员如何克服焦虑?
克服焦虑的最好方法就是在征服世界之前,请先走好脚下的路 现代社会节奏越来越快,焦虑成为了一种普遍存在的城市病。不知不觉中,竟有很多人都错误地认为:只有焦虑和迷茫的人,才是有追求、有上进心的人。 这种说法之所以看似没有毛病,大抵是因为焦虑的人太多了,其中更是不乏很多成功者。但我想说,为什么只有追求、有上进心的人,才会焦虑和迷茫呢?这样是不是自我矛盾呢? 在帮助职场人做职业咨询时,发现一个问题:他们的焦虑和迷茫都是因为接触太多外面的世界,而后想得太多而导致。 比如,一些人听到罗胖的跨年演讲后,就开始焦虑和迷茫,担心自己所在的行业有黑天鹅事件发生,开始转到陌生的领域去挖矿。 你转移到陌生领域,就不担心黑天鹅事件发生了吗?这真是大错特错的荒谬想法。当听到某一种新的理念或者想法,真的还是要谨慎思考,不要轻易拿来误导自己的人生。 没错,外面的世界非常好。但残酷的是,外面的世界对你来说未必好,或许就是一个非常大的陷阱在等待着你。 看来,如今真的是全民焦虑和迷茫,有钱的也焦虑和迷茫,没钱的更焦虑和迷茫。也正是这些焦虑和迷茫,像稻草一样,压垮了中国的年轻人。 为什么会有焦虑和迷茫呢?根据老王的调研,大致...
- 下一篇
智能媒体管理(IMM)文档转换/预览提供 API 按量计费模式
一、导语 智能媒体管理 (Intelligent Media Management, IMM) 是阿里云的云服务,它通过 文档标准型 实例提供了 Cloud Native 架构的文档转换/预览功能 ,本文介绍 API 按量计费模式的配置。 二、创建文档标准型按量计费项目 使用 API 按量计费,需要重新创建文档标准型项目,如下图所示。 进入 IMM 控制台,在指定区域创建项目,注意要选择文档标准型并在付费类型中指定按次付费,此后基于此项目的调用将按照 API 调用次数计费,每次调用费用为 0.08元人民币。 三、使用建议 针对文档标准型,IMM 提供了 2 种计费模式: QPS 模式。按每天的处理能力计费,QPS 表示每秒的并发处理能力,该值为 1 表示每秒钟只能处理 1 个文档请求。同时,文档转换请求为异步请求,此时异步请求的队列深度和 Q
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- MySQL8.0.19开启GTID主从同步CentOS8
- CentOS6,7,8上安装Nginx,支持https2.0的开启
- 设置Eclipse缩进为4个空格,增强代码规范
- SpringBoot2初体验,简单认识spring boot2并且搭建基础工程
- Red5直播服务器,属于Java语言的直播服务器
- CentOS7设置SWAP分区,小内存服务器的救世主
- CentOS7安装Docker,走上虚拟化容器引擎之路
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果
- SpringBoot2整合Redis,开启缓存,提高访问速度
- SpringBoot2配置默认Tomcat设置,开启更多高级功能