本文将从四个部分(namesrv、broker、producer和consumer)来解释rocketmq源代码，它们之间的关系可以在rocketmq 架构图中看到 。RocketMq-rebalance介绍RocketMq的概念，rocketMqnamesrv介绍rocketMqTopic的创建过程 ， rocketMqproducer介绍rocketMqconsumer介绍rocketMqrebalance介绍rocketMq的并发消费过程 ， rocketMq串行消费过程ro ， CketMqbroker介绍rocketMqbroker消息存储介绍rocketMqcommitLogrocketMqindex介绍rocketMq延迟消息介绍rocketMq事务消息介绍rocketMq消息查询rocketMq和kafka的架构rocket MQ主/从同步的区别本章主要解释再平衡在消费端的作用，如果你想理解消费者的逻辑 ， 你必须知道在消费者方面有一种重新平衡的服务 ， 没有重新平衡，就不会有来自消费者的信息拉动 。
1、RocketMQ千锤百炼哈啰在分布式消息治理和微服务治理中的实践【rocketmq架构设计分析】简介:随着公司业务的不断发展，流量也在不断增加 。我们发现生产中的一些重大事故往往是被突发的流量冲刷过去的，因此对流量的控制和保护，保证系统的高可用性就显得尤为重要 。Hello已经发展成为一个综合性的移动出行平台 ， 包括两轮出行(Hellobike、Hello助力车、Hello电动车、小哈换电)和四轮出行(Hello搭便车、全网叫车、Hello打车)，并探索了酒店、店铺等多个本地生活生态 。
我们发现生产中的一些重大事故往往是被突发的流量冲刷过去的，因此对流量的控制和保护 ， 保证系统的高可用性就显得尤为重要 。在本文中，我们将分享Hello在消息流量和微服务调用的治理上踩过的经验 。《RocketMQ实战与进阶》专栏作者之一梁勇(老梁) ， 参与了《RocketMQ技术内幕》稿件的审稿工作 。ArchSummit Global 架构师范大学讲师，QCon案例研究学会讲师 。
2、RocketMQ系列之特性以及常见api的使用消息发布是指一个生产者向一个主题发送消息；消息订阅是指一个消费者关注某个话题中带有某些标签的消息，然后从该话题中消费数据 。消息发送后进入同步等待状态，可以保证消息传递到达 。可靠的同步消息传输可用于重要通知消息、短信通知、短信营销系统等广泛场景 。异步传输通常用于对响应时间敏感的业务场景 。
只发送消息，不等待服务器响应，只发送请求，不等待应答 。以这种方式发送消息的过程需要非常短的时间，通常在微秒级 。单向消息适用于需要中等可靠性的场景，如日志收集 。多条消息可以打包一起发送，减少了网络传输次数，提高了效率 。producer . send(collection oc)方法可以接收一个集合，实现批量发送 。批量发送邮件的复杂性只会在发送大量邮件时增加，并且您可能无法确定邮件是否超过大小限制(1mb) 。
3、RocketMQ如何动态扩容和缩容上一篇文章RocketMQ如何解决分布式事务推荐阅读 。
推荐阅读
- 软件测试与分析报告
- 回归分析拟合效果,spss回归分析显示完美拟合
- 仿真结果分析lm386,proteus仿真结果分析
- 协方差分析 proc mixed
- 商城需要统计的数据分析,通过汇总统计、调查登记和数据分析
- 谷歌分析使用的设备标示
- 分析像素值工具,matlab像素值查看工具
- fluent流体分析软件,ansys 流体分析软件
- 语法分析的基本手续