RocketMQ中Broker的消息存儲源碼分析
Broker和前面分析過的NameServer類似，需要在Pipeline責任鏈上通過NettyServerHandler來處理消息 【RocketMQ中NameServer的啟動源碼分析】 實際上就通過前面提到的SendMessageProcessor ...
原文：rocketmq源碼分析2-broker的消息接收
broker消息接收，假設接收的是一個普通消息 即沒有事務 ，此處分析也只分析master上動作邏輯，不涉及ha。 . 如何找到消息接收處理入口 可以通過broker的監聽端口 順藤摸瓜式的找到 NettyClientConfig.setListenPort gt BrokerStartup gt BrokerController gt NettyRemotingServercom.alibaba ...
2017-02-05 19:37 0 1871 推薦指數：
相關推薦
RocketMQ中Broker的刷盤源碼分析
上一篇博客的最后簡單提了下CommitLog的刷盤 【RocketMQ中Broker的消息存儲源碼分析】 （這篇博客和上一篇有很大的聯系） Broker的CommitLog刷盤會啟動一個線程，不停地將緩沖區的內容寫入磁盤（CommitLog文件）中，主要分為異步刷盤和同步刷盤 異步刷盤又可 ...
RocketMQ中Broker的啟動源碼分析（一）
在RocketMQ中，使用BrokerStartup作為啟動類，相較於NameServer的啟動，Broker作為RocketMQ的核心可復雜得多 【RocketMQ中NameServer的啟動源碼分析】 主函數作為其啟動的入口 ...
RocketMQ源碼詳解 | Broker篇 · 其一：線程模型與接收鏈路
概述 在上一節 RocketMQ源碼詳解 | Producer篇 · 其二：消息組成、發送鏈路 中，我們終於將消息發送出了 Producer，在短暫的 tcp 握手后，很快它就會進入目的 Broker。這次我們來自底向上的看下 Broker 端是如何接收然后分發處理消息，同時了解 ...
源碼分析RocketMQ消息軌跡
本文沿着《RocketMQ消息軌跡-設計篇》的思路，從如下3個方面對其源碼進行解讀： 發送消息軌跡 消息軌跡格式 存儲消息軌跡數據 @ 目錄 1、發送消息軌跡流程 1.1 DefaultMQProducer構造函數 1.2 ...
RocketMQ 源碼學習筆記 Producer 是怎么將消息發送至 Broker 的？
RocketMQ 源碼學習筆記 Producer 是怎么將消息發送至 Broker 的？ 目錄 RocketMQ 源碼學習筆記 Producer 是怎么將消息發送至 Broker 的？ 前言 項目結構 rocketmq-client 模塊 ...
RocketMQ源碼 — 四、 Consumer 接收消息過程
Consumer consumer pull message 訂閱 在Consumer啟動之前先將自己放到一個本地的集合中，再以后獲取消費者的時候會用到，同時會將自己訂閱的信息告訴broker 接收消息 consumer啟動的時候會啟動兩個service ...
RocketMQ源碼詳解 | Broker篇 · 其四：事務消息、批量消息、延遲消息
概述 在上文中，我們討論了消費者對於消息拉取的實現，對於 RocketMQ 這個黑盒的心臟部分，我們順着消息的發送流程已經將其剖析了大半部分。本章我們不妨乘勝追擊，接着討論各種不同的消息的原理與實現。 事務消息 概念 RocketMQ 中的事務消息功能，實際上是 分布式事務中的本地 ...