消费者从Broker中获取消息的方式有两种:pull拉取方式和push推动方式。消费者组对于消息消费的模式又分为两种:集群消费Clusterin...
除了通过通常的指定Topic进行消息消费外,rocketMQ还提供了根据Key进行查询的功能。该查询是通过store目录中的index子目录中的...
RocketMQ中的消息存储在本地文件系统中,这些相关文件默认在当前用户主目录下的store目录中。 abort:该文件在Broker启动后会自...
1.消息的生产过程 Producer可以将消息写入到某Broker中的某Queue中,经历的如下过程: Producer发送消息之前,会先向Na...
1.RAID历史 1988 年美国加州大学伯克利分校的 D. A. Patterson 教授等首次在论文 “A Case of Redundan...
1.数据复制与刷盘策略 复制策略复制策略是Broker得Master与Slave间得数据同步方式。分为同步复制与异步复制: 同步复制:消息写入m...
RocketMQ有一个可视化的的dashboard,通过该控制台可以直观的看到很多数据 1.下载 下载地址:https://github.com...
1.环境准备 2.下载 下载地址:https://rocketmq.apache.org/[https://rocketmq.apache.or...
RocketMQ架构上主要分为四部分构成: 1.Producer 消息生产者,负责生产消息。Producer通过MQ的负载均衡模块选择相应的Br...