TA的每日心情 | 开心
4 天前 |
|---|
签到天数: 40 天 [LV.5]常住居民I
管理员
- 积分
- 2824
|
Java电子书：RocketMQ分布式消息中间件：核心原理与实践 PDF 电子书 Java吧 java8.com
9 T- b- @5 y( v* f7 u* q( ?# R# F7 ~/ g( K* P' m4 a
作者:李伟出版社:电子工业出版社出版时间:2020年07月
, { v* [0 t( H, g. ?+ d0 \3 b) K- [
4 \' C3 S' H6 T2 T8 ]4 M" w编号：166-Java吧资源免费-X0191【Java吧 java8.com】
5 z' g: s$ z4 N7 E, e9 T0 O
# e& Z# _9 M! g9 n+ y$ i/ d) \9 f' P, f" e8 _) M- k
5 j ~& O, \) f2 B
目录：
6 i5 s; F! C! u; W% T第1章 RoketMQ综述 1$ U5 q) e6 Y! R8 G- M. v
1.1 什么是消息队列 2
4 @6 P; H" o! {4 s8 h1.2 为什么需要消息队列 4
4 V& [9 w1 L2 _. X. l2 M$ @1.2.1 削峰填谷 45 N: W* R; ]/ k1 X8 y' a& C, a N
1.2.2 程序间解耦 5
. g2 \/ _: K0 M- r% \ [: m) t1.2.3 异步处理 6
' g: P" h% y+ U) u8 B% d3 r! e5 v7 b1.2.4 数据的终一致性 66 l6 ~* O! i% P& e/ ]5 @) B
1.3 常见消息队列 7% n" W9 W+ i0 i" N& y
1.4 RocketMQ的发展史与未来 9
c A0 u9 d C; z0 d8 h1.4.1 RocketMQ的发展史 96 d2 w" E9 h) {/ J/ G- T) Z
1.4.2 Apache RocketMQ的未来 115 ^0 N. O# v! i; E: Y, X; i; r) e
第2章 RocketMQ的生产者原理和实践 14
1 n) j; ~) l$ B& \, n+ F1 E" I. H2.1 生产者原理 15, u$ B! b, @& ~: R# o% R
2.1.1 生产者概述 15
* e$ w4 A: h% ]# U0 @2.1.2 消息结构和消息类型 16
; h# m( E' n" x- Q2 t5 v u. L2.1.3 生产者高可用 178 i: E# e0 P5 B& L. A9 v, ]
2.2 生产者启动流程 22
2 r" j) Y V; |2.3 消息发送流程 32
, x3 f% u# Y5 l2.4 发送消息实践 36
) f3 c) |" W( w) T2.4.1 发送普通消息 36* H6 K& e i2 X$ d8 W
2.4.2 发送顺序消息 37# }* ]( U+ x2 X5 J6 b q
2.4.3 发送延迟消息 37, @1 S. z( e5 }# G9 ~7 c
2.4.4 发送事务消息 38
3 x, a) f R" c2.4.5 发送单向消息 40$ p2 K$ h# e( w c4 ]9 E1 k$ F
2.4.6 批量消息发送 41
' ?3 I$ d, O5 l: n: r2.5 生产者实践总结 426 B- B6 n- q) J& R1 F0 `0 W
第3章 RocketMQ的消费流程和实践 44
0 `8 Y7 B; d C4 _4 c! T* H. t3.1 消费者概述 45
: M2 ~' z, j* g. Z- V1 w: K3.1.1 消费流程 45
8 J6 ]/ U4 v% _1 I: X3.1.2 消费模式 46+ |9 Z D9 B- t
3.1.3 可靠消费 48
* _# ]: ~ z& @' P& U- w3.2 消费者启动机制 50+ z" W2 @2 m- U M4 e" N
3.3 消费者的Rebalance机制 58% q T) p$ ^. T: n( [! X
3.4 消费进度保存机制 65 v4 n" _) ^7 w- _
3.5 消费方式 70
9 Z" y1 ?0 p0 Z6 h# \; y3.5.1 Pull消费流程 71# |7 v" H* F4 x" ~& @5 g2 E9 _7 j* p: L
3.5.2 Push消费流程 72
" T' f: j6 R+ `8 Z* n3 L$ y. P" n! I3.6 消息过滤 868 }# G' ^7 S+ ]5 _: \: t8 s2 `
3.6.1 为什么要设计过滤功能 86
3 e/ M+ o4 n8 J( b: K+ r" I8 {9 ~3.6.2 RocketMQ支持消息过滤 86
8 l7 A& V. L* M) V! L; p3.7 消费者实践总结 91 m: {7 }- Q q0 T
第4章 RocketMQ架构和部署实践 94
$ m+ C: n7 |6 Q# O4.1 RocketMQ架构 95
+ `$ K) f! a8 B1 ~- Q! c- U$ W! g8 W4.2 常用的部署拓扑和部署实践 96
F( H! V, q, u* m5 O4.2.1 常用的拓扑图 96" ^1 q& \; a/ v* Q" P1 ?: y0 f
4.2.2 同步复制、异步复制和同步刷盘、异步刷盘 97
7 @* I+ [: i8 f- Z; M4.2.3 部署实践 98
2 k1 ?! S n3 D `/ R2 j, ~* c第5章 Namesrv 102, `) x' o+ K- ?
5.1 Namesrv概述 103. T" J: N) R1 l, P) R8 [
5.1.1 什么是Namesrv 103
- }# U0 [* t+ `9 w5.1.2 Namesrv核心数据结构和API 103
5 O# L8 Q1 Y( d- I2 b. {$ B- d |5.1.3 Namesrv和Zookeeper 1058 I" p# E: _7 ~/ p+ C
5.2 Namesrv架构 106
# R+ F4 a! T& B$ K5.2.1 Namesrv组件 1069 G$ I& b4 D3 X+ L
5.2.2 Namesrv启动流程 108
0 X) _" z" S" Y* t5.2.3 Namesrv停止流程 1101 Y6 u/ i, u% e: `. O5 v( J: _
5.3 RocketMQ的路由原理 111# d. Z& C+ K6 J2 a4 d" G/ g' z
5.3.1 路由注册 111
* a: @0 u" B" G: t5.3.2 路由剔除 1120 E2 Z- Y/ c( [6 a( ?
第6章 Broker存储机制 1149 t; K' @ e5 ?5 w. {
6.1 Broker概述 1159 s" v) E6 w- O6 }
6.1.1 什么是Broker 115
3 R% \8 k2 u6 p) `6.1.2 Broker存储目录结构 116
, ~. ?4 M( S, Q' U6.1.3 Broker启动和停止流程 117+ z* K, c, P& K3 `: l9 v: V$ J
6.2 Broker存储机制 125: ^' Z1 B% k" ]) h
6.2.1 Broker消息存储结构 126% y2 k; B3 }5 g0 t$ e( f
6.2.2 Broker消息存储机制 130' F$ g" z: i: r W/ z
6.2.3 Broker读写分离机制 150
) P" G( G/ Q# @+ ~4 ~/ @5 |6.3 Broker CommitLog索引机制 155
; _+ R6 v, `2 _" b6.3.1 索引的数据结构 155
: U# V# ?$ x5 w0 a9 j) l9 d+ T6.3.2 索引的构建过程 1587 t4 \. i* F0 u* @/ r5 _9 |1 X7 u" `
6.3.3 索引如何使用 1593 k# B: t2 e/ Z3 u$ [! b! M& f
6.4 Broker过期文件删除机制 162) Q/ N+ @0 W9 r' ?2 A9 U
6.4.1 CommitLog文件的删除过程 162
# m h: i% Y* x7 D# l# ?! g6.4.2 Consume Queue、Index File文件的删除过程 1668 [ M) x- {( C, @6 [: C4 }+ K
6.5 Broker主从同步机制 167' c {" H `. \1 k4 u
6.5.1 主从同步概述 168
2 A1 w! M, E7 o6.5.2 主从同步流程 169- f: m9 E( Y0 l
6.6 Broker的关机恢复机制 1745 N; x# ?+ E$ D
6.6.1 Broker关机恢复概述 174
3 Y5 j# w7 z* v, u+ u' z; [6.6.2 Broker关机恢复流程 177, y1 f: a# M$ x( g2 Q0 ?9 f p
第7章 RocketMQ特性——事务消息与延迟消息机制 182
( _' g& [6 u5 ~# B+ h6 r( y6 s7.1 事务消息概述 183* N* U/ N3 \8 I+ @, J8 f
7.2 事务消息机制 184/ L3 w9 a/ r% P
7.2.1 生产者发送事务消息和执行本地事务 1844 o3 G9 F! f% L7 }9 n
7.2.2 Broker存储事务消息 188! ~6 t# M% U% l0 s" o: N0 X4 g
7.2.3 Broker回查事务消息 191: s9 ?4 i, j3 A& N* g( `7 ?
7.2.4 Broker提交或回滚事务消息 197
2 n0 T) w+ d' y- I# O, g* [7.3 延迟消息概述 201
: q$ H. T7 U. H' h0 G1 k, P7.4 延迟消息机制 2036 s7 @/ M# h4 |# t$ M$ z
7.4.1 延迟消息存储机制 203
4 s9 H$ p5 @, [) X7 L. L2 b) Q7.4.2 延迟消息投递机制 205
) [# Q: H1 |1 f0 w' i第8章 RocketMQ源代码阅读 208
. {7 ~( |# A6 @) n2 _: O: v8.1 RocketMQ源代码结构概述 209
6 a- ]7 F7 |/ ~5 X( T* n1 H8.2 RocketMQ源代码编译 212
- Y( S# {8 m. m! Q0 I. T8.3 如何阅读源代码 214! a+ L; p) z) P( i
8.4 源代码阅读范例：通过消息id查询消息 216
( n) [) i1 R8 S/ D' U9 Q' Z第9章 RocketMQ企业实践 224/ I1 I3 I! j) |+ d" h8 I4 K
9.1 RocketMQ落地概述 225 }5 h; y! a# o& B- t0 H' D
9.1.1 为什么选择RocketMQ 2250 l7 w( h+ T8 D3 y1 R/ a
9.1.2 如何做RocketMQ的集群管理 226
6 m. }* g6 [* }& r" O1 g9.2 RocketMQ集群管理 230
/ W5 _7 j" |6 y: ?9.2.1 Topic管理 230 java8.com: {' t$ ]8 x' J: c
9.2.2 消费者管理 235% j+ |0 s1 z! K. P) a2 {
9.3 RocketMQ集群监控和报警 240! w5 m+ h7 d7 B I. U& e
9.3.1 监控和报警架构 2409 u9 ^' A: w3 J7 j
9.3.2 基于Grafana监控 242+ u9 d# H7 I! f) w2 r1 Y
9.3.3 基于Prometheus的报警 243
. d6 A8 S; {; P0 v/ w, |# _. c9.4 RocketMQ集群迁移 244
. K( r7 U" G% I# {9.5 RocketMQ测试环境实践 245" ` j, p3 r- m" t; S! m; m( d
9.6 RocketMQ接入实践 247; B7 F8 @1 F1 m
9.6.1 Spring接入RocketMQ 247/ j6 Z# Q1 D7 H5 E$ j2 m
9.6.2 Python接入RocketMQ 249
' {: U$ e% c/ [附录 252
9 A; K7 [4 C; u, O, ^( ] : v: ~( q! Y' k% b7 T5 \, V
: l" k: F; h) l$ g9 J/ ]
7 S1 l6 o8 I, C3 r0 y o0 V% }
0 O& S8 D3 D2 F7 X& U# c( \; y
! G( X$ x3 o; b. m& E
" _: a- G) x" E2 V* G3 n( e; q' y z |
本帖子中包含更多资源
您需要 登录 才可以下载或查看，没有账号？立即注册
x
|
电子书
309 人阅读
|
27 人回复
|
2024-03-19
