Avatar notebook default
RocketMQ
11篇文章 · 9150字 · 4人关注
  • RocketMQ 同步刷盘实现原理

    未写完，待续。。。。 刷盘服务类有三种 同步刷盘时使用 GroupCommitService 异步刷盘时使用 FlushRealTimeServ...

    1721 0 0
  • RocketMQ MappedFile 预热原理解析

    创建 MappedFile 文件 创建 MappedFile 文件实现如下： 从代码中可以看出，只有 MappedFile 的大小等于或大于 C...

    1.2 2160 1 8
  • RocketMQ 延迟消息

    概述 RocketMQ 支持发送延迟消息，但不支持任意时间的延迟消息的设置，仅支持内置预设值的延迟时间间隔的延迟消息。 预设值的延迟时间间隔为：...

    0.6 3906 0 8
  • Resize,w 360,h 240
    RocketMQ CommitLog 文件规则

    1、CommitLog 文件生成规则 偏移量：每个 CommitLog 文件的大小为 1G，一般情况下第一个 CommitLog 的起始偏移量为...

    5552 0 1
  • RocketMQ 存储机制源码解析

    producer 发送消息后，broker端开始存储消息，会调用 store 模块的 DefaultMessageStore.putMessag...

    0.4 2008 0 6
  • RocketMQ 生产者 Producer 发送消息三种方式分析

    概述 Producer 发送消息，RocketMQ 提供了三种模式。 同步发送 异步发送 OneWay 发送 示例代码如下： 1、同步发送Pro...

    0.6 8729 2 8
  • Resize,w 360,h 240
    RocketMQ 生产者 Producer 启动过程

    MQProducer 从类关系中可以看出，MQProducer 有两种实现方式。一个是 DefaultMQProducer，另一个是 Trans...

    0.3 7562 0 5
  • RocketMQ 生产者 rebalence 原理

    概述 生产者 producer 在发送消息的时候，每个消息发送到 broker 只存储在某一个 quene 上。那么 producer 是怎么选...

    1435 0 0
  • Resize,w 360,h 240
    RocketMQ 命令行工具源码结构解析

    概述 RocketMQ 提供有控制台及一系列控制台命令，用于管理员对主题，集群，broker 等信息的管理； 进入 RocketMQ 的bin ...

    1620 0 3

文集作者