成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

RocketMQ源碼學(xué)習(xí)(一)-概述

godlong_X / 758人閱讀

摘要：每個與集群中的所有節(jié)點(diǎn)建立長連接，定時注冊信息到所有。完全無狀態(tài)，可集群部署。本系列源碼解析主要參照原理簡介來追尋其代碼實(shí)現(xiàn)雖然版本不太一致但這也是能找到的最詳細(xì)的資料了接下來根據(jù)其模塊來源碼閱讀目錄如下

為什么選擇讀RocketMQ?

對MQ的理解一直不深,上周看了,還是覺得不夠深入,找個成熟的產(chǎn)品來學(xué)習(xí)吧,RabbitMQ是erLang寫的,Kafka是Scala寫的,非Java寫的看起來還需要補(bǔ)充很多知識,ActiveMQ雖然是Java,但是各方面略顯老舊,最終選擇了RocketMQ(4.1.0-incubating release)來學(xué)習(xí).

吐槽下RocketMQ

　　　作為阿里巴巴捐給Apache的項(xiàng)目,官網(wǎng)上有用的資源太少了,到處都只說性能的數(shù)據(jù),還有簡單例子,詳細(xì)的使用文檔竟然沒有了,怪不得沒有kafka流行呢,dubbo的文檔都比這強(qiáng)很多,話說開源產(chǎn)品不是擺來看和吹牛的,讓更多的人方便使用起來才是開源的核心思想吧,另外源碼中的注釋也實(shí)在太少了,還不如我司的項(xiàng)目的注釋齊全呢,跟JDK,Spring比起來差太多了,不過好在名字起的不錯,編碼也規(guī)范,看起來還能繼續(xù)下去.

概覽


如圖所示RocketMQ的使用由命名服務(wù)，生產(chǎn)者，消費(fèi)者，中轉(zhuǎn)服務(wù)器組成．

Name Server 是一個幾乎無狀態(tài)節(jié)點(diǎn)，可集群部署，節(jié)點(diǎn)之間無任何信息同步

Broker 部署相對復(fù)雜，Broker 分為 Master 與 Slave，一個 Master 可以對應(yīng)多個 Slave，但是一個 Slave 只能對應(yīng)一個 Master，Master 與 Slave 的對應(yīng)關(guān)系通過指定相同的 BrokerName，不同的 BrokerId 來定義，BrokerId為 0 表示 Master，非 0 表示 Slave。Master 也可以部署多個。每個 Broker 與 Name Server 集群中的所有節(jié)點(diǎn)建立長連接，定時注冊 Topic 信息到所有 Name Server。

Producer 與 Name Server 集群中的其中一個節(jié)點(diǎn)(隨機(jī)選擇)建立長連接，定期從 Name Server 取 Topic 路由信息，并向提供 Topic 服務(wù)的 Master 建立長連接，且定時向 Master 發(fā)送心跳。Producer 完全無狀態(tài)，可
集群部署。

Consumer 與 Name Server 集群中的其中一個節(jié)點(diǎn)(隨機(jī)選擇)建立長連接，定期從 Name Server 取 Topic 路
由信息，并向提供 Topic 服務(wù)的 Master、Slave 建立長連接，且定時向 Master、Slave 發(fā)送心跳。Consumer 既可以從 Master 訂閱消息，也可以從 Slave 訂閱消息，訂閱規(guī)則由 Broker 配置決定。

本系列源碼解析主要參照來追尋其代碼實(shí)現(xiàn),雖然版本不太一致,但這也是能找到的最詳細(xì)的資料了.接下來根據(jù)其模塊來源碼閱讀
目錄如下:
1.　Name Server
2.　Producer
3.　Broker
4.　Consumer

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/70243.html

相關(guān)文章

  • RocketMQ源碼學(xué)習(xí)(六)-Name Server

    摘要：完全無狀態(tài)，可集群部署與集群中的其中一個節(jié)點(diǎn)隨機(jī)選擇建立長連接，定期從取路由信息，并向提供服務(wù)的建立長連接，且定時向發(fā)送心跳。既可以從訂閱消息，也可以從訂閱消息，訂閱規(guī)則由配置決定。 問題列表: Name Server 的作用是什么? Name Server 存儲了Broker的什么信息? Name Server 為Producer的提供些什么信息? Name Server 為Co...

    Joyven 評論0 收藏0

  • jvm原理

    摘要：在之前，它是一個備受爭議的關(guān)鍵字，因?yàn)樵诔绦蛑惺褂盟占骼斫夂驮矸治龊喎Q，是后提供的面向大內(nèi)存區(qū)數(shù)到數(shù)多核系統(tǒng)的收集器，能夠?qū)崿F(xiàn)軟停頓目標(biāo)收集并且具有高吞吐量具有更可預(yù)測的停頓時間。 35 個 Java 代碼性能優(yōu)化總結(jié) 優(yōu)化代碼可以減小代碼的體積，提高代碼運(yùn)行的效率。 從 JVM 內(nèi)存模型談線程安全 小白哥帶你打通任督二脈 Java使用讀寫鎖替代同步鎖 應(yīng)用情景 前一陣有個做...

    lufficc 評論0 收藏0

  • 讓你看懂的RocketMQ事務(wù)消息源碼分析(干貨)

    摘要：但是服務(wù)器又確實(shí)是收到了這條消息的，只是給客戶端的響應(yīng)丟失了，所以導(dǎo)致的結(jié)果就是扣款失敗，成功發(fā)貨。所有的半消息都會寫在為的半消息隊(duì)列里，并且每條半消息，在整個鏈路里會被寫多次，如果并發(fā)很大且大部分消息都是事務(wù)消息的話，可靠性會存在問題。 前言 得益于MQ削峰填谷，系統(tǒng)解耦，操作異步等功能特性，在互聯(lián)網(wǎng)行業(yè)，可以說有分布式服務(wù)的地方，MQ都往往不會缺席。由阿里自研的RocketMQ更是...

    zsirfs 評論0 收藏0

  • 一定能看懂的RocketMQ事務(wù)消息源碼分析(干貨)

    摘要：但是服務(wù)器又確實(shí)是收到了這條消息的，只是給客戶端的響應(yīng)丟失了，所以導(dǎo)致的結(jié)果就是扣款失敗，成功發(fā)貨。既然消息的發(fā)送不能和本地事務(wù)寫在一起，那如何來保證其整體具有原子性的需求呢答案就是今天我們介紹的主角事務(wù)消息。 前言 得益于MQ削峰填谷，系統(tǒng)解耦，操作異步等功能特性，在互聯(lián)網(wǎng)行業(yè)，可以說有分布式服務(wù)的地方，MQ都往往不會缺席。由阿里自研的RocketMQ更是經(jīng)歷了多年的雙十一高并發(fā)挑戰(zhàn)...

    myshell 評論0 收藏0

  • 寫這么多系列博客，怪不得找不到女朋友

    摘要：前提好幾周沒更新博客了，對不斷支持我博客的童鞋們說聲抱歉了。熟悉我的人都知道我寫博客的時間比較早，而且堅(jiān)持的時間也比較久，一直到現(xiàn)在也是一直保持著更新狀態(tài)。 showImg(https://segmentfault.com/img/remote/1460000014076586?w=1920&h=1080); 前提 好幾周沒更新博客了，對不斷支持我博客的童鞋們說聲：抱歉了！。自己這段時...

    JerryWangSAP 評論0 收藏0

發(fā)表評論

0條評論

godlong_X

男|高級講師

TA的文章

閱讀更多
最新活動
閱讀需要支付1元查看
<