基礎(chǔ)篇
第1章 Apache RocketMQ 綜述/
1.1為什么高并發(fā)系統(tǒng)都繞不開(kāi)消息中間件/
1.1.1初識(shí)互聯(lián)網(wǎng)的架構(gòu)/
1.1.2大型互聯(lián)網(wǎng)系統(tǒng)遇到的共性挑戰(zhàn)/
1.1.3為什么要選擇 Apache RocketMQ/
1.2了解 Apache RocketMQ/
1.2.1RocketMQ簡(jiǎn)介/
1.2.2RocketMQ發(fā)展史/
1.2.3RocketMQ在雙十一的表現(xiàn)/
1.3RocketMQ 核心概念與特性/
1.3.1RocketMQ組件/
1.3.2術(shù)語(yǔ)/
1.3.3RocketMQ重要特性/
1.4RocketMQ初體驗(yàn)/
1.4.1安裝RocketMQ/
1.4.2啟動(dòng)Name Server/
1.4.3啟動(dòng)Broker/
1.4.4關(guān)閉Broker和Name Server/
1.4.5驗(yàn)證收發(fā)消息/
1.5本章小結(jié)/
1.6思考題/
第2章 RocketMQ 消息生產(chǎn)/
2.1生產(chǎn)者概述/
2.1.1生產(chǎn)者實(shí)例/
2.1.2生產(chǎn)者組/
2.2認(rèn)識(shí)RocketMQ消息/
2.2.1消息結(jié)構(gòu)/
2.2.2消息類(lèi)型/
2.3消息發(fā)送實(shí)戰(zhàn)/
2.3.1發(fā)送普通消息/
2.3.2發(fā)送批量消息/
2.3.3發(fā)送順序消息/
2.3.4發(fā)送延時(shí)消息/
2.3.5發(fā)送事務(wù)消息/
2.4消息的三種發(fā)送模型/
2.4.1發(fā)送同步消息/
2.4.2發(fā)送異步消息/
2.4.3發(fā)送單向消息/
2.5生產(chǎn)者最佳實(shí)踐/
2.5.1不同消息類(lèi)型的選擇/
2.5.2不同消息發(fā)送模型的選擇/
2.5.3發(fā)送消息的實(shí)戰(zhàn)建議/
2.6本章小結(jié)/
2.7思考題/
第3章 RocketMQ消息消費(fèi)/
3.1消費(fèi)者概述/
3.1.1消費(fèi)者實(shí)例/
3.1.2消費(fèi)者組/
3.2初探消費(fèi)流程/
3.2.1消息存儲(chǔ)與消息隊(duì)列的關(guān)系/
3.2.2消息消費(fèi)與消息隊(duì)列的關(guān)系/
3.3消費(fèi)實(shí)戰(zhàn)/
3.3.1Push并發(fā)消費(fèi)/
3.3.2Push順序消費(fèi)/
3.3.3Pull Subscribe消費(fèi)/
3.3.4Pull Assign消費(fèi)/
3.3.5集群模式與廣播模式/
3.3.6標(biāo)簽過(guò)濾 /
3.3.7SQL92過(guò)濾 /
3.3.8消息重試和死信隊(duì)列/
3.4消息消費(fèi)最佳實(shí)踐/
3.4.1消費(fèi)日志/
3.4.2消費(fèi)冪等/
3.4.3提高消費(fèi)并行度/
3.4.4批量消費(fèi)方式/
3.4.5大量堆積時(shí)跳過(guò)歷史消息/
3.4.6規(guī)范消費(fèi)者組名/
3.4.7訂閱關(guān)系保持一致/
3.4.8并發(fā)消費(fèi)和順序消費(fèi)的選擇/
3.4.9起始消費(fèi)位點(diǎn)的設(shè)置/
3.4.10關(guān)于異步消費(fèi)/
3.4.11消費(fèi)狀態(tài)處理/
3.5本章小結(jié)/
3.6思考題/
第4章 RocketMQ運(yùn)維與管理/
4.1RocketMQ Admin Tool/
4.1.1認(rèn)識(shí)RocketMQ管理工具/
4.1.2使用RocketMQ管理工具/
4.2RocketMQ Dashboard/
4.2.1Docker方式安裝 RocketMQ Dashboard/
4.2.2源碼方式安裝 RocketMQ Dashboard/
4.2.3使用 RocketMQ Dashboard/
4.3主題管理實(shí)踐/
4.3.1主題分類(lèi)/
4.3.2主題命名/
4.3.3隊(duì)列數(shù)管理/
4.4測(cè)試環(huán)境實(shí)踐/
4.4.1獨(dú)立集群模式/
4.4.2獨(dú)立主題模式/
4.4.3Tag路由模式/
4.4.4三種模式的優(yōu)劣對(duì)比/
4.5生產(chǎn)環(huán)境運(yùn)維實(shí)踐/
4.5.1集群擴(kuò)容/
4.5.2集群遷移/
4.6RocketMQ 常見(jiàn)部署架構(gòu)/
4.6.1單主模式/
4.6.2主備模式的架構(gòu)/
4.6.3多主模式的架構(gòu)/
4.6.4同城災(zāi)備模式/
4.7本章小結(jié)/
4.8思考題/
原理篇
第5章 RocketMQ消費(fèi)原理/
5.1理解RocketMQ的推模式/
5.1.1Push 模式/
5.1.2Pull 模式/
5.1.3Push模式與Pull模式的優(yōu)劣對(duì)比/
5.2了解長(zhǎng)輪詢(xún)/
5.2.1短輪詢(xún)/
5.2.2長(zhǎng)輪詢(xún)/
5.3RocketMQ長(zhǎng)輪詢(xún)實(shí)現(xiàn)/
5.3.1客戶(hù)端增大超時(shí)時(shí)間/
5.3.2服務(wù)端Hold住無(wú)數(shù)據(jù)的請(qǐng)求/
5.3.3RocketMQ長(zhǎng)輪詢(xún)小結(jié)/
5.4RocketMQ的消息拉取優(yōu)化細(xì)節(jié)/
5.4.1客戶(hù)端請(qǐng)求異步化/
5.4.2服務(wù)端超時(shí)處理細(xì)節(jié)/
5.4.3服務(wù)端多線程交互/
5.4.4合并多個(gè) Pull 請(qǐng)求/
5.5消費(fèi)者線程模型/
5.5.1消費(fèi)流程涉及的關(guān)鍵線程/
5.5.2消費(fèi)線程池/
5.6消費(fèi)進(jìn)度管理/
5.6.1消費(fèi)進(jìn)度存儲(chǔ)/
5.6.2初次啟動(dòng)從哪里消費(fèi)/
5.7消息ACK機(jī)制/
5.7.1AT LEAST ONCE保證/
5.7.2消息消費(fèi)失敗進(jìn)度管理/
5.8消息失敗重試設(shè)計(jì)/
5.8.1重試主題/
5.8.2延遲重試/
5.9消息消費(fèi)異常處理/
5.9.1消費(fèi)超時(shí)/
5.9.2卡進(jìn)度的保護(hù)處理/
5.9.3消息重發(fā)與順序性的矛盾/
5.10本章小結(jié)/
5.11思考題/
第6章 RocketMQ負(fù)載均衡與消費(fèi)模式/
6.1負(fù)載均衡綜述/
6.2消息生產(chǎn)負(fù)載均衡/
6.2.1消息生產(chǎn)負(fù)載均衡概述/
6.2.2消息生成負(fù)載均衡的原理/
6.3消息消費(fèi)負(fù)載均衡/
6.3.1無(wú)中心的隊(duì)列負(fù)載均衡/
6.3.2無(wú)中心負(fù)載均衡的核心源碼/
6.3.3消費(fèi)者負(fù)載均衡策略/
6.4無(wú)中心負(fù)載均衡帶來(lái)的弊端/
6.5RocketMQ廣播消息原理/
6.5.1JMS的消息類(lèi)型/
6.5.2主流消息中間件對(duì)發(fā)布/訂閱模式的支持/
6.5.3RocketMQ對(duì)發(fā)布/訂閱模式的支持/
6.5.4廣播模式下的可靠性及順序性處理/
6.6本章小結(jié)/
6.7思考題/
第7章 RocketMQ存儲(chǔ)設(shè)計(jì)/
7.1RocketMQ消息存儲(chǔ)概覽/
7.1.1文件構(gòu)成/
7.1.2消息存儲(chǔ)過(guò)程/
7.2RocketMQ存儲(chǔ)與檢索/
7.2.1RocketMQ存儲(chǔ)對(duì)比Kafka存儲(chǔ)/
7.2.2RocketMQ存儲(chǔ)設(shè)計(jì)對(duì)比Kafka的優(yōu)勢(shì)/
7.3CommitLog文件/
7.3.1CommitLog文件結(jié)構(gòu)/
7.3.2CommitLog抽象模型/
7.3.3CommitLog文件組成/
7.4ConsumeQueue文件/
7.4.1ConsumeQueue文件結(jié)構(gòu)/
7.4.2ConsumeQueue文件組成/
7.5IndexFile文件/
7.5.1IndexFile概覽/
7.5.2IndexFile文件結(jié)構(gòu)/
7.5.3IndexFile文件組成/
7.6本章小結(jié)/
7.7思考題/
第8章 RocketMQ消息高可靠的設(shè)計(jì)/
8.