RocketMQ技术内幕:RocketMQ架构设计与实现原理

RocketMQ技术内幕:RocketMQ架构设计与实现原理

暂无评价综合评分的显示会考虑用户真实性等多项因素,每部作品出现综合评分的时间不定。
春暖花开季 恰是读书时满500减300、满200减120、满100减60活动详情

作品简介

本书由RocketMQ社区早期的布道者和技术专家撰写,Apache RocketMQ创始人/Linux OpenMessaging创始人兼主席/Alibaba Messaging开源技术负责人冯嘉的高度评价并作序推荐。源码角度,本书对RocketMQ的核心技术架构,以及消息发送、消息存储、消息消费、消息过滤、顺序消息、主从同步(HA)、事务消息等主要功能模块的实现原理进行了深入分析,同时展示了源码阅读的相关技巧;应用层面,本书总结了大量RocketMQ的使用技巧。通过本书,读者将深入理解消息中间件和底层网络通讯机制的核心知识点。

丁威

Java、分布式服务架构、中间件等多个领域的技术专家,擅长高并发编程、Netty网络编程、RocketMQ等技术,国内知名开源数据库中间件MyCAT的志愿者和技术顾问。目前担任上海优速物流的技术专家和经营支撑部门的架构师。对RocketMQ有非常深入的研究,是RocketMQ社区的布道师,不仅实践经验丰富,而且对其源代码有深入且系统的研究。

周继锋

拥有10余年大型项目架构设计及实战经验,曾主导过众多分布式系统、微服务及大数据项目。在高并发、高可用、高可扩展性、高可维护性等领域有丰富经验,对Hadoop、Spark源码进行过深度分析并具有丰富的实战经验。曾在ERP、医学、互联网行业担任工程师、架构师、技术总监等职务,炼数成金高级讲师及国内知名的开源分布式数据库中间件Mycat负责人,也是《分布式数据库架构及企业实践:基于Mycat中间件》书籍的作者。

作品目录

  1. 推荐序
  2. 前言
  3. 第1章 阅读源代码前的准备
  4. 1.1 获取和调试RocketMQ的源代码
  5. 1.1.1 Eclipse获取RocketMQ源码
  6. 1.1.2 Eclipse调试RocketMQ源码
  7. 1.1.3 IntelliJ IDEA获取RocketMQ源码
  8. 1.1.4 IntelliJ IDEA调试RocketMQ源码
  9. 1.2 RocketMQ源代码的目录结构
  10. 1.3 RocketMQ的设计理念和目标
  11. 1.3.1 设计理念
  12. 1.3.2 设计目标
  13. 第2章 RocketMQ路由中心NameServer
  14. 2.1 NameServer架构设计
  15. 2.2 NameServer启动流程
  16. 2.3 NameServer路由注册、故障剔除
  17. 2.3.1 路由元信息
  18. 2.3.2 路由注册
  19. 2.3.3 路由删除
  20. 2.3.4 路由发现
  21. 2.4 本章小结
  22. 第3章 RocketMQ消息发送
  23. 3.1 漫谈RocketMQ消息发送
  24. 3.2 认识RocketMQ消息
  25. 3.3 生产者启动流程
  26. 3.3.1 初识DefaultMQProducer消息发送者
  27. 3.3.2 消息生产者启动流程
  28. 3.4 消息发送基本流程
  29. 3.4.1 消息长度验证
  30. 3.4.2 查找主题路由信息
  31. 3.4.3 选择消息队列
  32. 3.4.4 消息发送
  33. 3.5 批量消息发送
  34. 3.6 本章小结
  35. 第4章 RocketMQ消息存储
  36. 4.1 存储概要设计
  37. 4.2 初识消息存储
  38. 4.3 消息发送存储流程
  39. 4.4 存储文件组织与内存映射
  40. 4.4.1 MappedFileQueue映射文件队列
  41. 4.4.2 MappedFile内存映射文件
  42. 4.4.3 TransientStorePool
  43. 4.5 RocketMQ存储文件
  44. 4.5.1 Commitlog文件
  45. 4.5.2 ConsumeQueue文件
  46. 4.5.3 Index索引文件
  47. 4.5.4 checkpoint文件
  48. 4.6 实时更新消息消费队列与索引文件
  49. 4.6.1 根据消息更新ConumeQueue
  50. 4.6.2 根据消息更新Index索引文件
  51. 4.7 消息队列与索引文件恢复
  52. 4.7.1 Broker正常停止文件恢复
  53. 4.7.2 Broker异常停止文件恢复
  54. 4.8 文件刷盘机制
  55. 4.8.1 Broker同步刷盘
  56. 4.8.2 Broker异步刷盘
  57. 4.9 过期文件删除机制
  58. 4.10 本章小结
  59. 第5章 RocketMQ消息消费
  60. 5.1 RocketMQ消息消费概述
  61. 5.2 消息消费者初探
  62. 5.3 消费者启动流程
  63. 5.4 消息拉取
  64. 5.4.1 PullMessageService实现机制
  65. 5.4.2 ProcessQueue实现机制
  66. 5.4.3 消息拉取基本流程
  67. 5.5 消息队列负载与重新分布机制
  68. 5.6 消息消费过程
  69. 5.6.1 消息消费
  70. 5.6.2 消息确认(ACK)
  71. 5.6.3 消费进度管理
  72. 5.7 定时消息机制
  73. 5.7.1 load方法
  74. 5.7.2 start方法
  75. 5.7.3 定时调度逻辑
  76. 5.8 消息过滤机制
  77. 5.9 顺序消息
  78. 5.9.1 消息队列负载
  79. 5.9.2 消息拉取
  80. 5.9.3 消息消费
  81. 5.9.4 消息队列锁实现
  82. 5.10 本章小结
  83. 第6章 消息过滤FilterServer
  84. 6.1 ClassFilter运行机制
  85. 6.2 FilterServer注册剖析
  86. 6.3 类过滤模式订阅机制
  87. 6.4 消息拉取
  88. 6.5 本章小结
  89. 第7章 RocketMQ主从同步(HA)机制
  90. 7.1 RocketMQ主从复制原理
  91. 7.1.1 HAService整体工作机制
  92. 7.1.2 AcceptSocketService实现原理
  93. 7.1.3 GroupTransferService实现原理
  94. 7.1.4 HAClient实现原理
  95. 7.1.5 HAConnection实现原理
  96. 7.2 RocketMQ读写分离机制
  97. 7.3 本章小结
  98. 第8章 RocketMQ事务消息
  99. 8.1 事务消息实现思想
  100. 8.2 事务消息发送流程
  101. 8.3 提交或回滚事务
  102. 8.4 事务消息回查事务状态
  103. 8.5 本章小结
  104. 第9章 RocketMQ实战
  105. 9.1 消息批量发送
  106. 9.2 消息发送队列自选择
  107. 9.3 消息过滤
  108. 9.3.1 TAG模式过滤
  109. 9.3.2 SQL表达模式过滤
  110. 9.3.3 类过滤模式
  111. 9.4 事务消息
  112. 9.5 Spring整合RocketMQ
  113. 9.6 Spring Cloud整合RocketMQ
  114. 9.7 RocketMQ监控与运维命令
  115. 9.7.1 RocktetMQ监控平台搭建
  116. 9.7.2 RocketMQ管理命令
  117. 9.8 应用场景分析
  118. 9.9 本章小结
  119. 附录A 参数说明
载入中

大家都喜欢