RocketMQ技术内幕:RocketMQ架构设计与实现原理

admin 2022年11月13日 152次浏览

RocketMQ技术内幕:RocketMQ架构设计与实现原理

(副标题):无 ;

(作者): 丁威 ;

内容简介:

​ 5.1 RocketMQ消息消费概述
消息消费以组的模式开展,一个消费组内可以包含多个消费者,每一个消费组可订阅多个主题,消费组之间有集群模式与广播模式两种消费模式。集群模式,主题下的同一条消息只允许被其中一个消费者消费。广播模式,主题下的同一条消息将被集群内的所有消费者消费一次。消息服务器与消费者之间的消息传送也有两种方式:推模式、拉模式。所谓的拉模式,是消费端主动发起拉消息请求,而推模式是消息到达消息服务器后,推送给消息消费者。RocketMQ消息推模式的实现基于拉模式,在拉模式上包装一层,一个拉取任务完成后开始下一个拉取任务。
集群模式下,多个消费者如何对消息队列进行负载呢?消息队列负载机制遵循一个通用的思想:一个消息队列同一时间只允许被一个消费者消费,一个消费者可以消费多个消息队列。
RocketMQ支持局部顺序消息消费,也就是保证同一个消息队列上的消息顺序消费。不支持消息全局顺序消费,如果要实现某一主题的全局顺序消息消费,可以将该主题的队列数设置为1,牺牲高可用性。
RocketMQ支持两种消息过滤模式:表达式(TAG、SQL92)与类过滤模式。
消息拉模式,主要是由客户端手动调用消息拉取API,而消息推模式是消息服务器主动将消息推送到消息消费端,本章将以推模式为突破口重点介绍RocketMQ消息消费实现原理。

目录预览:

​ RocketMQ技术内幕:RocketMQ架构设计与实现原理
第1章 阅读源代码前的准备
1.1 获取和调试RocketMQ的源代码
1.1.1 Eclipse获取RocketMQ源码
1.1.2 Eclipse调试RocketMQ源码
1.1.3 IntelliJ IDEA获取RocketMQ源码
1.1.4 IntelliJ IDEA调试RocketMQ源码
1.2 RocketMQ源代码的目录结构
1.3 RocketMQ的设计理念和目标
1.3.2 设计目标
第2章 RocketMQ路由中心NameServer
2.1 NameServer架构设计
2.2 NameServer启动流程
2.3 NameServer路由注册、故障剔除
2.3.1 路由元信息
2.3.2 路由注册
2.3.3 路由删除
2.3.4 路由发现
2.4 本章小结
第3章 RocketMQ消息发送
........


[EPUB下载]