現貨RocketMQ實戰與原理解析 楊開元 雲棲社區係列 RocketMQ集群配置部署設計書籍 pdf epub mobi txt 电子书 下载 2025

☆☆☆☆☆

楊開元 著

店铺： 蓝墨水图书专营店

出版社： 机械工业

ISBN：9787111600251

商品编码：29164160295

基本信息

作者： 楊開元   

叢書名： 雲棲社區係列

齣版社：機械工業齣版社

ISBN：9787111600251

上架時間：2018-6-11

齣版日期：2018 年6月

開本：16開

版次：1-1

所屬分類：計算機

目錄

推薦序 

前言

第1章 快速入門1

1.1 消息隊列功能介紹1

1.1.1 應用解耦1

1.1.2 流量消峰2

1.1.3 消息分發3

1.2 RocketMQ簡介4

1.3 快速上手RocketMQ4

1.3.1 RocketMQ的下載、安裝和配置 5

1.3.2 啓動消息隊列服務6

1.3.3 用命令行發送和接收消息6

1.3.4 關閉消息隊列6

1.4 本章小結7

第2章 生産環境下的配置和使用8

2.1 RocketMQ各部分角色介紹8

2.2 多機集群配置和部署9

2.2.1 啓動多個NameServer和Broker10

2.2.2 配置參數介紹11

2.3 發送/接收消息示例13

2.4 常用管理命令15

2.5 通過圖形界麵管理集群21

2.6 本章小結22

第3章 用適閤的方式發送和接收消息23

3.1 不同類型的消費者23

3.1.1 DefaultMQPushConsumer的使用23

3.1.2 DefaultMQPushConsumer的處理流程25

3.1.3 DefaultMQPushConsumer的流量控製28

3.1.4 DefaultMQPullConsumer30

3.1.5 Consumer的啓動、關閉流程32

3.2 不同類型的生産者33

3.2.1 DefaultMQProducer 34

3.2.2 發送延遲消息36

3.2.3 自定義消息發送規則36

3.2.4 對事務的支持37

3.3 如何存儲隊列位置信息38

3.4 自定義日誌輸齣42

3.5 本章小結44

第4章 分布式消息隊列的協調者45

4.1 NameServer的功能45

4.1.1 集群狀態的存儲結構46

4.1.2 狀態維護邏輯47

4.2 各個角色間的交互流程48

4.2.1 交互流程源碼分析48

4.2.2 為何不用ZooKeeper50

4.3 底層通信機製50

4.3.1 Remoting模塊51

4.3.2 協議設計和編解碼54

4.3.3 Netty庫56

4.4 本章小結56

第5章 消息隊列的核心機製57

5.1 消息存儲和發送57

5.2 消息存儲結構58

5.3 高可用性機製60

5.4 同步刷盤和異步刷盤61

5.5 同步復製和異步復製62

5.6 本章小結63

第6章 可靠性優先的使用場景64

6.1 順序消息64

6.1.1 全局順序消息64

6.1.2 部分順序消息65

6.2 消息重復問題67

6.3 動態增減機器67

6.3.1 動態增減NameServer67

6.3.2 動態增減Broker69

6.4 各種故障對消息的影響70

6.5 消息優先級72

6.6 本章小結73

第7章 吞吐量優先的使用場景74

7.1 在Broker端進行消息過濾74

7.1.1 消息的Tag和Key74

7.1.2 通過Tag進行過濾75

7.1.3 用SQL錶達式的方式進行過濾75

7.1.4 Filter Server方式過濾77

7.2 提高Consumer處理能力78

7.3 Consumer的負載均衡80

7.3.1 DefaultMQPushConsumer的負載均衡80

7.3.2 DefaultMQPullConsumer的負載均衡81

7.4 提高Producer的發送速度83

7.5 係統性能調優的一般流程85

7.6 本章小結87

第8章 和其他係統交互88

8.1 在SpringBoot中使用RocketMQ88

8.1.1 直接使用88

8.1.2 通過Spring Messaging方式使用90

8.2 直接使用雲上RocketMQ91

8.3 RocketMQ與Spark、Flink對接93

8.4 自定義開發運維工具93

8.4.1 開源版本運維工具功能介紹94

8.4.2 基於Tools模塊開發自定義運維工具95

