240 发简信
IP属地:广东
  • Resize,w 360,h 240
    RocketMQ源码分析(六)消息的拉取

    几个基本概念先说下消息的消费有两种模式:集群模式和广播模式集群模式,一条消息只允许被一个消费者消费。广播模式,一条消息会发送给所有订阅该topi...

  • RocketMQ源码分析(五)消息的存储

    RocketMQ存储的文件主要包括Comitlog 文件、 ConsumeQueue 文件、 IndexFile 文件。 CommitLog :...

  • RocketMQ源码分析(四)消息的发送

    消息发送的主要步骤为:验证消息,查找路由,消息发送(包含异常机制处理) 我们以DefaultMQProducer#send为切入口: 以下代码为...

  • RocketMQ源码分析(三)生产者的启动

    RocketMQ 支持 3 种消息发送方式 :同 步(sync )、异步(async)、单向(oneway )。这些大家应该都比较了解了,我们从...

  • Resize,w 360,h 240
    RocketMQ源码分析(二)先从注册中心开始说起

    namesrv,相当于RocketMQ的服务注册中心(路由发现),大家通过结构图就可以看的明白: 我们先从启动类NamesrvStartup说起...

  • Resize,w 360,h 240
    RocketMQ源码分析(一)源码的各个模块

    首先,你得有源码,这个网上都可以找到,各个版本大差不差;但是由于RocketMQ并入了Apache基金会,所以没了中文注释,看起来会有些费劲。 ...

  • 【技术随笔】简单理解进程和线程

    结论先放前面:“进程是资源分配的最小单位,线程是CPU调度的最小单位” 首先,我们要知道,CPU是有单核和多核的区分。同一时间段,一个核只能运行...