CloudNativeEra
  • Introduction
  • 名词解释
  • Computer Science
    • Computer Organization
      • CPU
      • 二进制、电路、加法器、乘法器
      • 编译、链接、装载
      • 存储器
      • IO
    • Operating System
      • 操作系统基础知识
      • 系统初始化
      • 进程管理
      • Everything about Memory
      • 文件系统
      • 并行编程
      • Linux
        • CPU
        • IO 多路复用
        • DMA IO and Linux Zero Copy
    • Computer Network
      • 网络相关命令
      • 评估系统的网络性能
      • 网络抓包
      • Linux 最多支撑的 TCP 连接
      • 网络虚拟化
      • DHCP 工作原理
    • Data Structure and Algorithm
      • 题目列表
      • Summarize
        • 方法总结
        • 二分思想
        • 树的演化
        • 算法思想总结
      • Data Structure
        • Data Struct - Array
        • Tree
        • Heap
        • Hash
        • 字符串
      • Algorithm
        • Sorting Algorithm
        • 查找
        • 贪心算法
        • 动态规划
        • 位运算
      • Practice Topics
        • Data Struct in SDK
        • Topic - Tree
        • Topic - Graph
        • Topic - 滑动窗口
        • 剑指 Offer 题解
    • 并发编程
      • 并发模式
      • 并发模型
  • 系统设计
    • 软件设计
      • 软件架构
      • 编程范式
      • 系统设计题
      • 设计原则
      • 计算机程序的构造和解释 SICP
    • 领域驱动设计
      • 应用:在线请假考勤管理
      • 应用: library
    • 微服务与云原生
      • Designing and deploying microservices
      • 容器技术
      • Docker
      • Etcd
      • Kubernetes
        • Kubernetes - Mapping External Services
      • Istio
      • 监控
    • 分布式系统
      • 分布式理论
      • 分布式事务
    • 后端存储设计
      • 缓存设计
      • 数据库架构设计
    • CI/CD
    • 设计最佳实践
    • 测试
    • 安全
    • 综合
      • 开发实践
      • 分布式锁
      • 分布式计数服务
      • 弹幕系统设计
      • 消息队列设计
      • 分布式ID生成算法
      • 限流设计
      • 网关设计
      • 通用的幂等设计
      • 分布式任务调度
        • Timer
        • ScheduledExecutorService
        • Spring Task
        • Quartz
      • 交易系统
      • 权限设计
  • 编程语言
    • 编程语言
    • C & C++
    • Java
      • JVM
        • JVM Bytecode
      • Java 核心技术
      • Java 8 新特性
      • Java 集合框架
      • Java NIO
      • 并发编程
        • 线程生命周期与线程中断
        • 三个线程交替打印
        • 两个线程交替打印奇偶
        • 优雅终止线程
        • 等待通知机制
        • 万能钥匙:管程
        • 限流器
        • 无锁方案 CAS
    • Java 源码阅读
      • Unsafe
      • 异步计算 Future
      • Java Queue
      • CoalescingRingBuffer 分析
      • Java Collections
        • PriorityQueue 分析
        • HashMap 分析
        • TreeMap
    • Golang
    • Python
  • 框架/组件/类库
    • Guava
      • Guava Cache
      • Guava EventBus
    • RxJava
    • Apache MINA
    • Netty
      • 网络 IO 模型
      • Netty 生产问题
    • Apache Tomcat
    • MyBatis
    • 限流框架
    • Spring Framework
      • Spring Core
      • Spring 事务管理
    • Spring Boot
    • Spring Cloud
      • Feign & OpenFeign
      • Ribbon
      • Eurake
      • Spring Cloud Config
    • FixJ
    • Metrics
    • Vert.x
  • 中间件
    • Redis
      • Redis 基础
        • Redis 数据结构设计与实现
        • Redis 高性能网络模型
      • Redis checklist
      • 应用案例 - Redis 数据结构
      • 应用案例 - Redis 缓存应用
      • 应用案例 - Redis 集群
      • Redis 客户端
      • Redis 生产案例
        • [译] 在 Redis 中存储数亿个简单键值对
    • MySQL
      • MySQL 基础
      • MySQL Index
      • MySQL Transaction
      • MySQL 优化
      • MySQL 内核
      • MySQL Command
      • MySQL Checklist
      • MySQL Analysis Tool
      • 实现 MySQL
    • State Machine
    • 数据库连接池
    • MQ
      • 高性能内存队列 Disruptor
      • Kafka
      • Pulsar
      • RocketMQ
        • Broker 的设计与实现
      • NSQ
  • 实际案例
    • 线上 Case
      • Request Aborted
      • MySQL - Specified key was too long
      • Java 应用 CPU 100% 排查优化
      • 频繁 GC 导致的 Java 服务不响应
      • 导出优化
  • 大数据
    • 流计算
    • Flink
  • 其他
    • 工具
    • 读书
      • 设计数据密集型应用
      • 实现领域驱动设计
      • 精通比特币
      • 提问的智慧
    • 论文
    • 工程博客
    • 阅读源码
    • 面试
      • 如何在最短的时间里对对方有个全面的了解
    • 分享
    • 软技能
    • Todo
  • Blog
    • #算法
      • 查找
      • 位运算
      • 树
    • #架构
      • 1- 通信
    • Design & Dev & Opt
      • High Performance Data structure Design
  • Tiny Project
    • A Simple WeChat-like Instant Messaging Platform