8.5 本章小結96

第9章 首個Apache中間件頂級項目97

9.1 RocketMQ的前世今生97

9.2 Apache頂級項目（TLP）之路98

9.3 源碼結構99

9.4 不斷迭代的代碼100

9.5 本章小結102

第10章 NameServer源碼解析103

10.1 模塊入口代碼的功能103

10.1.1 入口函數103

10.1.2 解析命令行參數104

10.1.3 初始化NameServer的Controller105

10.2 NameServer的總控邏輯106

10.3 核心業務邏輯處理107

10.4 集群狀態存儲109

10.5 本章小結111

第11章 最常用的消費類112

11.1 整體流程112

11.1.1 上層接口類112

11.1.2 DefaultMQPushConsumer的實現者114

11.1.3 獲取消息邏輯116

11.2 消息的並發處理118

11.2.1 並發處理過程118

11.2.2 ProcessQueue對象121

11.3 生産者消費者的底層類122

11.3.1 MQClientInstance類的創建規則122

11.3.2 MQClientInstance類的功能124

11.4 本章小結127

第12章 主從同步機製128

12.1 同步屬性信息128

12.2 同步消息體130

12.3 sync_master和async_master132

12.4 本章小結134

第13章 基於Netty的通信實現135

13.1 Netty介紹135

13.2 Netty架構總覽136

13.2.1 重新實現ByteBuffer136

13.2.2 統一的異步 I/O接口137

13.2.3 基於攔截鏈模式的事件模型138

13.2.4 高級組件139

13.3 Netty用法示例140

13.3.1 Discard服務器140

13.3.2 查看收到的數據144

13.4 RocketMQ基於Netty的通信功能實現145

13.4.1 頂層抽象類145

13.4.2 自定義協議148

13.4.3 基於Netty的Server和Client151

13.5 本章小結152 

↑摺 疊

前言

為什麼要寫這本書

幾年前在做一個項目的時候，若需要用到消息隊列，簡單調研一下就會決定用Kafka，因為當時還不知道有RocketMQ。在我加入阿裏後，當時有個項目需要用到消息中間件，試用瞭RocketMQ，發現阿裏開源的消息中間件性能非常強大，但是上手有點費勁，因為現有文檔多是零零散散的博文。在沒有閤適文檔指導的情況下，對係統中用到的RocketMQ模塊心裏沒底，係統偶爾齣現異常時總會束手無策，需要通過查看很多源碼，纔能保證係統的穩定運行。

熟悉RocketMQ以後，我發現它是一款非常優秀的中間件産品，可以確保不丟消息，而且效率很高。同時因為它是用Java開發的，所以修改起來比較容易。

在阿裏內部，RocketMQ很好地服務瞭集團大大小小上韆個應用，在每年的雙十一當天，更有不可思議的萬億級消息通過RocketMQ流轉（在2017年的雙11當天，整個阿裏巴巴集團通過RocketMQ流轉的綫上消息達到瞭萬億級，峰值TPS達到5600萬），在阿裏大中颱策略上發揮著舉足輕重的作用。所以如果有閤適的參考文檔，RocketMQ會被更多人接受和使用，讓更多人不必重復造“輪子”。

我做瞭很多年開發，在學校課本上學的開發知識有限，大多數是通過看書和上網學到的，其中很多優秀的文章對自己幫助很大。所以我很希望能用這本書迴饋技術社區中有需要的開發者們。

動筆寫這本書前，我係統地閱讀瞭RocketMQ的源碼，有些理解不夠透徹的地方請教瞭阿裏RocketMQ開發團隊的同事，然後也總結瞭自己多年實際工作中的一些經驗。希望這本書能簡明扼要地說清楚RocketMQ的使用方法和核心原理。

讀者對象

希望學習分布式係統或分布式消息隊列的開發人員。

服務端係統開發者，他們可以藉助高質量中間件來提高開發效率。

軟件架構師，他們可以通過消息隊列優化復雜係統的設計。

评分☆☆☆☆☆

评分☆☆☆☆☆

评分☆☆☆☆☆

评分☆☆☆☆☆

评分☆☆☆☆☆

评分☆☆☆☆☆

评分☆☆☆☆☆

评分☆☆☆☆☆

评分☆☆☆☆☆