展开全部

主编推荐语

RocketMQ社区早期的布道者和技术专家撰写,RocketMQ创始人高度评价并作序,深度分析各功能模块源码架构与实现原理。

内容简介

源码角度,本书对RocketMQ的核心技术架构,以及消息发送、消息存储、消息消费、消息过滤、顺序消息、主从同步(HA)、事务消息等主要功能模块的实现原理进行了深入分析,同时展示了源码阅读的相关技巧;应用层面,本书总结了大量RocketMQ的使用技巧。通过本书,读者将深入理解消息中间件和底层网络通讯机制的核心知识点。

目录

  • 版权信息
  • 推荐序
  • 前言
  • 第1章 阅读源代码前的准备
  • 1.1 获取和调试RocketMQ的源代码
  • 1.1.1 Eclipse获取RocketMQ源码
  • 1.1.2 Eclipse调试RocketMQ源码
  • 1.1.3 IntelliJ IDEA获取RocketMQ源码
  • 1.1.4 IntelliJ IDEA调试RocketMQ源码
  • 1.2 RocketMQ源代码的目录结构
  • 1.3 RocketMQ的设计理念和目标
  • 1.3.1 设计理念
  • 1.3.2 设计目标
  • 第2章 RocketMQ路由中心NameServer
  • 2.1 NameServer架构设计
  • 2.2 NameServer启动流程
  • 2.3 NameServer路由注册、故障剔除
  • 2.3.1 路由元信息
  • 2.3.2 路由注册
  • 2.3.3 路由删除
  • 2.3.4 路由发现
  • 2.4 本章小结
  • 第3章 RocketMQ消息发送
  • 3.1 漫谈RocketMQ消息发送
  • 3.2 认识RocketMQ消息
  • 3.3 生产者启动流程
  • 3.3.1 初识DefaultMQProducer消息发送者
  • 3.3.2 消息生产者启动流程
  • 3.4 消息发送基本流程
  • 3.4.1 消息长度验证
  • 3.4.2 查找主题路由信息
  • 3.4.3 选择消息队列
  • 3.4.4 消息发送
  • 3.5 批量消息发送
  • 3.6 本章小结
  • 第4章 RocketMQ消息存储
  • 4.1 存储概要设计
  • 4.2 初识消息存储
  • 4.3 消息发送存储流程
  • 4.4 存储文件组织与内存映射
  • 4.4.1 MappedFileQueue映射文件队列
  • 4.4.2 MappedFile内存映射文件
  • 4.4.3 TransientStorePool
  • 4.5 RocketMQ存储文件
  • 4.5.1 Commitlog文件
  • 4.5.2 ConsumeQueue文件
  • 4.5.3 Index索引文件
  • 4.5.4 checkpoint文件
  • 4.6 实时更新消息消费队列与索引文件
  • 4.6.1 根据消息更新ConumeQueue
  • 4.6.2 根据消息更新Index索引文件
  • 4.7 消息队列与索引文件恢复
  • 4.7.1 Broker正常停止文件恢复
  • 4.7.2 Broker异常停止文件恢复
  • 4.8 文件刷盘机制
  • 4.8.1 Broker同步刷盘
  • 4.8.2 Broker异步刷盘
  • 4.9 过期文件删除机制
  • 4.10 本章小结
  • 第5章 RocketMQ消息消费
  • 5.1 RocketMQ消息消费概述
  • 5.2 消息消费者初探
  • 5.3 消费者启动流程
  • 5.4 消息拉取
  • 5.4.1 PullMessageService实现机制
  • 5.4.2 ProcessQueue实现机制
  • 5.4.3 消息拉取基本流程
  • 5.5 消息队列负载与重新分布机制
  • 5.6 消息消费过程
  • 5.6.1 消息消费
  • 5.6.2 消息确认(ACK)
  • 5.6.3 消费进度管理
  • 5.7 定时消息机制
  • 5.7.1 load方法
  • 5.7.2 start方法
  • 5.7.3 定时调度逻辑
  • 5.8 消息过滤机制
  • 5.9 顺序消息
  • 5.9.1 消息队列负载
  • 5.9.2 消息拉取
  • 5.9.3 消息消费
  • 5.9.4 消息队列锁实现
  • 5.10 本章小结
  • 第6章 消息过滤FilterServer
  • 6.1 ClassFilter运行机制
  • 6.2 FilterServer注册剖析
  • 6.3 类过滤模式订阅机制
  • 6.4 消息拉取
  • 6.5 本章小结
  • 第7章 RocketMQ主从同步(HA)机制
  • 7.1 RocketMQ主从复制原理
  • 7.1.1 HAService整体工作机制
  • 7.1.2 AcceptSocketService实现原理
  • 7.1.3 GroupTransferService实现原理
  • 7.1.4 HAClient实现原理
  • 7.1.5 HAConnection实现原理
  • 7.2 RocketMQ读写分离机制
  • 7.3 本章小结
  • 第8章 RocketMQ事务消息
  • 8.1 事务消息实现思想
  • 8.2 事务消息发送流程
  • 8.3 提交或回滚事务
  • 8.4 事务消息回查事务状态
  • 8.5 本章小结
  • 第9章 RocketMQ实战
  • 9.1 消息批量发送
  • 9.2 消息发送队列自选择
  • 9.3 消息过滤
  • 9.3.1 TAG模式过滤
  • 9.3.2 SQL表达模式过滤
  • 9.3.3 类过滤模式
  • 9.4 事务消息
  • 9.5 Spring整合RocketMQ
  • 9.6 Spring Cloud整合RocketMQ
  • 9.7 RocketMQ监控与运维命令
  • 9.7.1 RocktetMQ监控平台搭建
  • 9.7.2 RocketMQ管理命令
  • 9.8 应用场景分析
  • 9.9 本章小结
  • 附录A 参数说明
展开全部

评分及书评

评分不足
2个评分
  • 用户头像
    给这本书评了
    1.0

    只能按照目录自己去探索,鄙视一切喜欢大段粘贴代码的作者。

      转发
      评论

    出版方

    机械工业出版社有限公司

    机械工业出版社是全国优秀出版社,自1952年成立以来,坚持为科技、为教育服务,以向行业、向学校提供优质、权威的精神产品为宗旨,以“服务社会和人民群众需求,传播社会主义先进文化”为己任,产业结构不断完善,已由传统的图书出版向着图书、期刊、电子出版物、音像制品、电子商务一体化延伸,现已发展为多领域、多学科的大型综合性出版社,涉及机械、电工电子、汽车、计算机、经济管理、建筑、ELT、科普以及教材、教辅等领域。