dawnchen71189

实际工作中我们还是得用spring来进行开发，所以这篇文章旨在告诉大家spring boot和RocketMQ的整合...

RocketMQ的研发团队为了帮我们用好它，煞费苦心地在example包内直接写了几十demo。这些demo十分具有价值，几乎可以涵盖所有RocketMQ应用场景！下面我们...

一、开篇词 源码如天书，强行阅读收益极低。 自己动手实现功能，对标头部开源项目，可快速理解实现原理，事半功倍。 二、实现简图 三、实现细节图 四、实现成果 注册中心收到了客...

作为程序员，面对日新月异的技术，我们必须不断的坚持学习来拓展知识面，加深技术理解，提高自身竞争力。但是技术相关的书籍浩如烟海，如何选择成为摆在我们眼前的问题？今天我从编程语...

以下是 ElasticSearch 面试题，相信大家都会有种及眼熟又陌生的感觉、看过可能在短暂的面试后又马上忘记了。JavaPub在这里整理这些容易忘记的重点知识及解答，建...

普通岗位的背景调查证明人通常是直属Leader，高管职位是直属Leader和HR。有的大公司严谨一些，高管职位还会多加一个平级同事。调查的范围通常是以近1~2份的工作履历为...

背景 可以在以下场景使用单体服务部署 私有化部署场景，客户只有一台服务器，却需要消息队列进行业务处理 运维人力有限，分布式集群无力维护 测试环境中只需单个Broker节点满...

事务消息原理 源码位置 我们可以通过阅读这个类的代码熟悉事务消息的原理 org.apache.rocketmq.example.transaction.Transactio...

前置知识 消息的索引ConsumeQueue 要了解消费的过程，我们必须先了解下消息的RocketMQ消息的索引ConsumeQueue 一条ConsumeQueue由20...

源码位置 启动的代码是这个方法org.apache.rocketmq.namesrv.NamesrvStartup#main0 启动的方式和Producer十分类似 清理掉...

代码位置定位 先让我们找到类org.apache.rocketmq.broker.BrokerStartup 该类的main方法通过调用BrokerController的s...

代码位置定位 首先让我回到投递消息的那一个地方 一直对send方法点击ctrl+鼠标，直到找到方法sendDefaultImpl 我们可以看到方法 MessageQueue...

send代码解析 我们进入send函数一看究竟 给topic追加上命名空间，然后调用默认的生产者实现类中的send方法 RocketMQ源码大量使用重载，本次重载追加上了默...

源码位置 org.apache.rocketmq.example.simple.Producer 可以从下图位置进入Message类 从下图可以看到Message的结构很简...

普通消息 分为以下5步： 初始化：生产者构建消息，并投递到Broker 待消费：等待消费者消费 消费中：消息已进行消费，等待消费结果的响应 消费者提交：消费已完成，进行结果...