Broker精品文章

• 

  ActiveMQ集群整體認(rèn)識(shí)

  ...eMQ集群部署方式 ActiveMQ集群的部署方式主要有下面2種： Broker Clusters 模式：實(shí)現(xiàn)負(fù)載均衡，多個(gè)broker之間同步消息，已達(dá)到服務(wù)器負(fù)載的可能。 Master Slave 模式：實(shí)現(xiàn)高可用，當(dāng)主服務(wù)器宕機(jī)時(shí)，備用服務(wù)器可以立即補(bǔ)充，以保...

  sixgo 2019-08-15 15:42 評(píng)論0 收藏0
• 

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

  問題列表: Name Server 的作用是什么? Name Server 存儲(chǔ)了Broker的什么信息? Name Server 為Producer的提供些什么信息? Name Server 為Consuner的提供些什么信息? Name Server 作用 Name Server在RocketMQ中猶如如它名字一樣,是提供Broker發(fā)現(xiàn)服務(wù)的. Pro...

  Joyven 2019-08-16 10:44 評(píng)論0 收藏0
• 

  深度解析RocketMQ Topic的創(chuàng)建機(jī)制

  ...息隊(duì)列，消息內(nèi)容實(shí)際是存放在隊(duì)列中，而隊(duì)列又存儲(chǔ)在broker中，下面我用一張圖來說明topic的存儲(chǔ)模型： 其實(shí)rocketmq中存在兩種不同的topic創(chuàng)建方式，一種是我剛剛說的預(yù)先創(chuàng)建，另一種是自動(dòng)創(chuàng)建，下面我開車帶大家從源碼...

  gself 2019-08-16 16:17 評(píng)論0 收藏0
• 

  高并發(fā)異步解耦利器：RocketMQ究竟強(qiáng)在哪里？

  ...ssage Id的高效查詢？RocketMQ的Topic在集群中是如何存儲(chǔ)的？Broker自動(dòng)創(chuàng)建Topic會(huì)有什么問題？RocketMQ如何保證消息投遞的順序性？RocketMQ如何保證消息消費(fèi)的順序性？實(shí)現(xiàn)分布式事務(wù)的手段有哪些？RocketMQ如何實(shí)現(xiàn)事務(wù)消息？RocketMQ...

  tainzhi 2021-11-23 09:51 評(píng)論0 收藏0
• 

  kafka

  ...ka有以下一些基本概念： Producer 消息生產(chǎn)者，就是向kafka broker發(fā)消息的客戶端。 Consumer 消息消費(fèi)者，是消息的使用方，負(fù)責(zé)消費(fèi)Kafka服務(wù)器上的消息。 Topic 主題，由用戶定義并配置在Kafka服務(wù)器，用于建立Producer和Consumer之間的...

  W4n9Hu1 2019-07-30 18:35 評(píng)論0 收藏0
• 

  從RocketMQ我們學(xué)到了什么之NameServer

  ...的寄件人。 NameServer：路由注冊(cè)中?，就是圖中的衛(wèi)星。 Broker：消息存儲(chǔ)服務(wù)器，就是圖中的郵局。 Consumer：消息消費(fèi)者，不是今天的重點(diǎn)，圖中未標(biāo)出，就是收件人。 由此可見，NameServer作為分布式消息隊(duì)列的協(xié)調(diào)者，具有信...

  wangbjun 2019-08-16 15:57 評(píng)論0 收藏0
• 

  從RocketMQ我們學(xué)到了什么之NameServer

  ...的寄件人。 NameServer：路由注冊(cè)中?，就是圖中的衛(wèi)星。 Broker：消息存儲(chǔ)服務(wù)器，就是圖中的郵局。 Consumer：消息消費(fèi)者，不是今天的重點(diǎn)，圖中未標(biāo)出，就是收件人。 由此可見，NameServer作為分布式消息隊(duì)列的協(xié)調(diào)者，具有信...

  Arno 2019-07-24 10:54 評(píng)論0 收藏0
• 

  rocketmq之producer解析

  ...ServerInterval 30000 輪詢nameserver的時(shí)間間隔，單位ms heartbeatBrokerInterval 30000 向broker發(fā)送心跳的時(shí)間間隔，單位ms persistConsumerOffsetInterval 5000 持久化 Consumer 消費(fèi)進(jìn)度間隔時(shí)間，單位ms producer獨(dú)有的配置： 參數(shù)名 默認(rèn)值 說明 p...

  luodongseu 2019-08-19 11:15 評(píng)論0 收藏0
• 

  【Kafka】《Kafka權(quán)威指南》入門

  ...便接收特定類型的消息。發(fā)布與訂閱系統(tǒng)一般會(huì)有一個(gè) broker，也就是發(fā)布消息的中心點(diǎn)。 發(fā)布與訂閱消息系統(tǒng)的大部分應(yīng)用場(chǎng)景都是從一個(gè)簡(jiǎn)單的消息隊(duì)列或一個(gè)進(jìn)程間通信開始的。比如電商系統(tǒng)中，包含會(huì)員模塊、訂單模塊...

  番茄西紅柿 2019-05-23 16:08 評(píng)論0 收藏0
• 

  【Kafka】《Kafka權(quán)威指南》入門

  ...便接收特定類型的消息。發(fā)布與訂閱系統(tǒng)一般會(huì)有一個(gè) broker，也就是發(fā)布消息的中心點(diǎn)。 發(fā)布與訂閱消息系統(tǒng)的大部分應(yīng)用場(chǎng)景都是從一個(gè)簡(jiǎn)單的消息隊(duì)列或一個(gè)進(jìn)程間通信開始的。比如電商系統(tǒng)中，包含會(huì)員模塊、訂單模塊...

  番茄西紅柿 2019-05-23 16:08 評(píng)論0 收藏0