在系统中肯定是做命名服务，服务治理方面的工作，功能应该是和zookeeper差不多早期的版本中，使用的是 Zookeeper 做为配置中心，改名 RocketMQ 后使用了自己开发的 NameServer。是一个几乎无状态的节点，可集群部署，节点之间无...

作用：消息中转角色。负责存储消息，转发消息。一般也称为Server。在JMS规范中称为: Provider。

消息存储是RocketMQ中最为复杂和最为重要的一部分，将分别从RocketMQ的消息存储整体架构、PageCache与Mmap内存映射以及RocketMQ中两种不同的刷盘方式三方面来分别展开叙述。...

当出现 RocketMQ 消费者对某条消息重复消费的情况时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生任何负面影响，那么这个消费者的处理过程就是幂等的。...

下载地址： https://github.com/apache/rocketmq-dashboard

RocketMq作为一款纯java、分布式、队列模型的开源消息中间件，支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。

RocketMQ主要有四大核心组成部分：NameServer、Broker、Producer以及Consumer四部分。

路由管理： Producer和Conumser通过NameServer可以获取整个Broker集群的路由信息

org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java

这里所说的Table都是存储在内存中的Table,数据结构都是Map。由于比较多，这里记录一下。通常这些信息有一部分是存储在nameServer中，同时可以看到这些信息在Rocketmq中具备其作用，因此这里整理了一下。...