什么是rocketmq RocketMQ 是阿里巴巴开源的消息队列中间件。具有下列特点： 能够保证严格的消息顺序 提供丰富的消息拉取模式 高效的...
投稿
收录了15篇文章 · 23人关注
-
rocketmq 使用学习 -
RocketMQ源码阅读(六)-消息生产者上文介绍了双Master模式的就你部署, 本文分析消息生产者发送消息的过程. 1.例子 在源码包的org.apache.rocketmq.exa...
-
RocketMQ源码阅读(五)-Linux环境搭建RocketMQ双Master模式
前面几片文章介绍了RocketMQ底层的文件存储技术, 后续的文章会分析RocketMQ的消息发送和处理. 本文先介绍一下RocketMQ的部署...
-
RocketMQ源码阅读(四)-消息存储三
前文已经介绍了消息存储中使用到的充要对象, 本文分析一下消息介绍的主流程. 另外, 此篇主要分析消息存储主流程的代码, 不影响主流程的代码先不看...
-
RocketMQ源码阅读(四)-消息存储二
RocketMQ的消息存储过程非常复杂, 本文先介绍存储模块中几个重要对象. 1. MappedFile 对MappedByteBuffer的封...
-
RocketMQ源码阅读附一TopicQueue的划分RocketMQ存储Topic消息时会按照TopicQueue进行划分. 如下图 首先按照BrokerName划分到不同的master上(每一个...
-
RocketMQ源码阅读(二)-通信模块简介 在使用了消息队列的通信方之间, 总体的通信架构图如下: 在消息生产者, broker和消息消费者之间都会发生通信, RocketMQ的通信...
-
RocketMQ源码阅读(四)-消息存储前言 接下来会介绍RocketMQ的消息存储, 本文先对RocketMQ的整体设计和组件进行简单介绍,后续会针对细节进行源代码的分析. 目前MQ...
-
RocketMQ源码阅读(三)-NameServer
概述 如RocketMQ源码阅读(二)中所述, RocketMQ的总体架构如下: RocketMQ将注册中心单独提取出来封装成了一个可以单独部署...
-
RocketMQ源码阅读(一)-调试环境搭建最近想深入学习一下消息队列, 本来想看kafka的源码, 但由于kafka是scala写的,本人又不懂kafaka,最终选择了阿里的Rocket...
{var%20f='http://v.t.sina.com.cn/share/share.php?appkey=1881139527',u=z||d.location,p=['&url=',e(u),'&title=',e(t||d.title),'&source=',e(r),'&sourceUrl=',e(l),'&content=',c||'gb2312','&pic=',e(p||'')].join('');function%20a(){if(!window.open([f,p].join(''),'mb',['toolbar=0,status=0,resizable=1,width=440,height=430,left=',(s.width-440)/2,',top=',(s.height-430)/2].join('')))u.href=[f,p].join('');};if(/Firefox/.test(navigator.userAgent))setTimeout(a,0);else%20a();})(screen,document,encodeURIComponent,'','','https://upload.jianshu.io/collections/images/560451/174037biyowmz9zorr3mix.jpg', '推荐专题《RocketMQ》（ 分享自 @简书 ）','https://jianshuapi.com/c/1603a79f398e?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','页面编码gb2312|utf-8默认gb2312'));){kind=link}