几个基本概念先说下消息的消费有两种模式:集群模式和广播模式集群模式,一条消息只允许被一个消费者消费。广播模式,一条...[作者空间]
RocketMQ存储的文件主要包括Comitlog 文件、 ConsumeQueue 文件、 IndexFile ...[作者空间]
消息发送的主要步骤为:验证消息,查找路由,消息发送(包含异常机制处理) 我们以DefaultMQProducer#...[作者空间]
RocketMQ 支持 3 种消息发送方式 :同 步(sync )、异步(async)、单向(oneway )。这...[作者空间]
namesrv,相当于RocketMQ的服务注册中心(路由发现),大家通过结构图就可以看的明白: 我们先从启动类N...[作者空间]
首先,你得有源码,这个网上都可以找到,各个版本大差不差;但是由于RocketMQ并入了Apache基金会,所以没了...[作者空间]