第1 篇 基礎(chǔ)
第1 章 初識(shí)RocketMQ ·························.2
1.1 認(rèn)識(shí)分布式架構(gòu) ····························.2
1.1.1 什么是分布式 ·······················.2
1.1.2 什么是架構(gòu) ··························.3
1.1.3 分布式架構(gòu)的冰與火 ··············.5
1.2 認(rèn)識(shí)RocketMQ ·····························.7
1.2.1 什么是RocketMQ ··················.7
1.2.2 RocketMQ 與分布式架構(gòu) ·······.12
1.3 搭建RocketMQ 環(huán)境 ····················.13
1.3.1 了解RocketMQ 相關(guān)的安裝包 .13
1.3.2 搭建單Master 的單機(jī)環(huán)境 ·····.15
1.3.3 搭建多Master 的集群環(huán)境 ·····.15
1.3.4 搭建單Master 和單Slave 的集群環(huán)境 ·································.16
1.3.5 【實(shí)例】搭建Raft 集群環(huán)境 ··.18
1.4 RocketMQ 5.0 的新特性 ················.20
第2 章 實(shí)現(xiàn)通信渠道 ··························.22
2.1 認(rèn)識(shí)通信渠道 ·····························.22
2.2 通信渠道的架構(gòu) ··························.25
2.2.1 認(rèn)識(shí)Netty ·························.25
2.2.2 RocketMQ 通信渠道的架構(gòu) ····.29
2.3 使用Netty 實(shí)現(xiàn)通信渠道的原理 ······.33
2.3.1 實(shí)現(xiàn)通信渠道的通信協(xié)議 ······.33
2.3.2 實(shí)現(xiàn)客戶(hù)端通信渠道 ············.38
2.3.3 實(shí)現(xiàn)服務(wù)端通信渠道 ············.41
2.4 使用客戶(hù)端連接服務(wù)端 ·················.47
2.4.1 分析模塊通信渠道的類(lèi)型 ······.48
2.4.2 連接服務(wù)端 ························.50
2.5 【實(shí)例】修改通信渠道客戶(hù)端和服務(wù)端的線程模型 ·······················.54
第3 章 消息路由信息的無(wú)狀態(tài)存儲(chǔ)和管理 ······································.61
3.1 了解消息路由信息 ·······················.61
3.2 Name Server 的架構(gòu) ·····················.68
3.2.1 認(rèn)識(shí)無(wú)狀態(tài)架構(gòu) ··················.68
3.2.2 認(rèn)識(shí)Name Server 架構(gòu) ·········.69
3.2.3 認(rèn)識(shí)地址服務(wù)架構(gòu) ···············.72
3.2.4 【實(shí)例】用地址服務(wù)動(dòng)態(tài)更新客戶(hù)端中的Name Server 節(jié)點(diǎn)的地址信息 ··························.74
3.3 “使用Name Server 存儲(chǔ)和管理消息路由信息”的原理 ·······················.77
3.3.1 Name Server 的啟動(dòng)流程 ·······.77
3.3.2 注冊(cè)Broker Server ···············.84
3.3.3 取消注冊(cè)的業(yè)務(wù)場(chǎng)景和取消注冊(cè)Broker Server ···············.89
3.3.4 存儲(chǔ)和管理消息路由信息 ······.93
3.4 【實(shí)例】啟動(dòng)多個(gè)Name Server 節(jié)點(diǎn)，模擬故障以驗(yàn)證Name Server 節(jié)點(diǎn)的無(wú)狀態(tài)性 ·································.101
第4 章 生產(chǎn)消息和消費(fèi)消息 ···············.104
4.1 生產(chǎn)和消費(fèi)消息的模式 ················.104
4.1.1 生產(chǎn)消息 ··························.104
4.1.2 消費(fèi)消息 ··························.110
4.2 消費(fèi)消息的類(lèi)型 ·························.116
4.2.1 集群消息 ··························.116
4.2.2 廣播消息 ··························.118
4.2.3 順序消息 ··························.119
4.2.4 并發(fā)消息 ··························.125
4.2.5 延遲消息 ··························.126
4.2.6 事務(wù)消息 ··························.130
4.3 生產(chǎn)消息 ··································.134
4.3.1 生產(chǎn)者SDK 的3 種使用方式 ································.135
4.3.2 采用“同步”模式生產(chǎn)消息 ···.137
4.3.3 采用“異步”模式生產(chǎn)消息 ···.142
4.3.4 采用“最多發(fā)送一次”模式生產(chǎn)消息 ··························.148
4.4 消費(fèi)消息 ··································.152
4.4.1 采用pull 模式消費(fèi)消息 ········.153
4.4.2 采用push 模式消費(fèi)消息 ·······.171
4.4.3 采用pop 模式消費(fèi)消息 ········.183
4.5 采用“請(qǐng)求/應(yīng)答”消息實(shí)現(xiàn)同步調(diào)用 ········································.197
4.5.1 “請(qǐng)求/應(yīng)答”消息的架構(gòu) ····.197
4.5.2 分析“請(qǐng)求/應(yīng)答”消息的過(guò)程 ································.198
4.6 【實(shí)例】生產(chǎn)者發(fā)送消息，消費(fèi)者順序地消費(fèi)消息 ·························.212
4.6.1 驗(yàn)證“普通順序消息” ········.212
4.6.2 驗(yàn)證“嚴(yán)格順序消息” ········.217
第5 章 存儲(chǔ)消息 ······························.219
5.1 認(rèn)識(shí)存儲(chǔ)引擎 ····························.219
5.1.1 什么是存儲(chǔ)引擎 ·················.219
5.1.2 存儲(chǔ)引擎的架構(gòu) ·················.221
5.2 認(rèn)識(shí)存儲(chǔ)模型 ····························.222
5.2.1 消息模型 ··························.222
5.2.2 文件模型 ··························.229
5.2.3 【實(shí)例】利用源碼遠(yuǎn)程調(diào)試存儲(chǔ)模型 ································.236
5.3 啟動(dòng)存儲(chǔ)引擎 ····························.238
5.3.1 初始化Broker Server 和存儲(chǔ)引擎 ································.238
5.3.2 啟動(dòng)Broker Server 和存儲(chǔ)引擎 ································.247
5.3.3 【實(shí)例】動(dòng)態(tài)修改存儲(chǔ)引擎的配置參數(shù) ··························.251
5.4 使用存儲(chǔ)引擎處理“儲(chǔ)存消息”的請(qǐng)求 ········································.253
5.4.1 接收并處理生產(chǎn)消息的請(qǐng)求 ································.254
5.4.2 存儲(chǔ)消息 ··························.257
5.4.3 【實(shí)例】利用存儲(chǔ)引擎實(shí)現(xiàn)批量地存儲(chǔ)消息 ·······················.262
5.5 對(duì)比存儲(chǔ)單條消息和批量消息的性能 ········································.263

