深入解析Apache Pulsar

"1. 适用范围广 本书对Pulsar的每个功能点都先做简介与使用说明，然后进行原理级别的剖析，因此适用范围较广。对于不想深入理解Pulsar内部原理，只想先了解并使用Pulsar的读者，可以阅读前面的章节以快速了解Pulsar。如果读者后续需要对Pulsar进行二次开发，或者想深入了解源码，则可以阅读后面的原理章节。在对流程、实现思路有了了解之后，阅读源码的门槛就会低得多。 2. 代码量少 本书中基本没有大段的代码，书中的源码也非常简短。本书主要以图和文字的方式对概念和原理进行描述，力求让读者快速理解Pulsar。"

本书由浅入深地讲解了Apache Pulsar中各个组件的使用方式及内部实现原理，通过阅读本书，读者可以快速、轻松地了解Apache Pulsar内部的运行机制。第1章介绍Apache Pulsar的背景，以及如何快速部署一个Apache Pulsar服务。第2章介绍Apache Pulsar客户端的实现机制与原理，包括生产者、消费者、管理流客户端等。第3章介绍Apache Pulsar中最重要的逻辑组件——Broker，读者通过这部分内容可以了解Broker所有的特性。除了最基础的收发消息，Apache Pulsar还能进行轻量级的函数计算、数据流转。第4章详细介绍Apache Pulsar的Function和Pulsar IO（Connector）。第5章介绍Apache Pulsar的存储层——BookKeeper，通过本章的学习，读者可以了解Apache Pulsar的数据存储模型及流程实现。第6章介绍线上实战的一些经验，包括高可用、扩/缩容、资源隔离等。

林琳，腾讯专家工程师，Apache Pulsar Committer & PMC，著有《深入理解Apache Dubbo原理与实战》，先后就职于蚂蚁金服、腾讯等公司。开源与中间件爱好者，常年混迹在开源社区，喜欢研究各种中间件的源码与设计思想，专注于中间件领域，在消息队列、微服务等方面有丰富的经验，致力于打造稳定、高效、可扩展的底层基础组件或服务。

第1章 认识Pulsar
1.1 Pulsar的背景
1.2 Pulsar总体介绍
1.3 第一个Pulsar程序
1.3.1 环境的准备
1.3.2 下载Pulsar
1.3.3 Pulsar的目录结构
1.3.4 部署Pulsar
1.4 小结
第2章 客户端
2.1 名词介绍
2.2 Topic
2.2.1 Topic简介
2.2.2 Topic的创建与删除
2.2.3 Topic的归属
2.2.4 Topic的迁移
2.2.5 可压缩Topic
2.3 Pulsar客户端
2.3.1 不同的客户端
2.3.2 创建管理流客户端的流程
2.3.3 创建数据流客户端的流程
2.4 生产者客户端
2.4.1 生产者客户端简介
2.4.2 生产者原理解析
2.5 消费者客户端
2.5.1 消费者客户端简介
2.5.2 创建ConsumerImpl
2.5.3 接收消息
2.5.4 确认消息
2.5.5 MultiTopicsConsumerImpl
2.5.6 ZeroQueueConsumerImpl
2.5.7 PatternMultiTopicsConsumerImpl
2.5.8 Consumer的其他接口
2.6 Reader
2.6.1 创建ReaderImpl
2.6.2 Reader的实现原理
2.7 客户端其他能力
2.7.1 连接管理与线程池管理
2.7.2 LookupService
2.7.3 MemoryLimitController
2.8 小结
第3章 Broker
3.1 Broker简介
3.1.1 Broker的启动流程
3.1.2 Broker的生产消费流程
3.2 Schema
3.2.1 Schema简介
3.2.2 Schema的类型
3.2.3 Schema的管理
3.2.4 Schema的版本与兼容性
3.2.5 Schema的实现
3.3 安全机制
3.3.1 认证授权简介
3.3.2 认证授权框架
3.3.3 默认的认证插件
3.3.4 端到端加密
3.4 配置与策略
3.4.1 配置的加载
3.4.2 动态配置的实现
3.4.3 Namespace策略
3.4.4 Topic策略
3.4.5 策略的实现
3.5 元数据管理
3.5.1 元数据简介
3.5.2 元数据的缓存
3.5.3 元数据的线程安全
3.5.4 Session检测
3.6 存储管理
3.6.1 存储模型
3.6.2 存储流程
3.6.3 游标
3.6.4 消息回溯的实现
3.6.5 数据的清理
3.6.6 BacklogSize与StorageSize
3.7 分层存储
3.7.1 分层存储的使用
3.7.2 数据的卸载与加载
3.8 扩展点
3.8.1 扩展点简介
3.8.2 ProtocolHandler扩展点
3.8.3 BrokerInterceptor
3.8.4 其他扩展点
3.9 负载管理
3.9.1 负载管理简介
3.9.2 负载的上报
3.9.3 负载策略
3.9.4 Bundle的自动分裂
3.9.5 Leader选举与Broker分配
3.10 管理流服务
3.10.1 管理流服务简介
3.10.2 REST接口的重定向
3.10.3 WebSocket
3.11 消息去重
3.12 事务消息
3.12.1 事务简介
3.12.2 事务流程
3.12.3 事务的实现
3.13 Dispatcher
3.13.1 Dispatcher流程
3.13.2 Dispatcher的实现原理
3.14 小结
第4章 Function与Pulsar IO
4.1 Function简介
4.2 Function的使用
4.3 Function的架构
4.4 Function的实现原理
4.4.1 服务的启动
4.4.2 LeaderService的实现
4.4.3 MembershipManager与SchedulerManager的实现
4.4.4 FunctionAssignmentTailer的实现
4.4.5 FunctionMetaDataManager的实现
4.4.6 FunctionRuntimeManager的实现
4.5 Runtime的实现
4.5.1 ThreadRuntime的实现
4.5.2 ProcessRuntime的实现
4.5.3 KubernetesRuntime的实现
4.6 Pulsar IO简介
4.7 部署Connector
4.8 开发Connector
4.9 Pulsar IO的实现
4.10 小结
第5章 BookKeeper存储
5.1 项目结构
5.2 存储简介
5.3 数据写入的实现
5.4 数据读取的实现
5.5 自愈能力
5.6 小结
第6章 实战Pulsar
6.1 高可用
6.1.1 跨区域感知
6.1.2 跨地域复制
6.1.3 跨地域复制的使用
6.1.4 跨地域复制的实现
6.2 扩/缩容
6.3 资源隔离
6.3.1 资源隔离的使用
6.3.2 资源隔离的实现
6.4 小结