下载  >  开发技术  >  Java  > RocketMQ技术内幕

RocketMQ技术内幕 评分:

RocketMQ技术内幕
42初识消息存储 ……76 54消息拉取 ……133 4.3消息发送存储流程… 78 54.1 PullMessage Service实现 44存储文件组织与内存映射…83 机制 133 44.1 MappedFile Queue映射文件 542 Process Queue实现机制…136 队列… 84 54.3消息拉取基本流程…138 44.2 MappedFile内存映射文件…87 5.5消息队列负载与重新分布 4.4.3 Transient StorePool 93 机制 154 4.5 RocketMQ存储文件 ………94 56消息消费过程…162 4.5.1 Commitlog文件…………95 5.6.1消息消费………………163 4.5.2 Consume Queue文件………97 4.5.3 Index索引文件……………100 562消息确认(ACK)…………167 4.54 checkpoint文件… 104 5.6.3消费进度管理 171 4.6实时更新消息消费队列与索引 5.7定时消息机制… 176 文件… 105 5.7.1load方法…………177 46.1根据消息更新 5.72 start方法…………178 ConumeQueue…107 5.7.3定时调度逻辑…………179 462根据消息更新 Index索引 58消息过滤机制 ………181 文件 108 59顺序消息 …………186 4,7消息队列与索引文件恢复 591消息队列负载……187 4.7.1 Broker正常停止文件恢复…112 592消息拉取………187 4.,7.2 Broker异常停止文件恢复…114 5.9.3消息消费 188 4.8文件刷盘机制 115 5.94消息队列锁实现……………195 4.8.1 Broker同步刷盘… 116 510本章小结 196 4.82 Broker异步刷盘……………119 4.9过期文件删除机制 122第6章消息过滤 Filter Server………198 4.10本章小结……126 61 Class Filter运行机制…198 第5章 RocketMQ消息消费… 127 62 FilterServer注册剖析……199 5.1 RocketMQ消息消费概述…127 6.3类过滤模式订阅机制 …202 5.2消息消费者初探… 128 64消息拉取… ………205 53消费者启动流程 ……130 65本章小结… ……206 仅供非商业用途或交流学习使用 X 第7章 RocketMQ主从同步(HA) 8.5本章小结… 240 机制 …∴……∵………207 第9章 RocketMQ实战 242 7.1 RocketMQ主从复制原理………207 9.1消息批量发送 ·····,· 242 7 HAService整体工作机制…20892消息发送队列自选择 243 71.2 AcceptSocketService实现 9.3消息过滤… 243 原理……208 9.3.1TAG模式过滤 244 71.3 Group TransferService实现 9.3.2SQL表达模式过滤 …244 原理 ·,,,.,., 210 9.3.3类过滤模式 245 714 CLIent实现原理 , 211 94事务消息 ………247 7.1.5 HAConnection实现原理……214 9.5 Spring整合 RocketMQ……250 72 RocketER读写分离机制…20 9.6 Spring Cloud整合 RocketT…251 7.3本章小结 223 97 RocketMQ监控与运维命令…258 97.1 RocktetMQ监控平台搭建…258 第8章 RocketS事务消息 225 9.7.2 RocketMQ管理命令…261 8.1事务消息实现思想… 225 9.8应用场景分析 …280 82事务消息发送流程… 226 99本章小结 8.3提交或回滚事务 …232 84事务消息回查事务状态……233附录A参数说明 282 仅供非商业用途或交流学习使用 器圆 8圆 器 第1章Cy< 阅读源代码前的准备 硏究一款开源中间件,首先我们需要了解它的整体架构以及如何在开发环境调试源 码,从代码入手才能快速熟悉一个开源项目,只有这样才能抽丝剥茧地理解透彻,了解 作者的设计思想和实现原理。本章将重点介绍 RocketMQ的整体设计理念以及如何调试 RocketMQ,为后续源码阅读打下扎实的基础。 本章重点内容如下。 获取和调试 RocketMQ源代码 RocketMQ源代码的目录结构 RocketMQ的设计理念和设计目标 1.1获取和调试 RocketMQ的源代码 RocketMQ原先是阿里巴巴内部使用的消息中间件,于2017年提交到 Apache基金 会成为Apache基金会的顶级开源项目,Github代码库链接:htts:/github.com/apache rocketing git。在 Github网站上搜索 RocketMQ,如图1-1所示。 仅供非商业用途或交流学习使用 2 RocketS技术内幕: RocketS架构设计与实现原理 https://github.com/apache/rocketmq Features Business Explore Marketplace Pricing This repository Sign in Sign up a apache/rocketmq ⊙wts9★9m305y6k14 <>Code: O lssues 2 n Pull requests 44 Fi Projects o bIt Insights 昂 Dismiss Join GitHub today GitHub is home to over 20 million developers working together to host and review code, manage projects, and build software together Mirror of Apache RocketMQ G 429 commits w 13 branches 9 3 releases R8 29 contributors 中 Apache20 New pul Find file Clone or downton zhouxinyu [HOTFXIROCKETMQ-356 Change Aversion to 4.2.0 Clone with htTps⑦ Add a modified version of iSSUE TEMPLATE that created by the bookkeep Use Git or checkout with SVN using the web URL. Imaven-release-pbuginl prepare release rocketmq-alI-4.2.0 https://github.com/apache/rocketmq.gite E dient Imaven-release-pluginl prepare release rocketmq-all-4.2.0 Open in Desktop Download zip icommon [HOTFIXIROCKETMQ2-356 Change MQVersion to 4.2.0 a202Tp clean un remount incubating related 图1-1 GitHub RocketMQ搜索界面 1.1.1 Eclipse获取 RocketS源码 Step1:单击右键从菜单中选择 Import git,弹出如图1-2所示的对话框。 Select Import one or more projects from a Git Repository Select an import wizard: filter te >e General ②EJB e Git a Projects from Git Back Next Finish Cancel 图1-2 对话框 仅供非商业用途或交流学习使用 第1章阅读源代码前的准备 Step2:点击Next按钮,弹出 Projects from Git对话框,如图1-3所示 Import Projects from Git Select Repository Source Select a location of Git Repositories type filter text U Existing local repositon Clone URI Back Next Cancel 图1-3 Import Projects from Git对话框 Step3:点击Next按钮,弹出 Clone uri对话框,如图1-4所示。 C Import Projects from Git × Source Git Repository Enter the location of the source repository Location URI: ttps: //github. com/apache/rocketmq Local File Host: github. com Git URL Repository path: /apache/rocketmq git Connection Protocolhttps Port Authentication User GHb用户名 Password Github密码 M Store in Secure Store Bak[Nex:■而[cace 图1-4 Import Projects from Git对话框 仅供非商业用途或交流学习使用 4 RocketMO技术内幕: Rockets架构设计与实现原理 step4:继续点击Next进入下一步,选择代码分支,如图1-5所示。 C Import Projects from Gi Branch Selection Select branches to clone from remote repository. Remote tracking branches will be created to track updates for these branches in the Branchesofhttps://github.com/apache/rocketmq.git type filter text vee devel 典 enhancedTls tip:如果网络不是特别好,可以只选择 vo master develop或 master分支即可 vee openmessaging-imp 6t release-4.0.0-incubating Select All Deselect Al Back Next Cancel 图1-5 Import Projects from Git对话框 Step5:选择所需要的分支后点击Next,进入代码存放目录选择,如图1-6所示。 O Import Projects from Gi Local Destination Configure the local storage location for rocketmg Destination Directoryκ k: Users Dwigittrocketmq选择源码存放路径 Brow initial branch: master □ Clone submodules Confiquration Remote name: origin Next Ca 图1-6 Import Projects from Git对话框 Step6:点击Next, Eclipse将从远程仓库下载代码,如图1-7所示。 仅供非商业用途或交流学习使用 第1章阅读源代码前的准备心5 OCloningfromhttps://github.com/apache/rocketmq.gi Select a wizard to use for importing projects Depending on the wizard, you may select a directory to determine the wizard's scope Vizard for project import O Import existing Eclipse projects O Import using the New Project wizard O Import as general project yorking Tree -E: \SH1115github\rocketmg new Cloningfromhttps://github.com/apache/rocketmq.git:Receivingobjects51%(6412/1257 Fnis 图1-7 Import Projects from Git对话框 Step7:代码下载到指定目录后,默认选择 Import existing projects(单分支),这里手动 选择 Import as general projects(多分支),点击 Finish,成功导人,如图1-8所示 cLoningfromhttps://github.com/apache/roc Select a wizard to use for importing projects Depending on the wizard, you may select a directory to determine the wizard's scope Wizard for project import OImport existing Eclipse projects O Import using the New Project wizard O Import as general project C Working Tree -E: \ SH111S\github\rocketmq_new Back Next Finish Cancel 图1-8 Import Projects from Git对话框 Step8:代码导入成功后,需要将项目转换成 Maven项目,导入成功后的效果图,如图 1-9所示。 Step9:单击右键从上下文菜单中选择 rocketing new(文件下载目录名)→ Configure Convert and Detect Nested Projects转换成 Maven项目,如图1-10所示。 仅供非商业用途或交流学习使用 6心 RocketMg技术内幕: RocketS架构设计与实现原理 E rocketmq new [rocketmq new master] as broke s pom. xml 会 client 会co a dev e distribution er example 〉 a filter 合 logapp >2 names L openmessaging >ft remoting a sutil eg store style test C tools 露 BUILDING 画 CONTRIBUTING. md 画 LICENSE 品 NOTICE as pom. xml E README. md 图1-9导入项目初始状态 ˇ品 rocketmq new [rocketmg net >2 broker Go Into o Eh client v tl common Show in Local Terminal src e Copy Ctrl+C a po Ctrl+v v E dev Delete Delete 0 merge rocketmq pr py e Remove from Context Ctrl+Alt+Shift+Down E distribution Move 的 example Rename Import.… es pom.xm 〉 filters a Refresh o E logappender Close Project C names Close Unrelated Project >2 openmessaging Show in Remote Systems view a remoting L sutil Coverage As store Run A a style Debug As test Profile as ea tools Restore from Local History. S BUILDING Maven E CONTRIBUTING. md Team 品 LICENSE Compare W 品 NOTICE Replace With E pom.xml Configure Convert to Faceted Form 圆 README. md Configure and Detect Nested Projects Properties Alt+Enter Add Gradle Nature Convert to Plug-in Projects Convert to JavaScript Project. 图1-10转换 Maven项目 仅供非商业用途或交流学习使用

