TA的每日心情 | 开心
4 天前 |
|---|
签到天数: 40 天 [LV.5]常住居民I
管理员
- 积分
- 2824
|
Java电子书：RocketMQ分布式消息中间件：核心原理与实践 PDF 电子书 Java吧 java8.com
! ?% C U) K! L; z4 `/ ^0 Z, l- ^2 n# e9 h( Y* n: O$ V
作者:李伟出版社:电子工业出版社出版时间:2020年07月
4 X, s! G7 R/ U. d6 y2 X1 _: c( y' z3 c& B; w/ E
编号：166-Java吧资源免费-X0191【Java吧 java8.com】1 r1 M4 s: Q3 c. U
" x+ ?4 s; c% _( ~
* i& d6 U4 m7 W/ v- E/ {
7 ]4 ]( {" B. U) Z& j1 r, k
目录：5 X x* T. H. ?, F8 e) w
第1章 RoketMQ综述 10 ~* [( E7 b0 [5 P: P4 y2 {
1.1 什么是消息队列 2
" O: `. o" ?# `2 A3 s' ~& g1.2 为什么需要消息队列 4& t# {8 r, K9 F. x. u
1.2.1 削峰填谷 40 L7 R3 U/ f0 S8 @3 ^
1.2.2 程序间解耦 5; t5 ^; Z1 x2 R0 S# ?+ R4 E B0 u
1.2.3 异步处理 61 G1 t, W: ?( u. V7 v( W
1.2.4 数据的终一致性 6
9 n4 ]/ U* f) i$ e$ U/ A1.3 常见消息队列 7" J/ b0 J! b& |/ U+ T' {! ~
1.4 RocketMQ的发展史与未来 9! k% c$ _1 `+ `. D5 H
1.4.1 RocketMQ的发展史 9
/ C6 D" E, ]/ A; A1.4.2 Apache RocketMQ的未来 11
1 V8 X0 P& i' C6 f3 t8 W" t9 _第2章 RocketMQ的生产者原理和实践 142 P- w6 R- E- n$ ]. D8 f
2.1 生产者原理 151 V7 U( N8 O7 _/ U& |( ~
2.1.1 生产者概述 158 s7 `4 |# Z! F( z) N4 t
2.1.2 消息结构和消息类型 16/ n. k1 u( ^7 ]5 P# u+ B+ K
2.1.3 生产者高可用 17" ~/ N# m. v% o2 S
2.2 生产者启动流程 22
8 p* c1 M4 C3 ?) |! S8 }; y2.3 消息发送流程 329 q1 D+ J# K% L, G
2.4 发送消息实践 366 g. H( i* n* f' j0 J* `2 a
2.4.1 发送普通消息 36! _( ^$ H4 V9 ]" D
2.4.2 发送顺序消息 37
: M) b9 j+ H4 o: D% _2.4.3 发送延迟消息 37- f5 ?% g a( T4 R7 Y9 h
2.4.4 发送事务消息 38
, a3 }: M' [9 Q0 h2.4.5 发送单向消息 408 v, x( g0 u1 F' i
2.4.6 批量消息发送 41
! j, \% l: n5 E3 W; Z2.5 生产者实践总结 421 z& Q8 ^0 ~# ?4 _' T4 P
第3章 RocketMQ的消费流程和实践 44" z) j& i8 ^# F4 l3 f
3.1 消费者概述 453 l: V* T, L2 `
3.1.1 消费流程 45
; L8 y) G% _8 _& i0 O3.1.2 消费模式 46
" n& r8 P7 Y- [* L5 \1 l# T3.1.3 可靠消费 48
& i# g/ D9 D8 o) U: @) `3.2 消费者启动机制 50: X, i% K) e; X; Y7 M9 E
3.3 消费者的Rebalance机制 582 B8 R% t6 `4 f3 Z$ h1 `
3.4 消费进度保存机制 65
) a- H/ q" V. W7 z2 U7 }9 l3.5 消费方式 70
8 d2 ^6 |* q+ T3.5.1 Pull消费流程 71
$ H |" M$ \$ ~$ j3.5.2 Push消费流程 72
7 w% e# @8 M" m! @$ l3.6 消息过滤 86
+ P6 {4 S, ^% @3.6.1 为什么要设计过滤功能 86
: D. s/ g8 a* l- y: h C5 D3.6.2 RocketMQ支持消息过滤 86
' Z4 f2 H1 s. C3.7 消费者实践总结 91, N) N, ^) W8 a5 }& ~# N7 K
第4章 RocketMQ架构和部署实践 948 I# O: D* b- W1 Z; }# o; M& `$ i$ r
4.1 RocketMQ架构 95
4 d! Y) ]8 _5 j1 |$ K4.2 常用的部署拓扑和部署实践 96" O8 v; \' U( N; Y
4.2.1 常用的拓扑图 96- L# Q0 v# y' [; {
4.2.2 同步复制、异步复制和同步刷盘、异步刷盘 97
9 y! e! M8 R+ o1 n1 N2 f' C4.2.3 部署实践 98/ a* m6 ]' r! Z! ]* @# \6 f0 S
第5章 Namesrv 102 R% _3 J5 j: K* H/ k* N- y
5.1 Namesrv概述 103! f/ V! x, }, f, ?3 j. X
5.1.1 什么是Namesrv 103$ \ L0 W: V) ~
5.1.2 Namesrv核心数据结构和API 103% f9 [( Y* Q- ~2 E
5.1.3 Namesrv和Zookeeper 105, P$ I j9 J" l4 F _9 K+ k
5.2 Namesrv架构 106
: U3 m% g, Z" d7 |1 H5.2.1 Namesrv组件 1067 L ?! l3 m# ^; k$ _, y3 h
5.2.2 Namesrv启动流程 108
}) d/ G2 ]( y* p! G5.2.3 Namesrv停止流程 1107 w4 E; |9 O! L# N1 b
5.3 RocketMQ的路由原理 111
6 G0 p/ t3 z4 Z5 e! q& H% X5.3.1 路由注册 111
- ^/ X& L. J0 V5 q4 X5.3.2 路由剔除 112
. n) v- T7 M2 V2 T7 s第6章 Broker存储机制 114, W& D3 G) j4 j0 ?, X
6.1 Broker概述 115( U" y5 v9 O6 X
6.1.1 什么是Broker 115
4 I5 U9 {0 O7 l( S" i6.1.2 Broker存储目录结构 116
, a E" m+ k( V( W1 P6.1.3 Broker启动和停止流程 117
& d4 B- L# f+ V( d6.2 Broker存储机制 125
- g- K* K& C, c7 T, w2 O4 R6.2.1 Broker消息存储结构 126
& X! F3 Q8 U, k8 D3 e6.2.2 Broker消息存储机制 130" p4 D, p" _+ c. ?4 }! P
6.2.3 Broker读写分离机制 150) y5 t' Q. |/ L8 Z+ @9 Z- P! Y
6.3 Broker CommitLog索引机制 1558 ?+ z( N. m; W
6.3.1 索引的数据结构 1552 U7 F) C( u- k- S ~
6.3.2 索引的构建过程 158. ?7 R3 i, z S9 p! e% x
6.3.3 索引如何使用 159
& [" D! G, P8 i, s2 r& w6.4 Broker过期文件删除机制 162
- p5 {" [5 |5 i, f3 l _; r6 n6.4.1 CommitLog文件的删除过程 162
( F# { |% V( b, X" r6.4.2 Consume Queue、Index File文件的删除过程 166% |$ S# B2 v$ z! }& \( a% I
6.5 Broker主从同步机制 167, P' A* m m: G+ x
6.5.1 主从同步概述 168+ B: N4 r* n3 F
6.5.2 主从同步流程 169) I! O# v/ v% _7 G) ?) u! Z, u% u3 d( I
6.6 Broker的关机恢复机制 1740 }3 U2 X. }5 @% s( c1 ^
6.6.1 Broker关机恢复概述 174
- K; m1 X; f; |7 Q5 S5 |+ I6.6.2 Broker关机恢复流程 177
+ b3 K# o. r! [7 z* D0 f% d# Y第7章 RocketMQ特性——事务消息与延迟消息机制 182: P% M$ e' A1 R* C
7.1 事务消息概述 183
g' X* o, o- O, x- Q7.2 事务消息机制 1849 l6 q. K+ r F9 N" d
7.2.1 生产者发送事务消息和执行本地事务 184
+ B, q& e/ ~7 C- r K1 h7.2.2 Broker存储事务消息 1884 O7 W, t) q4 P, l0 ?# h2 ]4 w
7.2.3 Broker回查事务消息 1918 M0 G8 I6 ]% N B) U
7.2.4 Broker提交或回滚事务消息 197
0 _& K& b" b9 B' b' X7.3 延迟消息概述 201
8 A" i! p$ w% m9 z0 L( p7.4 延迟消息机制 2039 G# Z, ^ D4 ]8 a8 d4 i! `
7.4.1 延迟消息存储机制 203 f, u# s+ K5 ~& W4 r; I
7.4.2 延迟消息投递机制 205+ @) }' e9 ^+ P7 W1 D
第8章 RocketMQ源代码阅读 208
8 A2 E- s9 O# W0 W/ Y8.1 RocketMQ源代码结构概述 209! E4 V2 V% o' Y. `$ f: ]% @
8.2 RocketMQ源代码编译 212% G& D" z/ k, V
8.3 如何阅读源代码 214
/ ?+ a' g# O. {( s5 r0 q8.4 源代码阅读范例：通过消息id查询消息 216$ |$ E4 p5 j% P2 |- Y
第9章 RocketMQ企业实践 224
6 S D% m" B# w. t* V- Y9.1 RocketMQ落地概述 225' r2 q; D; ?* E7 L$ N5 q0 _6 k
9.1.1 为什么选择RocketMQ 225
" B6 u" j; Q1 F: M. M9.1.2 如何做RocketMQ的集群管理 226
* e9 Z/ A* N. ]' l9.2 RocketMQ集群管理 2304 V; s( Q+ @9 X9 Z9 d* M
9.2.1 Topic管理 230 java8.com
% O% I* I( R9 c/ O9.2.2 消费者管理 235
1 A' ]! m6 K$ ?4 Q5 @3 \9.3 RocketMQ集群监控和报警 240
$ G; x: D5 c \2 C9.3.1 监控和报警架构 240
; c) c1 p o2 V8 @' ?" M3 k9.3.2 基于Grafana监控 2426 \& x7 \* C2 G* J2 ?
9.3.3 基于Prometheus的报警 243
8 ?0 m, P! L0 l h; o E9.4 RocketMQ集群迁移 244+ l' I9 Y- j: w3 E \/ P
9.5 RocketMQ测试环境实践 245# u1 P' s$ O7 V+ N
9.6 RocketMQ接入实践 247+ ^" _# E3 n0 U2 [3 d
9.6.1 Spring接入RocketMQ 2473 O) `2 ?; W" m9 f
9.6.2 Python接入RocketMQ 249
- h) \+ P& f7 {- t1 h/ f附录 252
4 {) E+ @9 n4 P& O4 r7 A
& b( z9 L' j- z4 U8 q
: ^* ^$ L6 [; j% y! h
3 ^' p. d2 e% @; f
' ~" M. I. b; ~, Q. Y+ d g: Q4 F3 a" o% P
* l! |( Y8 w+ e; h8 S/ l6 Y* Q2 ?
|
本帖子中包含更多资源
您需要 登录 才可以下载或查看，没有账号？立即注册
x
|
电子书
307 人阅读
|
27 人回复
|
2024-03-19
