全新正版ApachePulsar原理解析与应用实践9787111726081机械工业

前　言<br />基础篇<br />章　Pulsar概述　　2<br />1.1　Pulsar是什么　　2<br />1.2　Pulsar的优势　　3<br />1.2.1　Pulsar不只是消息队列　　4<br />1.2.2　存储与计算分离　　4<br />1..　云原生架构　　5<br />1.2.4　Pulsar的存储特　　6<br />1.2.5　消息传输协议　　8<br />1.2.6　消费方式　　8<br />1.2.7　丰富的功能与生态　　9<br />1.3　消息队列对比　　9<br />1.3.1　消息队列简介　　10<br />1.3.2　能与可靠　　11<br />1.3.3　功能特对比　　14<br />1.4　快速体验　　17<br />1.4.1　下载安装　　17<br />1.4.2　单机服务启动　　17<br />1.4.3　生产与消费　　18<br />第2章　Pulsar的基本概念和架构<br />详解　　20<br />2.1　Pulsar的基本概念　　20<br />2.1.1　多租户与命名空间　　20<br />2.1.2　主题　　21<br />2.1.3　生产者　　22<br />2.1.4　消费者与订阅　　24<br />2.1.5　消息的保留与过期　　27<br />2.2　Pulsar的逻辑架构　　28<br />2.2.1　主题的配置管理　　29<br />2.2.2　主题的数据流转　　30<br />2..　主题的数据存储　　31<br />.　Pulsar物理架构　　32<br />..1　物理架构概述　　32<br />..2　核心组件与服务　　35<br />第3章　Pulsar安装与部署　　39<br />3.1　依赖环境　　39<br />3.1.1　安装Java　　39<br />3.1.2　Pulsar安装包　　40<br />3.2　分布式部署　　42<br />3.2.1　资源分配规划　　42<br />3.2.2　集群搭建实战　　44<br />3.3　Docker部署　　47<br />3.3.1　Docker单机部署　　47<br />3.3.2　Docker分布式部署　　48<br />3.4　Kubernetes部署　　48<br />3.4.1　minikube环境安装　　48<br />3.4.2　Helm Chart安装　　49<br />3.4.3　在Kubernetes中使用<br />Pulsar　　51<br />3.5　源码的结构与编译　　52<br />3.5.1　源码结构　　52<br />3.5.2　源码编译　　52<br />第4章　Pulsar的基本操作　　54<br />4.1　生产者开发　　54<br />4.1.1　生产者概览　　54<br />4.1.2　构建客户端对象　　56<br />4.1.3　构建生产者　　58<br />4.1.4　数据发送路由规则　　60<br />4.1.5　分批发送　　63<br />4.1.6　分块发送　　64<br />4.1.7　生产者　　64<br />4.2　消费者开发　　65<br />4.2.1　构建消费者　　65<br />4.2.2　数据确认　　68<br />4..　消费者　　72<br />4.2.4　消费者监听器　　72<br />4.3　Reader开发　　73<br />4.4　模式管理　　74<br />4.4.1　模式类型　　75<br />4.4.2　自动模式　　78<br />4.4.3　模式管理　　79<br />原理篇<br />第5章　Pulsar核心组件原理　　84<br />5.1　Broker原理　　84<br />5.1.1　通信协议层　　84<br />5.1.2　主题查找服务　　89<br />5.1.3　租户与命名空间管理　　90<br />5.1.4　负载管理　　92<br />5.2　BookKeeper原理　　94<br />5.2.1　BookKeeper简介　　94<br />5.2.2　BookKeeper的使用　　100<br />5.3　ManagedLedger组件　　100<br />5.3.1　ManagedLedger简介　　101<br />5.3.2　消息积压的配额管理　　102<br />5.3.3　消息的保留与清理　　103<br />5.3.4　消息的写入　　104<br />5.3.5　消息的缓存与读取　　104<br />5.4　主题管理　　105<br />5.4.1　Pulsar主题管理架构　　106<br />5.4.2　生产者原理　　108<br />5.4.3　订阅与消费者原理　　110<br />5.4.4　消息生存时间与持久化<br />控制　　114<br />第6章　Pulsar高级特　　115<br />6.1　Pulsar事务　　115<br />6.1.1　消息队列事务隔离级别　　116<br />6.1.2　Pulsar事务简介　　117<br />6.1.3　Pulsar事务的使用方法　　118<br />6.1.4　Pulsar事务实现原理及关键<br />流程　　119<br />6.2　消息队列协议层　　122<br />6.2.1　协议处理器　　122<br />6.2.2　Pulsar上的Kafka简介　　125<br />6..　Pulsar上的Kafka使用　　126<br />6.2.4　Pulsar上的Kafka工作<br />原理　　128<br />6.3　分层存储　　130<br />6.3.1　分层存储的设计　　130<br />6.3.2　分层存储的使用　　131<br />6.3.3　分层存储的原理　　133<br />6.4　消息延迟传递　　133<br />6.5　主题压缩　　134<br />6.5.1　主题压缩应用　　135<br />6.5.2　主题压缩原理　　135<br />第7章　Pulsar Function与<br />Pulsar I/O　　137<br />7.1　Pulsar Function简介　　137<br />7.1.1　Pulsar Function编程模型　　137<br />7.1.2　Pulsar Function逻辑结构与<br />应用场景　　140<br />7.2　Pulsar Function应用实践　　141<br />7.2.1　Pulsar Function的部署与<br />使用　　141<br />7.2.2　自定义Pulsar Function<br />开发　　146<br />7..　Pulsar Function语义支持　　148<br />7.3　Pulsar Function原理　　150<br />7.3.1　Pulsar Function运行流程　　150<br />7.3.2　Function Worker组件工作<br />原理　　152<br />7.3.3　Pulsar运行时　　153<br />7.4　Pulsar I/O　　154<br />7.4.1　Pulsar I/O概述　　154<br />7.4.2　使用内置的Pulsar连接器　　155<br />7.4.3　开发自定义连接器　　156<br />7.4.4　实例层原理　　160<br />应用篇<br />第8章　Pulsar SL架构、配置与<br />实现原理　　164<br />8.1　Trino简介　　164<br />8.1.1　Trino架构简介　　165<br />8.1.2　存储与计算分离　　168<br />8.2　Pulsar SL配置　　169<br />8.2.1　单机体验Pulsar SL　　169<br />8.2.2　数据查询　　170<br />8.3　Pulsar连接器工作原理　　171<br />8.4　Pulsar联邦查询　　172<br />8.4.1　准备数据源　　173<br />8.4.2　联邦查询　　175<br />第9章　管理你的Pulsar　　176<br />9.1　Pulsar安全配置　　176<br />9.1.1　数据加密　　176<br />9.1.2　授权与认　　180<br />9.1.3　自定义权限插件　　186<br />9.2　Pulsar监控配置　　189<br />9.2.1　Pulsar监控概述　　189<br />9.2.2　Prometheus部署　　190<br />9..　Grafana仪表盘配置　　191<br />9.3　Pulsar管理工具　　192<br />9.3.1　pulsar-admin工具　　192<br />9.3.2　Pulsar Manager工具　　196<br />9.3.3　能压测工具　　197<br />9.3.4　ManagedLedger管理　　199<br />9.4　集群管理　　201<br />9.4.1　配置管理　　201<br />9.4.2　Pulsar资源配置　　203<br />0章　Pulsar与Flink生态　　206<br />10.1　Flink简介　　207<br />10.1.1　Flink的概念　　207<br />10.1.2　Flink基本组件　　212<br />10.2　Flink Pulsar源连接器　　214<br />10.2.1　源连接器的使用　　214<br />10.2.2　源连接器原理　　218<br />10.3　Flink Pulsar输出连接器　　220<br />10.3.1　统一接收器API　　221<br />10.3.2　Flink Pulsar Sink API的<br />使用　　221<br />10.3.3　PulsarSink原理　　2<br />1章　Pulsar应用实践　　224<br />11.1　Pulsar应用模式　　224<br />11.1.1　Pulsar数据总线概述　　224<br />11.1.2　Pulsar数据集成　　226<br />11.2　Pulsar与Spark集成　　0<br />11.3　Pulsar与Kafka集成　　1<br />11.3.1　Kafka客户端适配器　　1<br />11.3.2　Pulsar I/O Kafka　　<br />11.3.3　Pulsar Connector适配器　　4<br />11.4　Pulsar CDC　　<br />11.4.1　Pulsar Canal CDC　　<br />11.4.2　Pulsar Debezium CDC　　<br />11.5　可靠优先场景　　<br />11.5.1　幂等、消确认与<br />事务　　<br />11.5.2　可靠与一致　　240