第6 章 治理消息 ······························.268
6.1 如何治理消息 ····························.268
6.1.1 治理消息的目標(biāo) ·················.268
6.1.2 使用消息度量提供治理消息的依據(jù) ································.276
6.1.3 使用消息管控實(shí)現(xiàn)治理消息的落地 ································.280
6.2 認(rèn)識(shí)命令控制臺(tái)和UI 控制臺(tái) ········.285
6.2.1 什么是命令控制臺(tái)和UI控制臺(tái) ·····························.285
6.2.2 啟動(dòng)命令控制臺(tái)和UI控制臺(tái) ·····························.289
6.2.3 使用對(duì)象池管理RocketMQDashboard 中通信渠道客戶(hù)端的核心類(lèi) ·····························.292
6.3 使用命令控制臺(tái)治理消息 ·············.298
6.3.1 執(zhí)行治理消息的命令 ···········.299
6.3.2 【實(shí)例】使用命令控制臺(tái)，完成
RocketMQ 集群的擴(kuò)容 ·········.322
6.3.3 【實(shí)例】使用命令控制臺(tái)，完成
RocketMQ 集群的縮容 ·········.325
6.3.4 【實(shí)例】使用命令控制臺(tái)，動(dòng)態(tài)增加Topic 的讀/寫(xiě)消息隊(duì)列的數(shù)量 ·················.332
6.4 使用UI 控制臺(tái)治理消息 ··············.334
6.4.1 使用UI 控制臺(tái)治理消息的原理 ································.335
6.4.2 【實(shí)例】使用UI 控制臺(tái)手動(dòng)地禁用消費(fèi)者組 ····················.341
6.4.3 【實(shí)例】使用UI 控制臺(tái)重置消費(fèi)者進(jìn)度 ·······················.343
第7 章 實(shí)現(xiàn)分布式事務(wù) ·····················.345
7.1 什么是分布式事務(wù) ······················.345
7.1.1 本地事務(wù) ··························.345
7.1.2 分布式事務(wù) ·······················.350
7.1.3 事務(wù)消息與數(shù)據(jù)的最終一致性 ·····························.354
7.2 使用“兩階段提交”模式處理事務(wù)消息 ········································.359
7.3 使用“定時(shí)回調(diào)”機(jī)制查詢(xún)本地事務(wù)狀態(tài) ········································.370
7.4 【實(shí)例】架構(gòu)師如何在電商項(xiàng)目中落地分布式事務(wù) ·························.380
7.4.1 分析業(yè)務(wù)場(chǎng)景 ····················.380
7.4.2 分析業(yè)務(wù)復(fù)雜度 ·················.381
7.4.3 分析技術(shù)復(fù)雜度 ·················.385
7.4.4 落地代碼 ··························.391
7.4.5 驗(yàn)證接入的結(jié)果 ·················.392
7.5 【實(shí)例】使用泛娛樂(lè)業(yè)務(wù)驗(yàn)證事務(wù)消息的故障轉(zhuǎn)移機(jī)制 ···················.393
7.5.1 準(zhǔn)備環(huán)境 ··························.394
7.5.2 架構(gòu)設(shè)計(jì) ··························.394
7.5.3 代碼設(shè)計(jì) ··························.395
7.5.4 驗(yàn)證故障轉(zhuǎn)移 ····················.397
第8 章 實(shí)現(xiàn)消息的可追蹤性 ···············.402
8.1 消息的可追蹤性 ·························.402
8.1.1 認(rèn)識(shí)消息的可追蹤性 ···········.402
8.1.2 為什么需要消息的可追蹤性 ···.404
8.1.3 RocketMQ 支持的追蹤類(lèi)型 ···.404
8.2 使用消息軌跡實(shí)現(xiàn)消息的可追蹤性 ··································.405
8.2.1 認(rèn)識(shí)消息軌跡 ····················.405
8.2.2 軌跡樹(shù)的原理 ····················.412
8.2.3 【實(shí)例】開(kāi)啟消息軌跡，追蹤生產(chǎn)消息、消費(fèi)消息和結(jié)束事務(wù)消息的過(guò)程 ································.421
8.3 使用Hook 機(jī)制收集Trace 消息 ······.422
8.3.1 什么是Hook 機(jī)制 ···············.422
8.3.2 “使用Hook 機(jī)制的實(shí)現(xiàn)類(lèi)收集Trace 消息”的原理 ······.425
8.4 使用“定時(shí)線程任務(wù)”異步存儲(chǔ)Trace信息 ········································.428
8.4.1 為什么要異步存儲(chǔ) ··············.428
8.4.2 異步存儲(chǔ)Trace 信息的過(guò)程 ···.431
8.4.3 【實(shí)例】斷點(diǎn)調(diào)試“客戶(hù)端異步存儲(chǔ)Trace 信息”···············.441
8.5 使用“OpenTracing + Jaeger”實(shí)現(xiàn)消息的分布式鏈路追蹤 ·························.444
8.5.1 認(rèn)識(shí)OpenTracing ···············.444
8.5.2 認(rèn)識(shí)Jaeger ·······················.446
8.5.3 “使用Jaeger 收集消息鏈路數(shù)據(jù)”的原理 ·····························.446
8.5.4 “使用OpenTracing 規(guī)范消息鏈路追蹤”的原理 ····················.448
8.5.5 【實(shí)例】收集普通消息和事務(wù)消息，使用Jaeger 實(shí)現(xiàn)可視化 ········.452
8.6 【實(shí)例】自定義Hook 和Trace 信息的派發(fā)類(lèi) ·····································.456
8.6.1 設(shè)計(jì) ································.457
8.6.2 關(guān)鍵代碼分析 ····················.457
第9 章 保證消息的穩(wěn)定性 ··················.461
9.1 什么是消息的穩(wěn)定性 ···················.461
9.1.1 認(rèn)識(shí)穩(wěn)定性 ·······················.461
9.1.2 認(rèn)識(shí)消息的穩(wěn)定性 ··············.466

