TA的每日心情 | 开心
昨天 10:36 |
|---|
签到天数: 393 天 [LV.9]以坛为家II
管理员
- 积分
- 12895
|
Java电子书：RocketMQ分布式消息中间件：核心原理与实践 PDF 电子书 Java吧 java8.com
6 S( Z6 K$ [. u8 T: u
8 W9 u3 U# O6 k- t7 a/ v作者:李伟出版社:电子工业出版社出版时间:2020年07月 2 n0 R% Y. p+ P
: o0 n# P! p3 G Y- O0 ]1 Y编号：166-Java吧资源免费-X0191【Java吧 java8.com】
5 n! Z, Y7 `& [; `* L: f7 q: N, N# D) p3 }* _2 V! Q1 v; o/ w+ X, Y. L
9 A- x! |, ]5 W" j
l# K: l) ~/ q4 t0 m5 B: F
目录：$ t/ k: U* z% n- \4 j% a) D0 E2 q9 p
第1章 RoketMQ综述 1
4 _( t; z. e5 H- p- z1.1 什么是消息队列 2
0 V4 N& G" C+ ^8 Q8 S# M& U# p1.2 为什么需要消息队列 4) i7 i0 l8 G& @0 F+ k ]3 N. `3 |
1.2.1 削峰填谷 4, C! H% E$ u6 W9 s7 a
1.2.2 程序间解耦 5
, f# c, V' j1 G9 |1.2.3 异步处理 68 P! T: I; N+ {: o( w) t" i
1.2.4 数据的终一致性 6
: v c! f) \( f d6 \1.3 常见消息队列 7
( r; p" n% t; k3 Y# r1.4 RocketMQ的发展史与未来 9
9 K7 x# q' C' ?1.4.1 RocketMQ的发展史 9
' ^* e6 G% [6 `4 f4 Y1.4.2 Apache RocketMQ的未来 11
- E8 o7 L- x4 B& l9 T第2章 RocketMQ的生产者原理和实践 14
# |$ o+ G$ P: v$ |) {9 z9 \5 P2.1 生产者原理 15
* u1 v$ {4 @/ k$ G0 X1 Q2.1.1 生产者概述 15
9 `1 [6 g+ T* n4 U7 j2.1.2 消息结构和消息类型 16
9 d* Y4 A9 J) f2 C3 F4 `/ V2.1.3 生产者高可用 174 ]# D! z' \. L
2.2 生产者启动流程 22
. ^6 [8 `. v9 Z# v& ?! G2.3 消息发送流程 32
7 b0 A2 H5 V) C, w9 U: |9 N2.4 发送消息实践 369 }( P, j* i1 k7 p% ^
2.4.1 发送普通消息 36
- c# L, U5 \0 b8 Z2.4.2 发送顺序消息 37! c4 o+ R, K6 A" i
2.4.3 发送延迟消息 379 v9 m" {4 S, K7 t
2.4.4 发送事务消息 38' d6 b1 G; I( {+ M' O
2.4.5 发送单向消息 40
+ M0 I8 u% M3 d* ^7 H# X2.4.6 批量消息发送 41
$ X0 |. `* {# w$ Z" [: H) C& Z2.5 生产者实践总结 42% i7 E" w4 v( }' U% N0 m8 z
第3章 RocketMQ的消费流程和实践 44
$ W5 W B+ k+ u! A- q' R1 u6 z. K3.1 消费者概述 45
* K; x6 u1 u3 i: |3.1.1 消费流程 45
" r5 f( L- D+ {; {. }' \3.1.2 消费模式 46
7 h6 l2 M8 o7 `4 |* N- u3.1.3 可靠消费 48
: o4 _ } m8 b$ v) N- e' L7 G3.2 消费者启动机制 50
. W, r+ J& {' F+ l3.3 消费者的Rebalance机制 585 g& x& f7 `$ `
3.4 消费进度保存机制 65- p' q, K. d" ~( {1 F; ]; d
3.5 消费方式 70) p' J% O% ?( a
3.5.1 Pull消费流程 71
( b. }& b1 Q+ w( I+ C( G3.5.2 Push消费流程 725 u% }& |% f& f" I0 _# ^; `
3.6 消息过滤 86
0 Z6 D. ?0 L) l( s8 e7 \" }4 c3.6.1 为什么要设计过滤功能 86& \1 M. C" b$ c( p1 R0 Y5 S( T& ]
3.6.2 RocketMQ支持消息过滤 86
7 p' S2 |0 t( F' A" ]/ N/ O3.7 消费者实践总结 91
' x+ A9 t8 G5 T5 z* E第4章 RocketMQ架构和部署实践 94) S1 S2 o3 t4 l; |. U
4.1 RocketMQ架构 95
. S3 \' N9 c) j# z8 s% u/ H4.2 常用的部署拓扑和部署实践 96
' Y; u R# d+ y$ g, B5 ~2 s1 R8 K4.2.1 常用的拓扑图 96
, c$ f2 ^' R- u& x. p5 V4.2.2 同步复制、异步复制和同步刷盘、异步刷盘 974 `' X' X) Z' r
4.2.3 部署实践 98* ^. t& }1 D3 I
第5章 Namesrv 102
3 ]3 g/ W# M" ~8 e3 Y: b5.1 Namesrv概述 103( n/ A+ s$ G/ g: O3 T3 b+ I
5.1.1 什么是Namesrv 103' b7 b# V7 a! {4 A. {
5.1.2 Namesrv核心数据结构和API 103" ~8 x0 {% T( x3 @
5.1.3 Namesrv和Zookeeper 105
' l8 [7 J5 W* _+ L5.2 Namesrv架构 106
! H( @4 u6 u& r0 C0 A I5 T' y5.2.1 Namesrv组件 106
" w: r; ^" S/ K5 @' a5.2.2 Namesrv启动流程 108
~( C& T% T& t+ C) B8 T! @5.2.3 Namesrv停止流程 1104 J" o4 r m% g" v. M
5.3 RocketMQ的路由原理 111
& q* z* I" @" j. D( j# w2 [, u( a5.3.1 路由注册 111
4 x- B4 z% w0 L' q) _8 p5.3.2 路由剔除 112
9 q/ F6 |& e& n第6章 Broker存储机制 114
r; j4 W& y- s! S* z( f3 |6.1 Broker概述 1155 a, S, M' _, `; S8 Z. L
6.1.1 什么是Broker 115 p6 G5 G7 _. {% ~* e. Y0 V, a
6.1.2 Broker存储目录结构 1164 o. h4 ~, X& k3 o$ L
6.1.3 Broker启动和停止流程 117
5 ]$ W2 }+ y) O3 K7 x( {& | ^6.2 Broker存储机制 1250 y/ f" Z6 G2 Y) `
6.2.1 Broker消息存储结构 126
) s: Q) _1 _+ ?7 j- N2 G7 \6.2.2 Broker消息存储机制 130
: V. c2 \7 ~; ~3 F7 f: Y. w+ ]6.2.3 Broker读写分离机制 1501 e- O: B+ ?' b: s
6.3 Broker CommitLog索引机制 155
1 }! u8 S1 x1 M+ A0 ]6.3.1 索引的数据结构 1556 n6 ]; ?5 i, _5 E
6.3.2 索引的构建过程 1587 g/ O" w1 e0 n
6.3.3 索引如何使用 159
$ z# x0 _7 |! K- `2 @' E6.4 Broker过期文件删除机制 162
8 U5 a5 n) O& E, f5 `6.4.1 CommitLog文件的删除过程 162
% n2 m" S( D1 ?, N, c& J. j6.4.2 Consume Queue、Index File文件的删除过程 166$ [. P. M! F- d3 I& B E
6.5 Broker主从同步机制 167
# D0 J& p' F) ~* f1 D$ I6.5.1 主从同步概述 168
2 H" H2 _+ ?! }; @6.5.2 主从同步流程 169
, a/ `! G, I% i0 }! r2 ~6.6 Broker的关机恢复机制 1742 c q$ }7 Y3 f5 {; I8 b, }
6.6.1 Broker关机恢复概述 174# X/ E$ j' a( F2 D
6.6.2 Broker关机恢复流程 177: h( d. }3 p# c" k1 u1 u
第7章 RocketMQ特性——事务消息与延迟消息机制 182
: m! R r6 \- y+ a& U, z) O2 Y8 v1 m7.1 事务消息概述 183 n8 J& j& y5 g ^0 r$ R( Z
7.2 事务消息机制 184
" ^9 q/ M* K3 |7.2.1 生产者发送事务消息和执行本地事务 184
2 N9 ^8 x# G# r, X$ j- q7.2.2 Broker存储事务消息 188
/ S$ s4 o& v/ s& b/ j) J/ E# W7.2.3 Broker回查事务消息 191
) `4 m* ?. Q1 |; u, Q7.2.4 Broker提交或回滚事务消息 197
1 ~: U; J0 R# w7 t! u/ L6 o7 s8 w7.3 延迟消息概述 201
/ `1 A- o5 q8 F7 P+ F3 ~7.4 延迟消息机制 203; ~# N7 L* T6 t) ]- Z
7.4.1 延迟消息存储机制 203
3 h$ r! [9 _& ^6 K {7.4.2 延迟消息投递机制 205
% c- f/ Y F8 V7 T9 A第8章 RocketMQ源代码阅读 208
& Q4 a+ P" d# t2 Y: w8.1 RocketMQ源代码结构概述 209
' T; d4 j/ ?; j+ l0 y T, y8.2 RocketMQ源代码编译 212: r& e5 l8 z" [% R& Q) N! p& h
8.3 如何阅读源代码 214
) N# R) m' H) R0 q9 m8.4 源代码阅读范例：通过消息id查询消息 216; _3 l+ ^+ s! [# \* F) e
第9章 RocketMQ企业实践 224
! C0 H' w! s: j k4 M# u9.1 RocketMQ落地概述 225
: U5 A# H- v, G$ P" C9.1.1 为什么选择RocketMQ 225
- Q' b! [; d. j( q, q) r5 ?7 b5 K7 s9.1.2 如何做RocketMQ的集群管理 226
K; M" l* b' R+ n% X9.2 RocketMQ集群管理 2302 G7 J3 A8 O7 M1 g
9.2.1 Topic管理 230 java8.com @3 l. U# M5 @
9.2.2 消费者管理 235
) ]2 A4 _- }' f5 s1 B9.3 RocketMQ集群监控和报警 240
1 x6 G$ i3 c! K4 m: @ o9 P& O$ W9.3.1 监控和报警架构 240
: M& a& C* r% S8 I# D9.3.2 基于Grafana监控 242
. `5 H* x, T* y9.3.3 基于Prometheus的报警 243
% h. T. Y! s+ B9.4 RocketMQ集群迁移 244
3 B2 }7 w6 }! U7 L& w- B9.5 RocketMQ测试环境实践 245$ Q5 y5 |. A ] J5 @- K
9.6 RocketMQ接入实践 247
" S2 }! n8 R0 u2 o3 h9.6.1 Spring接入RocketMQ 2473 ?; ^- E- R8 d. ~* k
9.6.2 Python接入RocketMQ 2496 O, u7 ~/ t. t2 @, Z. T* W) j* u
附录 252
( E6 E' {9 G0 {6 r5 N: Q
. F. K/ g! u. h, u2 U8 K. G0 j: [( p3 g- z* G Z2 {& K* F, B3 I
8 e0 {0 p* A1 m6 k* H V0 a p/ K! \' c! L% c+ ?9 |5 u% _ o
3 D2 c% e+ d2 r8 p* i5 D' T* {: T; F( K( ^7 j* ]* ^
- u4 D: J2 n+ E |
本帖子中包含更多资源
您需要 登录 才可以下载或查看，没有账号？立即注册
x
|
电子书
4463 人阅读
|
32 人回复
|
2024-03-19