由 GitBook 提供支持
在本页

这有帮助吗?

  1. 中间件
  2. MQ
  3. RocketMQ

Broker 的设计与实现

Broker 是 RocketMQ 的核心服务,它负责消息存储、消息转发、消息过滤、缓存消费者的消费进度等,可见它是连接消息生产者和消费者的核心组件,也是实现异步、解耦合、削峰填谷、数据缓冲等的重要基础。而针对 Broker,它有自己的核心职责要完成:

  1. 为了实现服务自动发现,Broker 需要有服务注册的能力,这个就是 Broker 与 Namesrv 配合的地方

  2. 消费者发送消息给 Broker,Broker 需要具备高性能的网络 IO,高吞吐的消息接收能力,处理消息要低延迟,支持各种场景下的消息发送功能:同步消息发送、异步消息发送、批量消息发送等

  3. Broker 收到消息后要能管理好消息,并路由转发给需要它的消费者(为了降低 Broker 的实现复杂度,都是采取消费者拉取消息的模式),这个是 Broker 最基本最核心的功能

  4. 为了 Broker 具备 HA 的能力,需要做 M-S 同步,或者 Broker 集群,在遇到故障时可以做故障切换,以免因为 Broker 不可恢复的故障导致消息丢失

  5. 消费者可以向 Broker 订阅某个 Topic 下的消息,一般都是以消费者组的方式进行订阅,然后使用负载均衡算法来分配具体的 MessageQueue 给到特定的消费者消费,这里也有很多需要注意的地方

针对 Broker 的权衡设计和实现,RocketMQ 的团队做了很多的努力和优化,从两个层面来分析一下 Broker:

  1. 从外层看 Broker,它提供了消息接收的 API、消息订阅的 API、Broker 的 HA 保证、Topic 的 MessageQueue 的分配在多个 Broker,提供了水平扩展的能力

  2. 从内部看 Broker,对于消息的存储统一抽象了内部的 MessageStore API,对于 API 协议的网络交互统一抽象了内部的基于 Netty 的 Remoting Service 和 Client,对于消息的快速查询抽象了索引服务 Index API,对于消息的过滤提供了 Filter API 等等;而这些内部实现,很多都基于底层的 OS 的特性做了优化,非常值得一探究竟

内外结合来分析 Broker,弄懂它实现的原理是基本目标。

首先我们要明白 MQ 的一个重要理论基础:日志,就像 The Log: What every software engineer should know about real-time data's unifying abstraction 里说的日志所能表现出来的诸多能力;

消息存储设计

RocketMQ Broker 的消息存储设计采取了当前 Broker 上的所有 MessageQueue 共享同一个 CommitLog 的方式,这里的 CommitLog 就是被接收的消息的日志,按照时间顺序的存放在文件中,在使用消息的时候也可以顺序的取出

Producer 发送一条消息时指定了 broker、topic、queueId 以及 Message 本身

MessageStore 抽象的接口可以分为四类

  • Store 管理类接口:start, shutdown, destroy, load, getBrokerStatusManager, isOSPageCacheBusy

  • Store 写接口:putMessage, asyncPutMessage, flush, appendToCommitLog

  • Store 查询类接口:getMessage, lookMessageByOffset, selectOneMessageByOffset,queryMessage

  • Store 计数类接口:getMessageTotalInTopic, getEarliestTimestamp

上一页RocketMQ下一页NSQ

最后更新于4年前

这有帮助吗?