《RocketMQ實戰與原理解析》最新版讀書筆記，下載可以直接修改思維導圖PPT模板消息小結功能隊列第章作者處理輪詢角色方式方法流程場景信息核心消費者集群順序機制本書關鍵字分析思維導圖01第1章快速入門第3章用適合的方式發送和接收消息第5章消息隊列的核心機制第2章生產環境下的配置和使用第4章分布式消息隊列的協調者第6章可靠性優先的使用場景目錄030502040607第7章吞吐量優先的使用場景第9章首個Apache中間件頂級項目第8章和其他系統交互第10章NameServer源碼解析目錄0908010011第11章最常用的消費類第13章基于Netty的通信實現第12章主從同步機制目錄013012內容摘要本書作者是阿里資深數據專家，對RocketMQ有深入的研究，并有大量的實踐經驗。在寫這本書之前，作者不僅系統、深入地閱讀了RocketMQ的源代碼，而且還向RocketMQ的官方開發團隊深入了解了它的諸多設計細節。作者結合自己多年使用RocketMQ的經驗，從開發和運維兩個維度，給出了大部分場景下的優秀實踐，能幫助讀者在學會使用和用好RocketMQ的同時，盡量少“踩坑”。第1章快速入門一是發信者，二是收信者，三是負責暫存、傳輸的郵局，四是負責協調各個地方郵局的管理機構。1.1消息隊列功能介紹1.2RocketMQ簡介1.3快速上手RocketMQ1.4本章小結第1章快速入門第2章生產環境下的配置和使用對應到RocketMQ中，這四個角色就是Producer、Consumer、Broker和NameServer。2.1RocketMQ各部分角色介紹2.2多機集群配置和部署2.3發送/接收消息示例2.4常用管理命令2.5通過圖形界面管理集群2.6本章小結010302040506第2章生產環境下的配置和使用第3章用適合的方式發送和接收消息如果一個Topic要發送和接收的數據量非常大，需要能支持增加并行處理的機器來提高處理速度，這時候一個Topic可以根據需求設置一個或多個MessageQueue,MessageQueue類似分區或Partition。3.1不同類型的消費者3.2不同類型的生產者3.3如何存儲隊列位置信息3.4自定義日志輸出3.5本章小結12345第3章用適合的方式發送和接收消息第4章分布式消息隊列的協調者Topic有了多個MessageQueue后，消息可以并行地向各個MessageQueue發送，消費者也可以并行地從多個MessageQueue讀取消息并消費。4.1NameServer的功能4.2各個角色間的交互流程4.3底層通信機制4.4本章小結第4章分布式消息隊列的協調者第5章消息隊列的核心機制“長輪詢”的核心是，Broker端HOLD住客戶端過來的請求一小段時間，在這個時間內有新消息到達，就利用現有的連接立刻返回消息給Consumer。5.1消息存儲和發送5.2消息存儲結構5.3高可用性機制5.4同步刷盤和異步刷盤5.5同步復制和異步復制5.6本章小結010302040506第5章消息隊列的核心機制第6章可靠性優先的使用場景“長輪詢”的主動權還是掌握在Consumer手中，Broker即使有大量消息積壓，也不會主動推送給Consumer。6.1順序消息6.2消息重復問題6.3動態增減機器6.4各種故障對消息的影響6.5消息優先級6.6本章小結010302040506第6章可靠性優先的使用場景第7章吞吐量優先的使用場景分布式消息隊列可以提供應用解耦、流量消峰、消息分發等功能，已經成為大型互聯網服務架構里標配的中間件解決消息重復有兩種方法：第一種方法是保證消費邏輯的冪等性（多次調用和一次調用效果相同）；另一種方法是維護一個已消費消息的記錄，消費前查詢這個消息是否被消費過。7.1在Broker端進行消息過濾7.2提高Consumer處理能力7.3Consumer的負載均衡7.4提高Producer的發送速度7.5系統性能調優的一般流程7.6本章小結010302040506第7章吞吐量優先的使用場景第8章和其他系統交互這兩種方法都需要使用者自己實現。8.1在SpringBoot中使用Ro...8.2直接使用云上RocketMQ8.3RocketMQ與Spark、F...8.4自定義開發運維工具8.5本章小結12345第8章和其他系統交互第9章首個Apache中間件頂級項目一個是DefaultMQPushConsumer，由系統控制讀取操作，收到消息后自動調用傳入的處理方法來處理；另一個是DefaultMQPullConsumer，讀取操作中的大部分功能由使用者自主控制保證全局順序消息，需要先把Topic的讀寫隊列數設置為一，然后Producer和Consumer的并發設置也要是一。9.1RocketMQ的前世今生9.2Apache頂級項目（TLP）之...9.3源碼結構9.4不斷迭代的代碼9.5本章小結12345第9章首個Apache中間件頂級項目第10章NameServer源碼解析在發送端，要做到把同一業務ID的消息發送到同一個MessageQueue；在消費過程中，要做到從同一個MessageQueue讀取的消息不被并發處理，這樣才能達到部分有序這是通過“長輪詢”方式達到Push效果的方法，長輪詢方式既有Pull的優點，又兼具Push方式的實時性。10.1模塊入口代碼的功能10.2NameServer的總控邏輯10.3核心業務邏輯處理10.4集群狀態存儲10.5本章小結12345第10章NameServer源碼解析第11章最常用的消費類第一代的Notify主要使用了推模型，解決了事務消息；第二代的MetaQ主要使用了拉模型，解決了順序消息和海量堆積的問題。11.1整體流程11.2消息的并發處理11.3生產者消費者的底層類11.4本章小結第11章最常用的消費類第12章主從同步機制RocketMQ基于長輪詢的拉取方式，兼有兩者的優點。12.1同步屬性信息12.2同步消息體12.3sync_master和asy...12.4本章小結第12章主從同步機制第13章基于Netty的通信實現此書對于了解rocketMQ大有幫助，建議閱讀，關鍵也沒幾本書可供選擇[呲牙]數據的存儲邏輯理解了，其他的都好說，可以設想自己也要開發一個MQ中間件，