...展开详情
2019-03-03 上传 大小:165.96MB
版权受限,无法下载
举报 收藏 (2)
分享

评论 下载该资源后可以进行评论 共6条

budongorz 现在分数都这么高,CSDN的脑残积分又是系统自定义。都快没积分了
2019-09-10
回复
zjl_csdn 扫描版,一点目录就缩小到看不见,体验极差
2019-04-28
回复
babyheart001 书挺好的,确实是我要找的书
2019-04-19
回复
qq417449614 还可以,不错
2019-04-16
回复
youxinshouhou rocketMQ看一下
2019-04-13
回复
RocketMQ技术内幕高清带书签目录

RocketMQ技术内幕高清带书签目录

立即下载
《RocketMQ技术内幕》_丁威.pdf

RocketMQ技术内幕,从入门到精通,RocketMQ源码分析。

立即下载
《RocketMQ技术内幕》.7z

《RocketMQ技术内幕》

立即下载
rocketmq官方中文文档.pdf

rocketmq官方中文文档.pdf

立即下载
RocketMQ实战与原理解析 高清 PDF

全书共13章,分为两个部分。第 一部分是RocketMQ实战,包括第1~8章。第1章是快速入门,让读者了解分布式消息队列的功能,了解RocketMQ,能够搭建好单机版的消息队列,收发消息;第2章是让读者快速地把消息队列用好,应用到生产环境中;第3章具体介绍不同类型生产者和消费者的特点,以及和它们相关的Offset和Log;第4章介绍了分布式消息队列的协调者NameServer,NameServer维护集群的配置信息、状态信息,其他角色都通过NameServer来协同执行;第5章介绍了RocketMQ的内部机制,包括接收Producer发过来的消息、处理Consumer的消费请求、消息的持久化存

