相關商品
商品簡介
名人/編輯推薦
目次
商品簡介
內容介紹
這是一本指導讀者如何在實踐中讓RocketMQ實現高性能、高可用、高吞吐量和低延遲的著作。
作者是RocketMQ官方認定的“優 秀佈道師”和技術專家，持續在RocketMQ領域深耕。本書從源碼的角度分析了RocketMQ的技術架構和實現原理，第1版獲得了良好的口碑，是RocketMQ領域的標誌性作品，第2版做了較大幅度的更新。
Apache RocketMQ創始人/Linux OpenMessaging創始人兼主席/Alibaba Messaging開放技術負責人馮嘉高度評價並作序推薦。
全書一共11章，邏輯上可分為3個部分：
第1部分（第1章）：
簡單介紹了RocketMQ的設計理念與目標，以及閱讀RocketMQ源碼的方法與技巧；
第二部分（第2～9章）：
從源碼角度對RocketMQ的技術架構以及消息發送、消息存儲、消息消費、消息過濾、順序消息、主從同步、事務消息等主要功能模塊的實現原理進行了深入分析。
第三部分（第10～11章）：
首先從實戰的角度講了RocketMQ監控的原理、實現和應用，然後通過各種類型的大量示例展示了RocketMQ的使用技巧。
這是一本指導讀者如何在實踐中讓RocketMQ實現高性能、高可用、高吞吐量和低延遲的著作。
作者是RocketMQ官方認定的“優 秀佈道師”和技術專家，持續在RocketMQ領域深耕。本書從源碼的角度分析了RocketMQ的技術架構和實現原理，第1版獲得了良好的口碑，是RocketMQ領域的標誌性作品，第2版做了較大幅度的更新。
Apache RocketMQ創始人/Linux OpenMessaging創始人兼主席/Alibaba Messaging開放技術負責人馮嘉高度評價並作序推薦。
全書一共11章，邏輯上可分為3個部分：
第1部分（第1章）：
簡單介紹了RocketMQ的設計理念與目標，以及閱讀RocketMQ源碼的方法與技巧；
第二部分（第2～9章）：
從源碼角度對RocketMQ的技術架構以及消息發送、消息存儲、消息消費、消息過濾、順序消息、主從同步、事務消息等主要功能模塊的實現原理進行了深入分析。
第三部分（第10～11章）：
首先從實戰的角度講了RocketMQ監控的原理、實現和應用，然後通過各種類型的大量示例展示了RocketMQ的使用技巧。
名人/編輯推薦
暢銷書升級，RocketMQ官方推薦，剖析9大模塊源碼，實現高性能、高可用、高吞吐量、低延遲
目次
序
前言
第1章 閱讀源碼前的準備1
1.1 獲取和調試RocketMQ的源碼1
1.1.1 Eclipse獲取RocketMQ源碼1
1.1.2 Eclipse調試RocketMQ源碼8
1.1.3 IntelliJ IDEA獲取RocketMQ源碼14
1.1.4 IntelliJ IDEA調試RocketMQ源碼16
1.2 RocketMQ源碼的目錄結構23
1.3 RocketMQ的設計理念和設計目標23
1.3.1 設計理念23
1.3.2 設計目標24
1.4 本章小結26
第2章 RocketMQ路由中心NameServer27
2.1 NameServer架構設計27
2.2 NameServer啟動流程29
2.3 NameServer路由註冊、故障剔除32
2.3.1 路由元信息32
2.3.2 路由註冊35
2.3.3 路由刪除40
2.3.4 路由發現43
2.4 本章小結44
第3章 RocketMQ消息發送46
3.1 漫談RocketMQ消息發送46
3.1.1 topic路由機制47
3.1.2 消息發送高可用設計48
3.2 認識RocketMQ消息50
3.3 生產者啟動流程51
3.3.1 初識DefaultMQProducer51
3.3.2 消息生產者啟動流程54
3.4 消息發送基本流程55
3.4.1 消息長度驗證56
3.4.2 查找主題路由信息57
3.4.3 選擇消息隊列60
3.4.4 消息發送65
3.5 批量消息發送72
3.6 本章小結74
第4章 RocketMQ消息存儲75
4.1 存儲概要設計75
4.1.1 RocketMQ存儲文件的組織方式76
4.1.2 內存映射80
4.1.3 靈活多變的刷盤策略81
4.1.4 transientStorePoolEnable機制82
4.1.5 文件恢複機制82
4.2 初識消息存儲83
4.3 消息發送存儲流程84
4.4 存儲文件組織與內存映射90
4.4.1 MappedFileQueue映射文件隊列 90
4.4.2 MappedFile內存映射文件92
4.4.3 TransientStorePool99
4.5 RocketMQ存儲文件100
4.5.1 CommitLog文件101
4.5.2 ConsumeQueue文件102
4.5.3 Index文件106
4.5.4 checkpoint文件110
4.6 實時更新ConsumeQueue與Index文件111
4.6.1 根據消息更新ConsumeQueue文件113
4.6.2 根據消息更新Index文件114
4.7 ConsumeQueue與Index文件恢複115
4.7.1 Broker正常停止文件恢複118
4.7.2 Broker異常停止文件恢複120
4.8 文件刷盤機制121
4.8.1 Broker同步刷盤122
4.8.2 Broker異步刷盤125
4.9 過期文件刪除機制128
4.10 同步雙寫132
4.11 本章小結136
第5章 RocketMQ消息消費137
5.1 RocketMQ消息消費概述137
5.1.1 消費隊列負載機制與重平衡138
5.1.2 併發消費模型139
5.1.3 消息消費進度反饋機制139
5.2 消息消費者初探141
5.3 消費者啟動流程143
5.4 消息拉取146
5.4.1 PullMessageService實現機制147
5.4.2 ProcessQueue實現機制149
5.4.3 消息拉取基本流程150
5.5 消息隊列負載與重新分佈機制167
5.6 消息消費過程175
5.6.1 消息消費176
5.6.2 消息確認180
5.6.3 消費進度管理184
5.7 定時消息機制189
5.7.1 load()方法190
5.7.2 start()方法190
5.7.3 定時調度邏輯192
5.8 消息過濾機制194
5.9 順序消息199
5.9.1 消息隊列負載199
5.9.2 消息拉取200
5.9.3 消息消費201
5.9.4 消息隊列鎖實現208
5.10 本章小結209
第6章 RocketMQ的ACL210
6.1 什麼是ACL210
6.2 如何使用ACL211
6.2.1 Broker端開啟ACL211
6.2.2 客戶端使用ACL212
6.3 ACL實現原理214
6.3.1 Broker端ACL核心入口214
6.3.2 PlainAccessValidator詳解216
6.3.3 PlainPermissionManager詳解220
6.3.4 AclClientRPCHook詳解228
6.4 本章小結231
第7章 RocketMQ主從同步機制232
7.1 RocketMQ主從同步原理232
7.1.1 HAService整體工作機制233
7.1.2 AcceptSocketService實現原理233
7.1.3 GroupTransferService實現原理235
7.1.4 HAClient實現原理236
7.1.5 HAConnection實現原理239
7.2 RocketMQ讀寫分離機制245
7.3 RocketMQ元數據同步248
7.3.1 從節點主動同步元數據249
7.3.2 主節點消息拉取主動同步消費進度250
7.4 本章小結251
第8章 RocketMQ消息軌跡252
8.1 消息軌跡的引入目的和使用方法252
8.2 消息軌跡設計原理255
8.2.1 消息軌跡數據格式255
8.2.2 如何採集軌跡數據256
8.2.3 如何存儲消息軌跡數據257
8.3 消息軌跡實現原理257
8.3.1 尋找消息軌跡入口257
8.3.2 消息發送軌跡數據259
8.3.3 消息軌跡異步轉發實現機制261
8.4 本章小結265
第9章 RocketMQ主從切換266
9.1 主從切換引入目的266
9.2 Raft協議簡介267
9.2.1 Leader選舉267
9.2.2 日誌複製268
9.3 RocketMQ DLedger主從切換之Leader選主269
9.3.1 DLedgerLeaderElector核心類及核心屬性270
9.3.2 選舉狀態管理器初始化271
9.3.3 選舉狀態機狀態流轉273
9.3.4 發送投票請求與處理投票請求280
9.3.5 發送心跳包與處理心跳包283
9.4 RocketMQ DLedger主從切換之存儲實現288
9.4.1 RocketMQ DLedger核心類及核心屬性288
9.4.2 RocketMQ DLedger數據存儲協議290
9.4.3 RocketMQ DLedger索引存儲協議291
9.5 RocketMQ DLedger主從切換之日誌追加291
9.5.1 日誌追加流程概述291
9.5.2 判斷Push隊列是否已滿293
9.5.3 Leader節點日誌存儲293
9.5.4 Leader節點等待從節點日誌複製響應ACK298
9.6 RocketMQ DLedger主從切換之日誌複製299
9.6.1 日誌複製設計理念300
9.6.2 日誌複製類設計體系301
9.6.3 日誌轉發303
9.7 RocketMQ整合DLedger設計技巧與實現原理326
9.7.1 數據存儲兼容設計327
9.7.2 數據存儲兼容實現原理328
9.7.3 主從切換元數據同步機制337
9.8 RocketMQ主從切換實戰344
9.8.1 主從切換核心配置屬性344
9.8.2 搭建主從同步環境344
9.8.3 主從同步集群升級到主從切換346
9.9 本章小結350
第10章 RocketMQ監控352
10.1 設計理念352
10.2 實現原理353
10.2.1 監控相關類圖353
10.2.2 監控原始數據采集流程355
10.3 監控數據採樣機制356
10.3.1 監控數據採樣356
10.3.2 根據採樣計算統計指標357
10.4 如何採集監控指標359
10.5 監控實戰應用360
10.6 本章小結365
第11章 RocketMQ實戰366
11.1 消息批量發送366
11.2 消息發送隊列自選擇367
11.3 消息過濾368
11.3.1 TAG過濾模式368
11.3.2 SQL過濾模式368
11.3.3 類過濾模式369
11.4 事務消息371
11.5 Spring整合RocketMQ375
11.6 Spring Cloud整合RocketMQ376
11.7 RocketMQ監控與運維命令384
11.7.1 搭建RocketMQ監控平臺rocketmq-console384
11.7.2 RocketMQ管理命令387
11.8 應用場景分析423
11.9 實戰案例424
11.9.1 RocketMQ集群線上故障縮容實戰案例424
11.9.2 RocketMQ在線擴容實戰427
11.10 本章小結430
附錄 A 參數說明431
附錄B RocketMQ各版本概述與升級建議436
前言
第1章 閱讀源碼前的準備1
1.1 獲取和調試RocketMQ的源碼1
1.1.1 Eclipse獲取RocketMQ源碼1
1.1.2 Eclipse調試RocketMQ源碼8
1.1.3 IntelliJ IDEA獲取RocketMQ源碼14
1.1.4 IntelliJ IDEA調試RocketMQ源碼16
1.2 RocketMQ源碼的目錄結構23
1.3 RocketMQ的設計理念和設計目標23
1.3.1 設計理念23
1.3.2 設計目標24
1.4 本章小結26
第2章 RocketMQ路由中心NameServer27
2.1 NameServer架構設計27
2.2 NameServer啟動流程29
2.3 NameServer路由註冊、故障剔除32
2.3.1 路由元信息32
2.3.2 路由註冊35
2.3.3 路由刪除40
2.3.4 路由發現43
2.4 本章小結44
第3章 RocketMQ消息發送46
3.1 漫談RocketMQ消息發送46
3.1.1 topic路由機制47
3.1.2 消息發送高可用設計48
3.2 認識RocketMQ消息50
3.3 生產者啟動流程51
3.3.1 初識DefaultMQProducer51
3.3.2 消息生產者啟動流程54
3.4 消息發送基本流程55
3.4.1 消息長度驗證56
3.4.2 查找主題路由信息57
3.4.3 選擇消息隊列60
3.4.4 消息發送65
3.5 批量消息發送72
3.6 本章小結74
第4章 RocketMQ消息存儲75
4.1 存儲概要設計75
4.1.1 RocketMQ存儲文件的組織方式76
4.1.2 內存映射80
4.1.3 靈活多變的刷盤策略81
4.1.4 transientStorePoolEnable機制82
4.1.5 文件恢複機制82
4.2 初識消息存儲83
4.3 消息發送存儲流程84
4.4 存儲文件組織與內存映射90
4.4.1 MappedFileQueue映射文件隊列 90
4.4.2 MappedFile內存映射文件92
4.4.3 TransientStorePool99
4.5 RocketMQ存儲文件100
4.5.1 CommitLog文件101
4.5.2 ConsumeQueue文件102
4.5.3 Index文件106
4.5.4 checkpoint文件110
4.6 實時更新ConsumeQueue與Index文件111
4.6.1 根據消息更新ConsumeQueue文件113
4.6.2 根據消息更新Index文件114
4.7 ConsumeQueue與Index文件恢複115
4.7.1 Broker正常停止文件恢複118
4.7.2 Broker異常停止文件恢複120
4.8 文件刷盤機制121
4.8.1 Broker同步刷盤122
4.8.2 Broker異步刷盤125
4.9 過期文件刪除機制128
4.10 同步雙寫132
4.11 本章小結136
第5章 RocketMQ消息消費137
5.1 RocketMQ消息消費概述137
5.1.1 消費隊列負載機制與重平衡138
5.1.2 併發消費模型139
5.1.3 消息消費進度反饋機制139
5.2 消息消費者初探141
5.3 消費者啟動流程143
5.4 消息拉取146
5.4.1 PullMessageService實現機制147
5.4.2 ProcessQueue實現機制149
5.4.3 消息拉取基本流程150
5.5 消息隊列負載與重新分佈機制167
5.6 消息消費過程175
5.6.1 消息消費176
5.6.2 消息確認180
5.6.3 消費進度管理184
5.7 定時消息機制189
5.7.1 load()方法190
5.7.2 start()方法190
5.7.3 定時調度邏輯192
5.8 消息過濾機制194
5.9 順序消息199
5.9.1 消息隊列負載199
5.9.2 消息拉取200
5.9.3 消息消費201
5.9.4 消息隊列鎖實現208
5.10 本章小結209
第6章 RocketMQ的ACL210
6.1 什麼是ACL210
6.2 如何使用ACL211
6.2.1 Broker端開啟ACL211
6.2.2 客戶端使用ACL212
6.3 ACL實現原理214
6.3.1 Broker端ACL核心入口214
6.3.2 PlainAccessValidator詳解216
6.3.3 PlainPermissionManager詳解220
6.3.4 AclClientRPCHook詳解228
6.4 本章小結231
第7章 RocketMQ主從同步機制232
7.1 RocketMQ主從同步原理232
7.1.1 HAService整體工作機制233
7.1.2 AcceptSocketService實現原理233
7.1.3 GroupTransferService實現原理235
7.1.4 HAClient實現原理236
7.1.5 HAConnection實現原理239
7.2 RocketMQ讀寫分離機制245
7.3 RocketMQ元數據同步248
7.3.1 從節點主動同步元數據249
7.3.2 主節點消息拉取主動同步消費進度250
7.4 本章小結251
第8章 RocketMQ消息軌跡252
8.1 消息軌跡的引入目的和使用方法252
8.2 消息軌跡設計原理255
8.2.1 消息軌跡數據格式255
8.2.2 如何採集軌跡數據256
8.2.3 如何存儲消息軌跡數據257
8.3 消息軌跡實現原理257
8.3.1 尋找消息軌跡入口257
8.3.2 消息發送軌跡數據259
8.3.3 消息軌跡異步轉發實現機制261
8.4 本章小結265
第9章 RocketMQ主從切換266
9.1 主從切換引入目的266
9.2 Raft協議簡介267
9.2.1 Leader選舉267
9.2.2 日誌複製268
9.3 RocketMQ DLedger主從切換之Leader選主269
9.3.1 DLedgerLeaderElector核心類及核心屬性270
9.3.2 選舉狀態管理器初始化271
9.3.3 選舉狀態機狀態流轉273
9.3.4 發送投票請求與處理投票請求280
9.3.5 發送心跳包與處理心跳包283
9.4 RocketMQ DLedger主從切換之存儲實現288
9.4.1 RocketMQ DLedger核心類及核心屬性288
9.4.2 RocketMQ DLedger數據存儲協議290
9.4.3 RocketMQ DLedger索引存儲協議291
9.5 RocketMQ DLedger主從切換之日誌追加291
9.5.1 日誌追加流程概述291
9.5.2 判斷Push隊列是否已滿293
9.5.3 Leader節點日誌存儲293
9.5.4 Leader節點等待從節點日誌複製響應ACK298
9.6 RocketMQ DLedger主從切換之日誌複製299
9.6.1 日誌複製設計理念300
9.6.2 日誌複製類設計體系301
9.6.3 日誌轉發303
9.7 RocketMQ整合DLedger設計技巧與實現原理326
9.7.1 數據存儲兼容設計327
9.7.2 數據存儲兼容實現原理328
9.7.3 主從切換元數據同步機制337
9.8 RocketMQ主從切換實戰344
9.8.1 主從切換核心配置屬性344
9.8.2 搭建主從同步環境344
9.8.3 主從同步集群升級到主從切換346
9.9 本章小結350
第10章 RocketMQ監控352
10.1 設計理念352
10.2 實現原理353
10.2.1 監控相關類圖353
10.2.2 監控原始數據采集流程355
10.3 監控數據採樣機制356
10.3.1 監控數據採樣356
10.3.2 根據採樣計算統計指標357
10.4 如何採集監控指標359
10.5 監控實戰應用360
10.6 本章小結365
第11章 RocketMQ實戰366
11.1 消息批量發送366
11.2 消息發送隊列自選擇367
11.3 消息過濾368
11.3.1 TAG過濾模式368
11.3.2 SQL過濾模式368
11.3.3 類過濾模式369
11.4 事務消息371
11.5 Spring整合RocketMQ375
11.6 Spring Cloud整合RocketMQ376
11.7 RocketMQ監控與運維命令384
11.7.1 搭建RocketMQ監控平臺rocketmq-console384
11.7.2 RocketMQ管理命令387
11.8 應用場景分析423
11.9 實戰案例424
11.9.1 RocketMQ集群線上故障縮容實戰案例424
11.9.2 RocketMQ在線擴容實戰427
11.10 本章小結430
附錄 A 參數說明431
附錄B RocketMQ各版本概述與升級建議436
您曾經瀏覽過的商品
購物須知
大陸出版品因裝訂品質及貨運條件與台灣出版品落差甚大，除封面破損、內頁脫落等較嚴重的狀態，其餘商品將正常出貨。
特別提醒：部分書籍附贈之內容(如音頻mp3或影片dvd等)已無實體光碟提供，需以QR CODE 連結至當地網站註冊“並通過驗證程序”，方可下載使用。
無現貨庫存之簡體書，將向海外調貨：
海外有庫存之書籍，等候約45個工作天;
海外無庫存之書籍，平均作業時間約60個工作天，然不保證確定可調到貨，尚請見諒。
為了保護您的權益，「三民網路書店」提供會員七日商品鑑賞期(收到商品為起始日)。
若要辦理退貨，請在商品鑑賞期內寄回，且商品必須是全新狀態與完整包裝(商品、附件、發票、隨貨贈品等)否則恕不接受退貨。