9.1.3 消息穩(wěn)定性技術(shù) ·················.467
9.2 實(shí)現(xiàn)RocketMQ 的實(shí)時(shí)監(jiān)控 ··········.472
9.2.1 認(rèn)識(shí)RocketMQ Exporter 及其相關(guān)組件 ··························.472
9.2.2 實(shí)時(shí)監(jiān)控的邏輯架構(gòu) ···········.474
9.2.3 “使用RocketMQ Exporter 實(shí)現(xiàn)實(shí)時(shí)監(jiān)控”的原理 ··············.477
9.2.4 搭建監(jiān)控環(huán)境 ····················.486
9.2.5 【實(shí)例】基于Prometheus 和Alert Manager 的RocketMQ實(shí)時(shí)告警 ··························.494
9.3 實(shí)現(xiàn)RocketMQ 客戶(hù)端的實(shí)時(shí)度量 ··································.503
9.3.1 認(rèn)識(shí)Skywalking ·················.503
9.3.2 “使用Skywalking 實(shí)時(shí)度量RocketMQ 客戶(hù)端”的原理 ···.504
9.3.3 搭建監(jiān)控環(huán)境 ····················.509
9.3.4 【實(shí)例】修改源碼動(dòng)態(tài)設(shè)置一些延遲時(shí)間，觸發(fā)基于Skywalking和釘釘?shù)母婢�閾�?··············.511
9.4 【實(shí)例】使用RocketMQ Dashboard實(shí)時(shí)監(jiān)控RocketMQ ····················.515
9.4.1 設(shè)計(jì) ································.515
9.4.2 修改RocketMQ Dashboard 的源碼 ································.516
9.4.3 配置監(jiān)控規(guī)則 ····················.517
9.4.4 初始化生產(chǎn)者和消費(fèi)者服務(wù) ··.517
9.4.5 驗(yàn)證監(jiān)控告警 ····················.518
9.5 【實(shí)例】改造RocketMQ 以支持Nacos 集群管理 ··························.520
9.5.1 架構(gòu)設(shè)計(jì) ··························.520
9.5.2 落地代碼 ··························.521
9.5.3 驗(yàn)證 ································.524
第4 篇 高并發(fā)、高可用和高性能
第10 章 消息的高并發(fā) ······················.528
10.1 消息的高并發(fā)概述 ·····················.528
10.1.1 什么是高并發(fā) ··················.528
10.1.2 為什么要實(shí)現(xiàn)消息的高并發(fā) ·····························.529
10.2 使用“管理通信渠道”實(shí)現(xiàn)消息的高并發(fā) ·····································.530
10.2.1 通信渠道與高并發(fā) ············.530
10.2.2 管理生產(chǎn)者與Broker Server之間的通信渠道 ·················.532
10.2.3 管理消費(fèi)者與Broker Server之間的通信渠道 ·················.533
10.3 使用“提高消費(fèi)者處理消息的功能”實(shí)現(xiàn)消息的高并發(fā) ······················.534
10.3.1 消費(fèi)者處理消息的功能與高并發(fā) ·····························.534
10.3.2 使用“擴(kuò)容消費(fèi)者客戶(hù)端”來(lái)提高消費(fèi)消息的并行性 ········.534
10.3.3 采用pop 模式來(lái)提高消費(fèi)消息的速度 ································.535

