|
|
Java电子书：RocketMQ技术内幕：RocketMQ架构设计与实现原理（第2版） 格式 pdf 电子书 PDF 电子书 Java吧 java8.com
' m4 T' ~9 k2 {( o; l" z2 |
% y0 j! i# e# w% P9 K/ Q# f" `# Z4 @, ^7 l5 M
编号：mudaima-P0202【Java吧 java8.com】
" H8 W0 Y. w) p3 @- k. e9 W7 U2 }; q# z3 @% l4 v
- ^0 |7 m0 O! J
3 L& l, S2 `' j0 \- ?5 k
Java电子书目录：第1章 阅读源码前的准备15 P6 ^( f1 d$ y- I2 h
1.1 获取和调试RocketMQ的源码1) i; c* u0 O4 N2 x
1.1.1 Eclipse获取RocketMQ源码1
9 n, x% z1 D: ?! M9 N5 k, E1.1.2 Eclipse调试RocketMQ源码8
3 \7 a$ u1 r4 i1.1.3 IntelliJ IDEA获取RocketMQ源码149 j7 J5 `! ]0 ?' F! z; N" a6 Q
1.1.4 IntelliJ IDEA调试RocketMQ源码16
1 k' J# G6 R1 R/ w% ~1.2 RocketMQ源码的目录结构23
) }- l* s$ m5 n( M& z3 @( d/ a1.3 RocketMQ的设计理念和设计目标23+ a& d# D1 } X! F3 Q0 R
1.3.1 设计理念23
8 [) A4 v6 w2 P) V& V1.3.2 设计目标24
+ j% h. m2 d# W6 {6 z P1.4 本章小结26第2章 RocketMQ路由中心NameServer27
; e( D5 X# K( j" o7 v5 P2.1 NameServer架构设计27
d1 p3 P6 `6 ^$ r# q! ~2.2 NameServer启动流程29: U7 p# b0 U6 g7 _5 q2 ~9 C
2.3 NameServer路由注册、故障剔除32/ `; P/ [$ @( `2 i: Z" x
2.3.1 路由元信息32
. s" R# b- C9 v2.3.2 路由注册35
2 j: @8 L; n8 D7 s9 r2.3.3 路由删除40
( a" r( C8 R( \9 [* m& S5 L' }2.3.4 路由发现43/ j& f' ?! e5 y- }$ j4 T
2.4 本章小结44第3章 RocketMQ消息发送46
- h6 B! o& y0 G" t3.1 漫谈RocketMQ消息发送468 }2 D# y! E9 ~/ Q: y3 _
3.1.1 topic路由机制47
2 Z9 v( w; {3 W, l0 z3.1.2 消息发送高可用设计486 ]: b& W! `9 }3 r, m
3.2 认识RocketMQ消息50
; K# x7 Q1 n+ g3 W3.3 生产者启动流程51' G4 Q. R1 X1 l7 H9 _
3.3.1 初识DefaultMQProducer512 }) i3 `2 C' s4 F- V4 H) L
3.3.2 消息生产者启动流程546 ]0 O8 j( b T$ S6 h
3.4 消息发送基本流程558 o( E; ]3 k3 i. W
3.4.1 消息长度验证562 v3 ]4 A" u. b9 j @6 a
3.4.2 查找主题路由信息57: i; W7 d& C, p3 G0 d
3.4.3 选择消息队列60
0 H; V! |9 u4 `/ s6 q. Q, p3.4.4 消息发送65
3 K" @) B: O$ \3.5 批量消息发送72; q; S f: s3 `
3.6 本章小结74第4章 RocketMQ消息存储759 b+ r# Q/ R1 C0 R' t4 ^/ R/ U
4.1 存储概要设计751 C/ k+ F' }" A- Q3 B
4.1.1 RocketMQ存储文件的组织方式760 v0 }4 Y# S0 l9 l* {4 t9 @ o5 o
4.1.2 内存映射80! q! h2 }5 s5 x- R+ `
4.1.3 灵活多变的刷盘策略81
' K6 s. j: A5 P4.1.4 transientStorePoolEnable机制825 V) h; |! {: |0 S
4.1.5 文件恢复机制82
1 ^# B' R3 ^3 ?8 G4 r, Q5 ~8 i7 u4.2 初识消息存储83& B* j8 L7 P& \1 K$ F) ^
4.3 消息发送存储流程846 D6 o) C+ a4 F' y* l0 u! U6 v/ m+ d
4.4 存储文件组织与内存映射90
0 J$ w* ^5 N" q' q* P" g; k$ F8 G0 ~4.4.1 MappedFileQueue映射文件队列 90
) |0 L/ g6 g3 d P7 h6 |4.4.2 MappedFile内存映射文件92/ b+ F/ z! }8 k
4.4.3 TransientStorePool99
& X- |* i) I1 O# U# N% \" g6 h4.5 RocketMQ存储文件100
! c7 W5 G: C& D7 B. _0 E4.5.1 CommitLog文件101
4 u( d a0 @+ v/ r9 C1 g, w4.5.2 ConsumeQueue文件102
, X9 T9 t( B, g& J: k4.5.3 Index文件106) R k$ J4 B l/ {
4.5.4 checkpoint文件110
" B" R% ?5 m( ?3 d2 `7 m% g8 u4.6 实时更新ConsumeQueue与Index文件111% t+ J* l, Y6 R
4.6.1 根据消息更新ConsumeQueue文件1136 l. n# Y" t* I [% i! c
4.6.2 根据消息更新Index文件114+ X3 B! T- k8 x
4.7 ConsumeQueue与Index文件恢复115! J: w) O& x2 b1 D& G! J
4.7.1 Broker正常停止文件恢复118
* s9 T( k9 _9 Y! ?2 r4.7.2 Broker异常停止文件恢复120* U5 \0 u. Q1 r, {* ~2 l* M3 r8 ~
4.8 文件刷盘机制121, h' h$ ~ x9 d. A: N
4.8.1 Broker同步刷盘122
; {% K1 U+ Z7 k% U/ N% X5 [8 ~4.8.2 Broker异步刷盘125$ Y5 O5 h/ @) t" X! |% K9 J1 @
4.9 过期文件删除机制128! M" s2 F! F# }( e; b1 {8 z
4.10 同步双写132
9 @! t5 P, ]5 e: ?4.11 本章小结136第5章 RocketMQ消息消费137
1 o$ g: a4 O& _1 v4 E% V% @5.1 RocketMQ消息消费概述1373 B/ e6 e5 c, u" i, M8 J
5.1.1 消费队列负载机制与重平衡138: {+ ^# c: o! A# t' ~; u! X$ P
5.1.2 并发消费模型139# w1 Y: ~( i: J9 o- p1 U
5.1.3 消息消费进度反馈机制139. l6 B" K( ^, y Z
5.2 消息消费者初探141" L/ y8 r$ Q3 n* ?) Q3 a3 E
5.3 消费者启动流程1430 ?* L1 P! g$ E( J# q' r9 S
5.4 消息拉取1461 l/ [0 H7 I' p
5.4.1 PullMessageService实现机制147
; k, T, n: b8 k3 n( B; e5.4.2 ProcessQueue实现机制149
e) _2 ]3 N5 ?% A# \3 Z* C5.4.3 消息拉取基本流程150+ R2 _0 B B. K1 S. G2 D0 I I
5.5 消息队列负载与重新分布机制167
& U7 A# V/ B; i' o6 [5.6 消息消费过程175
6 k+ R$ e6 M9 O1 j7 v: h5.6.1 消息消费176! x i, d7 s# k# ? e8 n
5.6.2 消息确认180+ U4 d$ K/ P9 I7 J( e
5.6.3 消费进度管理184 ]: z- K# D$ Q0 t0 @2 {: n
5.7 定时消息机制189: x4 P! ^0 w) ^4 T+ V
5.7.1 load()方法190
% f$ C5 D [; ?3 p) {+ \ B6 T5.7.2 start()方法190
! p+ f& ?2 r# m% y, ]( \5.7.3 定时调度逻辑192
+ X T; C, a8 \9 c1 e5.8 消息过滤机制1941 n, |0 H5 Q$ d* k9 y7 ~7 W
5.9 顺序消息199
9 r! _8 k/ T' ^2 U$ \0 G5.9.1 消息队列负载199; m' N6 H& q$ H5 N
5.9.2 消息拉取200& w. ]7 H* a+ z" x/ o5 e" q$ U
5.9.3 消息消费2014 b; w. |: q9 w( f0 `% ?5 N
5.9.4 消息队列锁实现208
$ k) g( x# j' f) i5.10 本章小结209第6章 RocketMQ的ACL210
) ~; D% |+ B. o! I! V+ ~3 ~( l6.1 什么是ACL210
0 c5 b' }$ c, d0 w: T" p# }3 U6.2 如何使用ACL211
- x: n+ t: G: Z' j7 S$ R6.2.1 Broker端开启ACL211' Q" I8 _: j; H. v- k a
6.2.2 客户端使用ACL212
, V( v% ~4 ?& v1 K$ y6.3 ACL实现原理214' S: B0 \+ u' a# G6 @
6.3.1 Broker端ACL核心入口214
9 ~6 }7 `& t: T1 T2 `6.3.2 PlainAccessValidator详解216
& O- g$ h; \4 m" v6.3.3 PlainPermissionManager详解220
) @+ l$ k% e! j( M* o6.3.4 AclClientRPCHook详解228, ]4 E! D3 Q: w4 l; ^- X7 p
6.4 本章小结231第7章 RocketMQ主从同步机制2324 R: c& D/ M( ^. |4 K) c0 Y- {
7.1 RocketMQ主从同步原理232
0 I! d7 c4 F3 a1 G, e; [7.1.1 HAService整体工作机制233
5 N$ {% O2 E2 ]+ b5 `' Q7 }7.1.2 AcceptSocketService实现原理2335 m3 |" M/ L. D8 k
7.1.3 GroupTransferService实现原理2351 v0 C0 F( A1 x1 _
7.1.4 HAClient实现原理236% k) ^" M+ D5 c p4 z5 t& v
7.1.5 HAConnection实现原理239) F0 b j$ P5 |$ c: E; i3 z
7.2 RocketMQ读写分离机制245# J J H# ?3 G
7.3 RocketMQ元数据同步248
* ^; c4 L# Q3 R1 ?" ]% {$ U7.3.1 从节点主动同步元数据249
4 X2 E$ V( f' Y" Q9 { e6 n7.3.2 主节点消息拉取主动同步消费进度250
! H: S( |! v( M/ I7.4 本章小结251第8章 RocketMQ消息轨迹2523 A8 ?$ \8 T2 S/ |) m5 y% P4 d8 x
8.1 消息轨迹的引入目的和使用方法252
7 I6 t( B) P; U: U8.2 消息轨迹设计原理255$ E) x% n9 w/ x3 R& ^5 B: u
8.2.1 消息轨迹数据格式255
6 j7 A7 a* q9 f+ _! u8 n/ R0 n1 K- O8.2.2 如何采集轨迹数据256
$ T5 {1 F2 _) o! j8.2.3 如何存储消息轨迹数据257
8 [, p1 c% m8 f) r- M8.3 消息轨迹实现原理2576 h6 A s+ D- |' S% u }0 |
8.3.1 寻找消息轨迹入口257
, p! d W5 K1 m* E* k' a T8.3.2 消息发送轨迹数据259
; U. F# y# G/ [8.3.3 消息轨迹异步转发实现机制2615 m7 h5 N1 G O1 E0 o
8.4 本章小结265第9章 RocketMQ主从切换2667 ~3 |+ u0 i4 e
9.1 主从切换引入目的266
. j! N+ r' v; z3 {1 R9.2 Raft协议简介267
* C- w( A. x+ @5 u! D9.2.1 Leader选举267' u% G& {9 P' @6 u3 c0 D6 z5 w
9.2.2 日志复制268! r2 N3 T% K. [& z1 c1 x H
9.3 RocketMQ DLedger主从切换之Leader选主269
4 B `. o$ d O5 `1 B9.3.1 DLedgerLeaderElector核心类及核心属性270
! W( S9 R. V) g, P6 i9.3.2 选举状态管理器初始化271
" e" Z' w. v/ A% i6 X9.3.3 选举状态机状态流转2737 M$ `7 A! k( K* h
9.3.4 发送投票请求与处理投票请求280
" ~" S* y; x6 l3 G+ }1 Y, P7 K1 Y( c" T9.3.5 发送心跳包与处理心跳包283
* r f1 \. l% `, @9.4 RocketMQ DLedger主从切换之存储实现288. i1 g' V2 J* j0 ?8 D0 c6 @" }' J
9.4.1 RocketMQ DLedger核心类及核心属性288" j! J# y6 K& H; P+ J0 F' T
9.4.2 RocketMQ DLedger数据存储协议290# B" J f4 \/ C8 S' u
9.4.3 RocketMQ DLedger索引存储协议291& r/ H6 O2 p) K/ N8 I7 J
9.5 RocketMQ DLedger主从切换之日志追加291
" f. v! J6 `3 r) l: I9.5.1 日志追加流程概述291" ]6 C `5 f% q8 t, |
9.5.2 判断Push队列是否已满293
. Z Q; F8 X8 E" g9.5.3 Leader节点日志存储293( p7 j$ x5 W" M, d4 ^
9.5.4 Leader节点等待从节点日志复制响应ACK2984 x6 _5 e% Q5 Y" X/ M: U1 ?" G
9.6 RocketMQ DLedger主从切换之日志复制299
% z/ A1 D# ^) w. @9.6.1 日志复制设计理念3006 R! ]: S. v0 C7 a; |2 O
9.6.2 日志复制类设计体系3012 O* q4 B3 {$ E! O! F
9.6.3 日志转发303
) Z; u7 D K% R- w9.7 RocketMQ整合DLedger设计技巧与实现原理326
) S* {: ]& j% ?* y( k+ z9.7.1 数据存储兼容设计327
& Y* B9 e, v6 o* P! Q; x$ u4 d0 s9.7.2 数据存储兼容实现原理3286 w0 l- r- z, s$ a
9.7.3 主从切换元数据同步机制337
3 I0 P, `1 n1 a2 a9 N% {7 F9.8 RocketMQ主从切换实战344
9 ^) G% F( I8 A6 j+ ~3 e+ m4 A& S, C$ t9.8.1 主从切换核心配置属性344
3 l- I; Y8 D+ I" q+ f3 A! D* k9.8.2 搭建主从同步环境344
1 k' x( p- `7 _. T% {* Q9.8.3 主从同步集群升级到主从切换3461 u# K- Z. _, E4 Q3 j1 B) X
9.9 本章小结350第10章 RocketMQ监控352
5 j- d( m( ^$ L3 C10.1 设计理念3526 ]* n' P9 i3 B) _3 _5 L; O
10.2 实现原理353
. M2 n/ t i$ b10.2.1 监控相关类图353
' M1 E1 G' O& G) Z: ~10.2.2 监控原始数据采集流程355$ _; }2 }# p; j- Y- Q
10.3 监控数据采样机制356
; `- p# d4 z# E8 I1 H10.3.1 监控数据采样356
* T: M+ J& A+ V10.3.2 根据采样计算统计指标357
9 ]$ G8 ?( a; o/ h: y5 s6 d10.4 如何采集监控指标359% ~5 n) D3 C- V! N' s/ ]$ c' L
10.5 监控实战应用3608 c! z9 z' N" U
10.6 本章小结365第11章 RocketMQ实战3668 u6 u0 A& ~3 f& V' W: _# E; c5 k
11.1 消息批量发送366
1 s& \( n3 C$ \ _ o11.2 消息发送队列自选择3676 Y0 b6 h9 E" o- g7 O" {
11.3 消息过滤368# Y4 y) {; l% a& [
11.3.1 TAG过滤模式368
" k$ b4 `8 x! {# @7 Q11.3.2 SQL过滤模式368
, e, P/ x4 q9 t1 p; i+ L11.3.3 类过滤模式369
" h! C& `7 n* T11.4 事务消息371
6 P, P& h- J7 f/ D. m11.5 Spring整合RocketMQ3750 {8 |; W5 S9 N/ j9 c0 t5 c) Y9 W9 b
11.6 Spring Cloud整合RocketMQ376
6 x9 z2 I, C" h11.7 RocketMQ监控与运维命令384& Q& ^: _7 O Z A6 J N: g1 g5 w
11.7.1 搭建RocketMQ监控平台rocketmq-console384% P: V! c3 W) T( @! n6 v \ Y
11.7.2 RocketMQ管理命令387
. g3 v$ V1 r( D6 Z2 `* z$ l11.8 应用场景分析423. d- b& J' ?2 g
11.9 实战案例424/ m) }* ?! e1 z' s# \5 A& Y
11.9.1 RocketMQ集群线上故障缩容实战案例424' }5 j5 I: M' G& v% |
11.9.2 RocketMQ在线扩容实战4273 D8 T9 ~/ F- T3 n! z
11.10 本章小结430
) M/ a/ @7 y# g& r. L附录 A 参数说明4313 }1 V; s7 Q7 ~3 u8 h
附录B RocketMQ各版本概述与升级建议4360 p& q$ r! A1 z+ }8 |9 ~' D
百度云盘下载地址(完全免费-绝无套路)：
9 }/ P% Y/ R* y5 X1 K3 ^ |
本帖子中包含更多资源
您需要 登录 才可以下载或查看，没有账号？立即注册
x
|
电子书
449 人阅读
|
33 人回复
|
2023-09-01
