
IP属地:广东
几个基本概念先说下消息的消费有两种模式:集群模式和广播模式集群模式,一条消息只允许被一个消费者消费。广播模式,一条消息会发送给所有订阅该topi...
RocketMQ存储的文件主要包括Comitlog 文件、 ConsumeQueue 文件、 IndexFile 文件。 CommitLog :...
消息发送的主要步骤为:验证消息,查找路由,消息发送(包含异常机制处理) 我们以DefaultMQProducer#send为切入口: 以下代码为...
RocketMQ 支持 3 种消息发送方式 :同 步(sync )、异步(async)、单向(oneway )。这些大家应该都比较了解了,我们从...
namesrv,相当于RocketMQ的服务注册中心(路由发现),大家通过结构图就可以看的明白: 我们先从启动类NamesrvStartup说起...
首先,你得有源码,这个网上都可以找到,各个版本大差不差;但是由于RocketMQ并入了Apache基金会,所以没了中文注释,看起来会有些费劲。 ...
结论先放前面:“进程是资源分配的最小单位,线程是CPU调度的最小单位” 首先,我们要知道,CPU是有单核和多核的区分。同一时间段,一个核只能运行...