立即下载
RocketMQ全套资料

这是阿里的一个开源项目,这个文件里面包含了项目开发需要的源码 官方文档 PDF和项目需要的的jar包 以及需要的工具.

立即下载
RocketMQ技术内幕.rar

RocketMQ技术内幕

立即下载
RocketMQ技术内幕~~

RocketMQ技术内幕,最好的rocketMQ学习材料~~

立即下载
RocketMQ实战与原理解析.pdf

RocketMQ实战与原理解析,消息队列,解耦合,高并发必备

立即下载
rocketMQ技术内幕

本书由RocketMQ社区早期的布道者和技术专家撰写,Apache RocketMQ创始人/Linux OpenMessaging创始人兼主席/Alibaba Messaging开源技术负责人冯嘉的高度评价并作序推荐。 源码角度,本书对RocketMQ的核心技术架构,以及消息发送、消息存储、消息消费、消息过滤、顺序消息、主从同步(HA)、事务消息等主要功能模块的实现原理进行了深入分析,同时展示了源码阅读的相关技巧;应用层面,本书总结了大量RocketMQ的使用技巧。通过本书,读者将深入理解消息中间件和底层网络通讯机制的核心知识点。 全书共10章,分三个部分: *部分 准备篇(第1章) 首先介绍

立即下载