10.3.4 【實(shí)例】實(shí)現(xiàn)“單進(jìn)程單消費(fèi)者的并發(fā)和批量消費(fèi)消息” ·····························.536
10.3.5 【實(shí)例】實(shí)現(xiàn)“單進(jìn)程多消費(fèi)者實(shí)例并發(fā)生產(chǎn)和消費(fèi)消息” ·····························.541
10.4 使用線程池實(shí)現(xiàn)消息的高并發(fā) ······.550
10.4.1 為什么要使用線程池 ·········.550
10.4.2 使用線程池實(shí)現(xiàn)消息的高并發(fā)的原理 ································.551
10.4.3 【實(shí)例】使用RocketMQ 自帶的線程實(shí)現(xiàn)生產(chǎn)和消費(fèi)消息的并發(fā)性 ·····························.558
10.4.4 【實(shí)例】動(dòng)態(tài)修改Consumer客戶(hù)端的核心線程數(shù) ···········.559
10.5 采用“異步”模式實(shí)現(xiàn)消息的高并發(fā) ····································.562
10.5.1 使用“回調(diào)+異步響應(yīng)對(duì)象”實(shí)現(xiàn)生產(chǎn)者的“異步”模式 ································.562
10.5.2 使用“異步命令事件處理器”實(shí)現(xiàn)Broker Server 的“異步”模式 ································.563
10.5.3 使用“流水線”技術(shù)實(shí)現(xiàn)存儲(chǔ)引擎的“異步”模式 ···········.564
10.6 使用“負(fù)載均衡”實(shí)現(xiàn)消息的高并發(fā) ·····································.566
10.6.1 什么是負(fù)載均衡 ···············.566
10.6.2 “使用選擇器實(shí)現(xiàn)生產(chǎn)消息的負(fù)載均衡”的原理 ··············.576
10.6.3 “使用客戶(hù)端負(fù)載均衡實(shí)現(xiàn)消費(fèi)消息的均衡性”的原理 ········.577
10.6.4 “使用服務(wù)端負(fù)載均衡實(shí)現(xiàn)消費(fèi)消息的均衡性”的原理 ········.578
10.6.5 【實(shí)例】動(dòng)態(tài)調(diào)整消費(fèi)者客戶(hù)端的負(fù)載均衡策略 ·················.579
第11 章 消息的高可用 ·······················.583
11.1 什么是消息的高可用 ··················.583
11.1.1 生產(chǎn)消息的高可用 ············.584
11.1.2 存儲(chǔ)消息的高可用 ············.585
11.1.3 消費(fèi)消息的高可用 ············.585
11.2 實(shí)現(xiàn)生產(chǎn)消息的高可用——利用故障容錯(cuò)機(jī)制 ··································.587
11.2.1 什么是故障容錯(cuò)機(jī)制 ·········.587
11.2.2 重試生產(chǎn)消息失敗的請(qǐng)求 ···.588
11.2.3 過(guò)濾故障的Broker Server ····.590
11.2.4 故障延遲 ························.591
11.2.5 【實(shí)例】在Spring Cloud Alibaba項(xiàng)目中，植入故障并驗(yàn)證故障
容錯(cuò)機(jī)制 ··························.594
11.3 實(shí)現(xiàn)消費(fèi)消息的高可用——利用重試隊(duì)列和死信隊(duì)列 ·························.596
11.3.1 利用“重試隊(duì)列”實(shí)現(xiàn)高可用的核心原理 ··························.597
11.3.2 利用“死信隊(duì)列”實(shí)現(xiàn)高可用的核心原理 ··························.598
11.3.3 【實(shí)例】動(dòng)態(tài)調(diào)整重試策略，并驗(yàn)證消費(fèi)失敗的高可用性 ···.599
11.3.4 【實(shí)例】在消息重試失敗后，消費(fèi)死信隊(duì)列中的消息 ········.601

