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