TA的每日心情 | 开心
10 小时前 |
|---|
签到天数: 240 天 [LV.8]以坛为家I
管理员
- 积分
- 8483
|
Java电子书：RocketMQ分布式消息中间件：核心原理与实践 PDF 电子书 Java吧 java8.com
: U. @$ B- Z) u0 U N/ e" g; I+ Z% a! \
作者:李伟出版社:电子工业出版社出版时间:2020年07月
/ I8 o6 d6 G$ d! d' E
+ Y) R" U& ~! X w9 R& a; o编号：166-Java吧资源免费-X0191【Java吧 java8.com】" j, `6 H, S! L8 ?8 Z
s0 M9 c6 I+ M0 \! v6 \$ ~6 r# i1 u4 ~. @
2 K9 F7 n1 s% m4 [目录：) x% C; z* }! I4 `
第1章 RoketMQ综述 16 s, q& i+ g# o% W
1.1 什么是消息队列 2
$ c, a1 H& H- K8 u& k3 j$ \$ ?6 J5 [1.2 为什么需要消息队列 45 A& `; F; s# V* d; _
1.2.1 削峰填谷 42 A8 `2 U, ^6 _2 X3 W" a
1.2.2 程序间解耦 5
* Y9 q: }- r" V. {0 A. A1.2.3 异步处理 6% K7 M- C" h( T+ v
1.2.4 数据的终一致性 6* a7 l" e. v: I" S9 Q& i2 p! n
1.3 常见消息队列 7
. u4 F! A% Y% u" q1.4 RocketMQ的发展史与未来 9
1 S6 g: i# S a6 R. _1.4.1 RocketMQ的发展史 9& j6 I+ r% d- [8 J+ V% M6 |* C1 I1 f0 w
1.4.2 Apache RocketMQ的未来 111 F8 O4 m- g/ E+ n% u ]; B" q
第2章 RocketMQ的生产者原理和实践 14( X- u( Y8 g) H W) P
2.1 生产者原理 15
; G+ ?) {9 i+ R2.1.1 生产者概述 15
/ W: ?: C b* ?/ r, H3 S: b2.1.2 消息结构和消息类型 169 |' S3 Y7 U9 G% C4 `2 P# u$ Q
2.1.3 生产者高可用 17
0 W$ F* r6 X$ U: {2.2 生产者启动流程 22: f/ T1 w; ^% U6 o' }
2.3 消息发送流程 32
4 N+ L2 v8 @8 W2 r1 Q8 [2.4 发送消息实践 36
1 T W" v' k5 n2.4.1 发送普通消息 36
3 X5 B: ?" h9 U ?6 i2.4.2 发送顺序消息 37# k$ I! @( U% d# j( p& A
2.4.3 发送延迟消息 37
, `9 h; r/ `. B; z6 [9 ]$ K2.4.4 发送事务消息 38
2 k9 l) L; C# O2 b2.4.5 发送单向消息 40
9 }$ ~* u/ ~. a/ R8 i5 P2.4.6 批量消息发送 41+ C- \& h: s5 K R; J4 ^5 S
2.5 生产者实践总结 427 s- O) _5 K6 Z) \* |) E f5 b
第3章 RocketMQ的消费流程和实践 44' E0 m. w" x" p; C8 G5 }4 ~0 G
3.1 消费者概述 45
# w, ]2 Q0 D5 y3.1.1 消费流程 45
: K9 i. P, y" D! @3.1.2 消费模式 46
& N/ t4 e2 c9 i( L G3.1.3 可靠消费 48( a6 ~2 o5 ~$ i
3.2 消费者启动机制 50
- s7 a& H) Y4 ]) Y3.3 消费者的Rebalance机制 580 [9 ?5 u4 y* Z2 X. H
3.4 消费进度保存机制 65* H o: q' W/ K1 [% S
3.5 消费方式 70
$ h8 y/ |0 G# E0 N- s3.5.1 Pull消费流程 71
' K6 x- M' B$ S |% t, H) I3.5.2 Push消费流程 72# ?% @' e7 s' s/ F$ i
3.6 消息过滤 86* ~$ g7 l; x) [7 ~+ W. l
3.6.1 为什么要设计过滤功能 86
! O4 n! O) f* {: H5 A: n3 l3.6.2 RocketMQ支持消息过滤 86
6 F4 X# Z2 ?) o6 o" ^5 ]3.7 消费者实践总结 91" k0 y9 a+ V' T H, p/ ~% s9 \
第4章 RocketMQ架构和部署实践 94
6 F1 T6 ] Y* p- D) Z4.1 RocketMQ架构 958 H g+ h( n' N9 J/ w/ ~
4.2 常用的部署拓扑和部署实践 96
$ W- S f* p' K3 ]" Q/ M4.2.1 常用的拓扑图 96
. R! d+ k( T1 e4.2.2 同步复制、异步复制和同步刷盘、异步刷盘 97
+ a4 l; g& t; I7 u1 J( a% |% o4.2.3 部署实践 98/ p( E& V# B9 C& r& v8 i8 N9 Q
第5章 Namesrv 102
5 F4 c V' ?4 Y& r' q" C3 B" y `; L5.1 Namesrv概述 103
# i; t( P: Q0 y) E5.1.1 什么是Namesrv 103
# f& E0 S$ |2 N0 B5.1.2 Namesrv核心数据结构和API 1037 m3 H7 F5 Z/ l. [) V
5.1.3 Namesrv和Zookeeper 1057 Y o% ~5 O/ [8 _
5.2 Namesrv架构 106
0 p i7 B0 t, c+ m) f5.2.1 Namesrv组件 106
1 B) y3 A# c7 x* B! h5.2.2 Namesrv启动流程 108
0 G* Y2 m( g% P& K: X4 O5.2.3 Namesrv停止流程 110! @$ Z/ l- v! q8 y
5.3 RocketMQ的路由原理 111
2 K" v% L. S* ~5.3.1 路由注册 111/ G7 B3 {' l! E5 N7 t
5.3.2 路由剔除 112
+ J: \( ]; s' v. s第6章 Broker存储机制 1141 n( ]4 T" \9 _1 ]+ |1 P/ S
6.1 Broker概述 115
4 @1 y+ Y- G5 ]' r! ^8 [/ H6.1.1 什么是Broker 115
2 y8 @$ B9 Z5 p# W* w6.1.2 Broker存储目录结构 116
. p) q7 [3 y/ W7 z1 P, j$ P) q6.1.3 Broker启动和停止流程 117) _/ _+ {; B5 T: d( c
6.2 Broker存储机制 125! v2 B4 V }3 K8 T
6.2.1 Broker消息存储结构 126; @6 l' c- H, o% l8 p' u4 i
6.2.2 Broker消息存储机制 130! F8 Z5 c5 q/ }1 ]+ p
6.2.3 Broker读写分离机制 150
$ }# J0 V- P8 `8 Q& D2 N1 c2 u2 ^1 b6.3 Broker CommitLog索引机制 155
7 g/ ~* g+ |# u6.3.1 索引的数据结构 155: _) Y: H' {, K& d( H
6.3.2 索引的构建过程 158
- U9 t4 t! v( W/ D! l6.3.3 索引如何使用 159& I4 _8 o% ?, R
6.4 Broker过期文件删除机制 162
5 I4 R8 y' h6 }6.4.1 CommitLog文件的删除过程 162: R- G/ P% J* m% X: j
6.4.2 Consume Queue、Index File文件的删除过程 166
+ t" q8 p6 \! r' s9 [6.5 Broker主从同步机制 167
' K$ I6 g) {3 m: Q6.5.1 主从同步概述 168
& q9 [7 }9 b* _6.5.2 主从同步流程 1697 R5 k( G4 F% Q+ n, v
6.6 Broker的关机恢复机制 1740 o6 }. y: e6 S! X
6.6.1 Broker关机恢复概述 174
2 U6 \3 [! X/ N9 Q9 Z$ Y6.6.2 Broker关机恢复流程 177
! p0 X& \( W: \) Q; a/ \8 V第7章 RocketMQ特性——事务消息与延迟消息机制 182
. J8 Z- I4 m( u$ o& b- m* U: m4 E5 C7.1 事务消息概述 183/ {. U3 x& _+ w& q
7.2 事务消息机制 1842 b: c! Z& T$ b7 e N9 D
7.2.1 生产者发送事务消息和执行本地事务 184: t+ p8 K3 m4 V# a' j
7.2.2 Broker存储事务消息 188
& e. }. E/ `; @5 K: Y3 ?# Z: T7.2.3 Broker回查事务消息 191
' E( \9 ]3 Y, \2 ^7 h- g- l7.2.4 Broker提交或回滚事务消息 197) n3 K6 s+ Y4 M# |
7.3 延迟消息概述 201 F4 s5 n# E$ O
7.4 延迟消息机制 2038 x, ~% M- n1 F- q' s9 i6 Y
7.4.1 延迟消息存储机制 203
6 P9 A C8 [1 z# y8 n7.4.2 延迟消息投递机制 2050 s7 w$ V3 f2 }' ^. z% q
第8章 RocketMQ源代码阅读 208+ O! e2 m- x4 |" Y; E
8.1 RocketMQ源代码结构概述 209
* b. R j7 E7 M4 f3 a4 H# w6 [+ P8.2 RocketMQ源代码编译 2124 V6 K4 G4 X( A @
8.3 如何阅读源代码 214
4 R4 a% D* u" Y& B! Z8.4 源代码阅读范例：通过消息id查询消息 2164 P [3 \6 a2 E3 z& b
第9章 RocketMQ企业实践 224
3 J; Q- C" D6 n4 t9 t# E9.1 RocketMQ落地概述 225
3 I3 `7 j& }& @( X+ w3 N8 U9.1.1 为什么选择RocketMQ 225* ?7 S& O) c% G- }5 T1 i! H ^
9.1.2 如何做RocketMQ的集群管理 226
8 G' ?1 Z1 H/ N1 l! W9.2 RocketMQ集群管理 230
! T9 H- T4 T1 ~$ W* i9.2.1 Topic管理 230 java8.com
3 A2 t8 }" ]" k9.2.2 消费者管理 235: @ m3 B. R) p. Q/ b% N# ]2 S
9.3 RocketMQ集群监控和报警 240
, z' H& Z" L+ q9.3.1 监控和报警架构 240 F* @8 Z) R" m" B* `
9.3.2 基于Grafana监控 242
# y" _- `/ m1 G5 ^# w* E$ z9.3.3 基于Prometheus的报警 243
" {! q6 t% g% w: g9.4 RocketMQ集群迁移 244( p; F. W7 L0 Z3 ^: w @
9.5 RocketMQ测试环境实践 245# k, z; m: {7 k% G/ }) c) `
9.6 RocketMQ接入实践 247
+ p: G3 U) ^6 K3 e% f/ U9.6.1 Spring接入RocketMQ 247
7 h. ^2 s/ i: n/ m9.6.2 Python接入RocketMQ 2493 Y: \6 B3 ^& v. P4 t# L2 I
附录 252
2 d; c# t# l0 c3 w, a) l' L 3 ^; G$ n8 A8 z: u% C* O' A
?* J1 B1 c! O
2 @, G& L6 Q: K% l* G2 Z
- ~$ @8 d5 p5 g. h$ r7 \$ o
6 n+ s& A2 ^! Z7 [$ J( K* v4 d/ J
% p% ]8 W3 `7 y+ S, D1 ~
|
本帖子中包含更多资源
您需要 登录 才可以下载或查看，没有账号？立即注册
x
|
电子书
2287 人阅读
|
33 人回复
|
2024-03-19