11.4 實(shí)現(xiàn)Broker Server 的高可用——利用主/從同步 ·································.602
11.4.1 什么是主/從同步 ···············.602
11.4.2 實(shí)現(xiàn)主/從節(jié)點(diǎn)之間的通信渠道 ································.605
11.4.3 實(shí)現(xiàn)主/從節(jié)點(diǎn)之間消息的同步 ································.610
11.4.4 【實(shí)例】模擬Broker Server主/從同步的業(yè)務(wù)場(chǎng)景 ··········.614
11.5 實(shí)現(xiàn)Broker Server 的高可用——利用多副本架構(gòu)（Dledger） ···············.617
11.5.1 什么是多副本架構(gòu)（DLedger） ·······················.617
11.5.2 “多副本架構(gòu)的通信渠道”的原理 ································.618
11.5.3 “多副本架構(gòu)的協(xié)議”的原理 ································.621
11.5.4 “多副本架構(gòu)的手動(dòng)選舉”的原理 ································.627
11.5.5 “多副本架構(gòu)的自動(dòng)選舉”的原理 ································.631
11.5.6 “多副本架構(gòu)的消息存儲(chǔ)”的原理 ································.634
11.5.7 “多副本架構(gòu)中集群之間消息同步”的原理 ····················.638
11.5.8 【實(shí)例】在主節(jié)點(diǎn)出現(xiàn)故障后，多副本架構(gòu)（DLedger）自動(dòng)選舉，并保持主/從消息一致性 ·······.645
11.6 【實(shí)例】模擬業(yè)務(wù)場(chǎng)景“從主/從架構(gòu)升級(jí)為多副本架構(gòu)”，并驗(yàn)證消息的高可用性 ··································.651
11.7 【實(shí)例】使用微服務(wù)來(lái)驗(yàn)證多副本的手動(dòng)選舉功能的高可用性 ·············.654
第12 章 消息的高性能 ······················.657
12.1 什么是消息的高性能 ·················.657
12.1.1 生產(chǎn)消息的高性能 ············.657
12.1.2 存儲(chǔ)消息的高性能 ············.659
12.1.3 消費(fèi)消息的高性能 ············.660
12.2 使用本地緩存實(shí)現(xiàn)高性能 ···········.661
12.2.1 緩存客戶(hù)端通信渠道 ·········.661
12.2.2 緩存消息路由信息 ············.663
12.2.3 【實(shí)例】使用IDEA 調(diào)試“緩存客戶(hù)端通信渠道” ······.665
12.3 提升存儲(chǔ)消息的性能——利用CommitLog 文件順序?qū)?···············.670
12.3.1 什么是CommitLog 文件 ·····.670
12.3.2 CommitLog 文件的存儲(chǔ)格式 ································.672
12.3.3 利用“順序?qū)憽贝鎯?chǔ)消息的原理 ································.673
12.4 提高消費(fèi)消息的速度——利用ConsumeQueue 文件實(shí)現(xiàn) ··············.676
12.4.1 什么是ConsumeQueue文件 ································.677
12.4.2 構(gòu)建ConsumeQueue 文件 ····.678
12.4.3 利用ConsumeQueue 文件提高消費(fèi)消息的性能 ·················.683
12.5 提高查詢(xún)消息的速度——利用索引文件實(shí)現(xiàn) ··································.684
12.5.1 什么是索引文件 ···············.684
12.5.2 構(gòu)建索引文件 ··················.685
12.5.3 利用索引文件提高查詢(xún)消息的性能 ································.687
12.6 提升消費(fèi)消息RPC 請(qǐng)求的性能——利用零拷貝實(shí)現(xiàn) ·························.687
12.6.1 什么是零拷貝 ··················.688
12.6.2 使用Netty 的FileRegion 類(lèi)實(shí)現(xiàn)文件的零拷貝 ····················.688
12.6.3 在Broker Server 的消息處理器中使用零拷貝 ·······················.691
12.7 提升Broker Server 寫(xiě)消息的性能——利用內(nèi)存映射、Page Cache 及堆外
內(nèi)存實(shí)現(xiàn) ··································.692
12.7.1 什么是內(nèi)存映射、Page Cache 和堆外內(nèi)存 ··························.693
12.7.2 寫(xiě)消息高性能的邏輯架構(gòu) ···.695
12.7.3 “利用MappedFile 文件實(shí)現(xiàn)內(nèi)存映射”的原理 ··············.696
12.7.4 “利用內(nèi)存映射實(shí)現(xiàn)Page Cache”的原理 ·····························.696
12.7.5 “管理堆外內(nèi)存和Page Cache”的原理 ·····························.697
12.8 清理過(guò)期的ConsumeQueue 文件和CommitLog 文件 ························.702
12.8.1 清理過(guò)期的ConsumeQueue文件 ································.702
12.8.2 清理過(guò)期的CommitLog文件 ································.704
12.8.3 【實(shí)例】利用Spring CloudAlibaba 項(xiàng)目演示清理過(guò)期的ConsumeQueue 文件和CommitLog文件 ································.709
第5 篇 應(yīng)用
第13 章 RocketMQ 在分布式架構(gòu)中的應(yīng)用 ····································.712
13.1 RocketMQ 在Spring Boot 中的應(yīng)用 ········································.712
13.1.1 為什么RocketMQ 要支持Spring Boot ·······················.712
13.1.2 利用Spring Boot 作為基礎(chǔ)框架生產(chǎn)和消費(fèi)消息 ·················.713
13.2 RocketMQ 在Spring Cloud Alibaba 中的應(yīng)用 ·······································.719
13.2.1 為什么Spring Cloud Alibaba 要支持RocketMQ ··················.719
13.2.2 利用Spring Cloud Alibaba 作為基礎(chǔ)框架生產(chǎn)和消費(fèi)消息 ·····.719
13.2.3 Spring Cloud Alibaba 定制化RocketMQ 的原理 ···············.728
13.3 【實(shí)例】將命令式編程模式升級(jí)為函數(shù)式編程模式，完成消息的生產(chǎn)和消費(fèi) ········································.730
13.3.1 采用命令式編程模式生產(chǎn)和消費(fèi)消息 ··························.730

13.3.2 將命令式編程模式升級(jí)為函數(shù)式編程模式 ·················.731
13.4 RocketMQ 在RocketMQ Connect 中的應(yīng)用 ········································.732
13.4.1 什么是Message Connect ·····.733
13.4.2 什么是RocketMQ Connect ··.735
13.4.3 RocketMQ Connect 的核心架構(gòu) ································.736
13.4.4 “利用生產(chǎn)者和消費(fèi)者來(lái)同步集群信息”的原理 ··············.739
13.4.5 “利用監(jiān)聽(tīng)器完成服務(wù)發(fā)現(xiàn)”的原理 ································.743
13.4.6 “利用客戶(hù)端負(fù)載均衡實(shí)現(xiàn)同步消息的高吞吐量”的原理 ·····.744
13.4.7 【實(shí)例】搭建RocketMQ Connect的本地和分布式環(huán)境 ···········.747
13.5 RocketMQ 在Event Bridge 中的應(yīng)用 ········································.750
13.5.1 什么是Event Bridge ···········.750
13.5.2 Event Bridge 的核心架構(gòu) ·····.751
13.5.3 利用RocketMQ 實(shí)現(xiàn)EventBridge 的核心原理 ··············.756
13.6 RocketMQ 在多語(yǔ)言環(huán)境中的應(yīng)用 ········································.757
13.6.1 RocketMQ 的多語(yǔ)言架構(gòu)設(shè)計(jì) ································.757
13.6.2 【實(shí)例】使用Go 語(yǔ)言客戶(hù)端生產(chǎn)和消費(fèi)消息 ·················.758
13.7 RocketMQ 在大數(shù)據(jù)中的應(yīng)用 ······.760
13.7.1 RocketMQ Streams 的核心架構(gòu) ································.761
13.7.2 【實(shí)例】利用RocketMQ Streams處理微服務(wù)中的流數(shù)據(jù) ········.765
第6 篇 新特性
章 分析RocketMQ 5.x 的新特性 ··.768
14.1 利用“對(duì)等部署模式”實(shí)現(xiàn)BrokerServer 的高可用 ·························.768
14.1.1 認(rèn)識(shí)“對(duì)等部署模式” ······.768
14.1.2 實(shí)現(xiàn)“對(duì)等部署模式”的原理 ································.771
14.1.3 【實(shí)例】利用微服務(wù)來(lái)驗(yàn)證“對(duì)等部署模式”的高可用 ···.777
14.2 利用“Slave 代理Master 模式”實(shí)現(xiàn)Broker Server 的高可用 ················.778
14.2.1 認(rèn)識(shí)“Slave 代理Master模式” ·····························.778
14.2.2 實(shí)現(xiàn)“Slave 代理Master模式”的原理 ····················.779
14.2.3 【實(shí)例】利用微服務(wù)來(lái)驗(yàn)證“Slave 代理Master 模式”的
高可用 ·····························.788
14.3 利用“RocketMQ Controller 模式”實(shí)現(xiàn)Broker Server 的高可用 ·········.790
14.3.1 認(rèn)識(shí)“RocketMQ Controller模式” ·····························.791
14.3.2 實(shí)現(xiàn)“RocketMQ Controller模式”的原理 ····················.793
14.3.3 利用“RocketMQ Controller模式”完成集群管理 ···········.797
14.3.4 實(shí)現(xiàn)“RocketMQ Controller 模式中多副本狀態(tài)機(jī)”的原理 ·····.806
14.3.5 【實(shí)例】驗(yàn)證“RocketMQController 模式”的
高可用性 ··························.810
14.4 利用“RocketMQ Proxy 模式”統(tǒng)一多語(yǔ)言客戶(hù)端 ····························.814
14.4.1 認(rèn)識(shí)“RocketMQ Proxy模式” ·····························.814
14.4.2 實(shí)現(xiàn)“RocketMQ Proxy 模式”的原理 ································.816
14.4.3 實(shí)現(xiàn)“代理多語(yǔ)言客戶(hù)端請(qǐng)求”的原理 ···························.821