| 作者 |
| 尼恩 汪文君 |
| 丛书名 |
| 出版社 |
| 机械工业出版社 |
| ISBN |
| 9782104251411 |
| 简要 |
| 简介 |
| 内容简介书籍计算机书籍 ---------------------------8080137 - Java高并发核心编程 卷2：多线程、锁、JMM、JUC、高并发设计模式--------------------------- 本书聚焦Java并发编程基础知识，介绍了Java多线程、线程池、内置锁、JMM、CAS、JUC、高并发设计模式等并发编程方面的核心原理和实战知识。 本书共分为10章。第1~2章浅显易懂地剖析多线程、线程池的核心原理和实战使用，揭秘线程安全问题和Java内置锁的核心原理；第3~4章细致地讲解CAS原理与JUC原子类、JMM的核心原理，揭秘CAS操作的弊端和两类规避措施、解密Java如何内存可见性和volatile关键字的底层知识；第5章细致地介绍JUC显示锁的原理和各种显示锁的使用；第6章图文并茂、深入浅出地阐述JUC高并发的基础设施：AQS抽象同步器核心原理；第7章介绍JUC容器类；第8~10章介绍常见的Java高并发设计模式的原理和使用。 ---------------------------8079752 - Java高并发核心编程 卷1：NIO、Netty、Redis、ZooKeeper--------------------------- 本书从操作系统底层的IO原理入手，同时提供高性能开发的实战案例，是一本Java高并发编程的基础原理和实战图书。 本书共分为15章。第1~4章为高并发基础，浅显易懂地剖析高并发IO的底层原理，细致地讲解Reactor高性能模式，图文并茂地介绍Java异步回调模式。这些原理方面的基础知识非常重要，会为读者打下坚实的基础，也是日常开发Java后台应用时解决实际问题的金钥匙。第5~8章为Netty原理和实战，是本书的重中之重，主要介绍高性能通信框架Netty、Netty的重要组件、单体IM的实战设计和模块实现。第9~12章从TCP、HTTP入手，介绍客户端与服务端、服务端与服务端之间的高性能HTTP通信和WebSocket通信。第13~15章对ZooKeeper、Curator API、Redis、Jedis API的使用进行详尽的说明，以提升读者设计和开发高并发、可扩展系统的能力。 ---------------------------8071119 - Java高并发编程详解：深入理解并发核心库--------------------------- . 本书共包含四大部分，其中，第一部分（第1章）详细介绍了JMH（Java Micro benchmark Harness）基准测试工具的使用细节。该工具是由Oracle JVM开发团队相关成员开发的，借助它，开发者将能足够了解自己所编写的程序代码，以及程序在运行期的精确性能表现。在本书的其他章节对API之间的性能进行对比时，主要也是依赖于该工具，因此在学习本书的其他章节时，最好能够掌握该部分内容，强烈推荐开发者将JMH纳入自己日常的“兵器库”中，以便能够随时随地进行利用。 第二部分主要围绕Java并发包进行展开，涉及的内容包括Java的原子类型及其底层原理（第2章）；Java的并发工具集（第3章），其中还穿插了Google Guava的部分内容；Java的并发容器（第4章），包括阻塞队列BlockingQueue和并发容器等内容；Java的ExecutorService（第5章），以及Future家族成员的详解。 第三部分（第6章），主要介绍自Java 8 引入的Stream，并且重点解释了具备高并发能力的并行流原理，以及如何自定义并行流等相关内容。 第四部分（第7章），深入讲解Metrics，它作为一个比较小巧的度量工具集，目前已经成为事实上的度量标准，在很多开源软件、框架和平台中都能看到对它的使用，比如Apache的Kafka、Spark、Storm、Spring Cloud等都是使用Metrics作为系统运行性能指标收集的手段。 |
| 目录 |
| [套装书具体书目] 8071119 - Java高并发编程详解：深入理解并发核心库 - 9787111657705 - 机械工业出版社 - 定价 99 8079752 - Java高并发核心编程 卷1：NIO、Netty、Redis、ZooKeeper - 9787111677581 - 机械工业出版社 - 定价 149 8080137 - Java高并发核心编程 卷2：多线程、锁、JMM、JUC、高并发设计模式 - 9787111679882 - 机械工业出版社 - 定价 129 ---------------------------8080137 - Java高并发核心编程 卷2：多线程、锁、JMM、JUC、高并发设计模式--------------------------- 前言 自序 第1章 多线程原理与实战 1 1.1 两个技术面试故事 1 1.2 无处不在的进程和线程 2 1.2.1 进程的基本原理 3 1.2.2 线程的基本原理 5 1.2.3 进程与线程的区别 8 1.3 创建线程的4种方法 8 1.3.1 Thread类详解 8 1.3.2 创建一个空线程 10 1.3.3 线程创建方法一：继承Thread类创建线程类 12 1.3.4 线程创建方法二：实现Runnable接口创建线程目标类 13 1.3.5 优雅创建Runnable线程目标类的两种方式 16 1.3.6 通过实现Runnable接口的方式创建线程目标类的优缺点 18 1.3.7 线程创建方法三：使用Callable和FutureTask创建线程 23 1.3.8 线程创建方法四：通过线程池创建线程 28 1.4 线程的核心原理 31 1.4.1 线程的调度与时间片 31 1.4.2 线程的优先级 32 1.4.3 线程的生命周期 35 1.4.4 一个线程状态的简单演示案例 37 1.4.5 使用Jstack工具查看线程状态 40 1.5 线程的基本操作 41 1.5.1 线程名称的设置和获取 41 1.5.2 线程的sleep操作 43 1.5.3 线程的interrupt操作 45 1.5.4 线程的join操作 48 1.5.5 线程的yield操作 53 1.5.6 线程的daemon操作 55 1.5.7 线程状态总结 61 1.6 线程池原理与实战 62 1.6.1 JUC的线程池架构 63 1.6.2 Executors的4种快捷创建线程池的方法 65 1.6.3 线程池的标准创建方式 72 1.6.4 向线程池提交任务的两种方式 73 1.6.5 线程池的任务调度流程 77 1.6.6 ThreadFactory（线程工厂） 79 1.6.7 任务阻塞队列 81 1.6.8 调度器的钩子方法 82 1.6.9 线程池的拒绝策略 84 1.6.10 线程池的优雅关闭 87 1.6.11 Executors快捷创建线程池的潜在问题 93 1.7 确定线程池的线程数 97 1.7.1 按照任务类型对线程池进行分类 97 1.7.2 为IO密集型任务确定线程数 98 1.7.3 为CPU密集型任务确定线程数 100 1.7.4 为混合型任务确定线程数 101 1.8 ThreadLocal原理与实战 104 1.8.1 ThreadLocal的基本使用 104 1.8.2 ThreadLocal的使用场景 107 1.8.3 使用ThreadLocal进行线程隔离 108 1.8.4 使用ThreadLocal进行跨函数数据传递 109 1.8.5 ThreadLocal内部结构演进 110 1.8.6 ThreadLocal源码分析 111 1.8.7 ThreadLocalMap源码分析 114 1.8.8 ThreadLocal综合使用案例 119 第2章 Java内置锁的核心原理 123 2.1 线程安全问题 123 2.1.1 自增运算不是线程安全的 123 2.1.2 临界区资源与临界区代码段 126 2.2 synchronized关键字 127 2.2.1 synchronized同步方法 127 2.2.2 synchronized同步块 128 2.2.3 静态的同步方法 130 2.3 生产者-消费者问题 131 2.3.1 生产者-消费者模式 131 2.3.2 一个线程不安全的实现版本 132 2.3.3 一个线程安全的实现版本 139 2.4 Java对象结构与内置锁 140 2.4.1 Java对象结构 141 2.4.2 Mark Word的结构信息 143 2.4.3 使用JOL工具查看对象的布局 145 2.4.4 大小端问题 149 2.4.5 无锁、偏向锁、轻量级锁和重量级锁 150 2.5 偏向锁的原理与实战 152 2.5.1 偏向锁的核心原理 152 2.5.2 偏向锁的演示案例 152 2.5.3 偏向锁的膨胀和撤销 156 2.6 轻量级锁的原理与实战 157 2.6.1 轻量级锁的核心原理 157 2.6.2 轻量级锁的演示案例 158 2.6.3 轻量级锁的分类 161 2.6.4 轻量级锁的膨胀 162 2.7 重量级锁的原理与实战 162 2.7.1 重量级锁的核心原理 162 2.7.2 重量级锁的开销 165 2.7.3 重量级锁的演示案例 166 2.8 偏向锁、轻量级锁与重量级锁的对比 169 2.9 线程间通信 170 2.9.1 线程间通信的定义 170 2.9.2 低效的线程轮询 170 2.9.3 wait方法和notify方法的原理 171 2.9.4 “等待-通知”通信模式演示案例 174 2.9.5 生产者-消费者之间的线程间通信 177 2.9.6 需要在synchronized同步块的内部使用wait和notify 180 第3章 CAS原理与JUC原子类 182 3.1 什么是CAS 182 3.1.1 Unsafe类中的CAS方法 182 3.1.2 使用CAS进行无锁编程 185 3.1.3 使用无锁编程实现轻量级安全自增 186 3.1.4 字段偏移量的计算 189 3.2 JUC原子类 191 3.2.1 JUC中的Atomic原子操作包 191 3.2.2 基础原子类AtomicInteger 192 3.2.3 数组原子类AtomicIntegerArray 194 3.2.4 AtomicInteger线程安全原理 195 3.3 对象操作的原子性 198 3.3.1 引用类型原子类 198 3.3.2 属性更新原子类 200 3.4 ABA问题 201 3.4.1 了解ABA问题 201 3.4.2 ABA问题解决方案 203 3.4.3 使用AtomicStampedReference解决ABA问题 203 3.4.4 使用AtomicMarkableReference解决ABA问题 205 3.5 提升高并发场景下CAS操作的性能 207 3.5.1 以空间换时间：LongAdder 208 3.5.2 LongAdder的原理 211 3.6 CAS在JDK中的广泛应用 218 3.6.1 CAS操作的弊端和规避措施 218 3.6.2 CAS操作在JDK中的应用 219 第4章 可见性与有序性的原理 220 4.1 CPU物理缓存结构 220 4.2 并发编程的三大问题 222 4.2.1 原子性问题 222 4.2.2 可见性问题 223 4.2.3 有序性问题 224 4.3 硬件层的MESI协议原理 227 4.3.1 总线锁和缓存锁 228 4.3.2 MSI协议 230 4.3.3 MESI协议及RFO请求 230 4.3.4 volatile的原理 234 4.4 有序性与内存屏障 237 4.4.1 重排序 237 4.4.2 As-if-Serial规则 238 4.4.3 硬件层面的内存屏障 240 4.5 JMM详解 242 4.5.1 什么是Java内存模型 243 4.5.2 JMM与JVM物理内存的区别 244 4.5.3 JMM的8个操作 246 4.5.4 JMM如何解决有序性问题 248 4.5.5 volatile语义中的内存屏障 250 4.6 Happens-Before规则 251 4.6.1 Happens-Before规则介绍 252 4.6.2 规则1：顺序性规则 252 4.6.3 规则2：volatile规则 252 4.6.4 规则3：传递性规则 255 4.6.5 规则4：监视锁规则 255 4.6.6 规则5：start()规则 256 4.6.7 规则6：join()规则 257 4.7 volatile不具备原子性 258 4.7.1 volatile变量的自增实例 258 4.7.2 volatile变量的复合操作不具备原子性的原理 260 第5章 JUC显式锁的原理与实战 262 5.1 显式锁 262 5.1.1 显式锁Lock接口 263 5.1.2 可重入锁ReentrantLock 264 5.1.3 使用显式锁的模板代码 267 5.1.4 基于显式锁进行“等待-通知”方式的线程间通信 269 5.1.5 LockSupport 273 5.1.6 显式锁的分类 276 5.2 悲观锁和乐观锁 279 5.2.1 悲观锁存在的问题 279 5.2.2 通过CAS实现乐观锁 279 5.2.3 不可重入的自旋锁 280 5.2.4 可重入的自旋锁 281 5.2.5 CAS可能导致“总线风暴” 283 5.2.6 CLH自旋锁 285 5.3 公平锁与非公平锁 293 5.3.1 非公平锁实战 293 5.3.2 公平锁实战 295 5.4 可中断锁与不可中断锁 296 5.4.1 锁的可中断抢占 296 5.4.2 死锁的监测与中断 298 5.5 共享锁与独占锁 302 5.5.1 独占锁 302 5.5.2 共享锁Semaphore 302 5.5.3 共享锁CountDownLatch 306 5.6 读写锁 307 5.6.1 读写锁ReentrantReadWriteLock 308 5.6.2 锁的升级与降级 310 5.6.3 StampedLock 312 第6章 AQS抽象同步器的核心原理 316 6.1 锁与队列的关系 316 6.2 AQS的核心成员 318 6.2.1 状态标志位 318 6.2.2 队列节点类 319 6.2.3 FIFO双向同步队列 321 6.2.4 JUC显式锁与AQS的关系 322 6.2.5 ReentrantLock与AQS的组合关系 322 6.3 AQS中的模板模式 325 6.3.1 模板模式 325 6.3.2 一个模板模式的参考实现 326 6.3.3 AQS的模板流程 329 6.3.4 AQS中的钩子方法 329 6.4 通过AQS实现一把简单的独占锁 331 6.4.1 简单的独占锁的UML类图 331 6.4.2 简单的独占锁的实现 331 6.4.3 SimpleMockLock测试用例 333 6.5 AQS锁抢占的原理 335 6.5.1 显式锁抢占的总体流程 335 6.5.2 AQS模板方法：acquire(arg) 336 6.5.3 钩子实现：tryAcquire(arg) 336 6.5.4 直接入队：addWaiter 337 6.5.5 自旋入队：enq 338 6.5.6 自旋抢占：acquireQueued() 339 6.5.7 挂起预判：shouldParkAfterFailedAcquire() 340 6.5.8 线程挂起：parkAndCheckInterrupt() 342 6.6 AQS的两个关键点：节点的入队和出队 343 6.6.1 节点的自旋入队 343 6.6.2 节点的出队 343 6.7 AQS锁释放的原理 345 6.7.1 SimpleMockLock独占锁的释放流程 345 6.7.2 AQS模板方法：release() 345 6.7.3 钩子实现：tryRelease() 346 6.7.4 唤醒后继：unparkSuccessor() 346 6.8 ReentrantLock的抢锁流程 347 6.8.1 ReentrantLock非公平锁的抢占流程 347 6.8.2 非公平锁的同步器子类 348 6.8.3 非公平抢占的钩子方法：tryAcquire(arg) 349 6.8.4 ReentrantLock公平锁的抢占流程 350 6.8.5 公平锁的同步器子类 350 6.8.6 公平抢占的钩子方法：tryAcquire(arg) 351 6.8.7 是否有后继节点的判断 351 6.9 AQS条件队列 352 6.9.1 Condition基本原理 352 6.9.2 await()等待方法原理 353 6.9.3 signal()唤醒方法原理 355 6.10 AQS的实际应用 356 第7章 JUC容器类 358 7.1 线程安全的同步容器类 358 7.2 JUC高并发容器 360 7.3 CopyOnWriteArrayList 362 7.3.1 CopyOnWriteArrayList的使用 362 7.3.2 CopyOnWriteArrayList的原理 364 7.3.3 CopyOnWriteArrayList 读取操作 366 7.3.4 CopyOnWriteArrayList写入操作 366 7.3.5 CopyOnWriteArrayList的迭代器实现 367 7.4 BlockingQueue 368 7.4.1 BlockingQueue的特点 368 7.4.2 阻塞队列的常用方法 368 7.4.3 常见的BlockingQueue 370 7.4.4 ArrayBlockingQueue的基本使用 372 7.4.5 ArrayBlockingQueue构造器和成员 374 7.4.6 非阻塞式添加元素：add()、offer()方法的原理 376 7.4.7 阻塞式添加元素：put()方法的原理 378 7.4.8 非阻塞式删除元素：poll()方法的原理 380 7.4.9 阻塞式删除元素：take()方法的原理 381 7.4.10 peek()直接返回当前队列的头元素 382 7.5 ConcurrentHashMap 383 7.5.1 HashMap和HashTable的问题 383 7.5.2 JDK 1.7版本ConcurrentHashMap的结构 384 7.5.3 JDK 1.7版本ConcurrentHashMap的核心原理 385 7.5.4 JDK 1.8版本ConcurrentHashMap的结构 393 7.5.5 JDK 1.8版本ConcurrentHashMap的核心原理 395 7.5.6 JDK 1.8版本ConcurrentHashMap的核心源码 398 第8章 高并发设计模式 402 8.1 线程安全的单例模式 402 8.1.1 从饿汉式单例到懒汉式单例 402 8.1.2 使用内置锁保护懒汉式单例 404 8.1.3 双重检查锁单例模式 404 8.1.4 使用双重检查锁+volatile 405 8.1.5 使用静态内部类实现懒汉式单例模式 406 8.2 Master-Worker模式 407 8.2.1 Master-Worker模式的参考实现 408 8.2.2 Netty中Master-Worker模式的实现 413 8.2.3 Nginx中Master-Worker模式的实现 414 8.3 ForkJoin模式 415 8.3.1 ForkJoin模式的原理 415 8.3.2 ForkJoin框架 416 8.3.3 ForkJoin框架使用实战 416 8.3.4 ForkJoin框架的核心API 419 8.3.5 工作窃取算法 421 8.3.6 ForkJoin框架的原理 423 8.4 生产者-消费者模式 423 8.5 Future模式 424 第9章 高并发核心模式之异步回调模式 426 9.1 从泡茶的案例讲起 426 9.2 join：异步阻塞之闷葫芦 427 9.2.1 线程的合并流程 427 9.2.2 调用join()实现异步泡茶喝 427 9.2.3 join()方法详解 429 9.3 FutureTask：异步调用之重武器 430 9.3.1 通过FutureTask获取异步执行结果的步骤 431 9.3.2 使用FutureTask实现异步泡茶喝 431 9.4 异步回调与主动调用 434 9.5 Guava的异步回调模式 435 9.5.1 详解FutureCallback 435 9.5.2 详解ListenableFuture 436 9.5.3 ListenableFuture异步任务 437 9.5.4 使用Guava实现泡茶喝的实例 438 9.5.5 Guava异步回调和Java异步调用的区别 442 9.6 Netty的异步回调模式 442 9.6.1 GenericFutureListener接口详解 443 9.6.2 Netty的Future接口详解 443 9.6.3 ChannelFuture的使用 444 9.6.4 Netty的出站和入站异步回调 444 9.7 异步回调模式小结 445 第10章 CompletableFuture异步回调 446 10.1 CompletableFuture详解 446 10.1.1 CompletableFuture的UML类关系 446 10.1.2 CompletionStage接口 447 10.1.3 使用runAsync和supplyAsync创建子任务 448 10.1.4 设置子任务回调钩子 449 10.1.5 调用handle()方法统一处理异常和结果 451 10.1.6 线程池的使用 452 10.2 异步任务的串行执行 453 10.2.1 thenApply()方法 453 10.2.2 thenRun()方法 455 10.2.3 thenAccept()方法 455 10.2.4 thenCompose()方法 456 10.2.5 4个任务串行方法的区别 458 10.3 异步任务的合并执行 458 10.3.1 thenCombine()方法 458 10.3.2 runAfterBoth()方法 460 10.3.3 thenAcceptBoth()方法 461 10.3.4 allOf()等待所有的任务结束 462 10.4 异步任务的选择执行 463 10.4.1 applyToEither()方法 463 10.4.2 runAfterEither()方法 465 10.4.3 acceptEither()方法 465 10.5 CompletableFuture的综合案例 466 10.5.1 使用CompletableFuture实现泡茶喝实例 466 10.5.2 使用CompletableFuture进行多个RPC调用 468 10.5.3 使用RxJava模拟RPC异步回调 469 ---------------------------8079752 - Java高并发核心编程 卷1：NIO、Netty、Redis、ZooKeeper--------------------------- 前言 自序 第1章 高并发时代的必备技能 1 1.1 Netty为何这么火 1 1.1.1 Netty火热的程度 1 1.1.2 Netty是面试的必杀器 2 1.2 高并发利器Redis 2 1.2.1 什么是Redis 2 1.2.2 Redis成为缓存事实标准的原因 3 1.3 分布式利器ZooKeeper 3 1.3.1 什么是ZooKeeper 3 1.3.2 ZooKeeper的优势 4 1.4 高性能HTTP通信技术 4 1.4.1 十万级以上高并发场景中的高并发HTTP通信技术 5 1.4.2 微服务之间的高并发RPC技术 6 1.5 高并发IM的综合实战 7 1.5.1 高并发IM的学习价值 8 1.5.2 庞大的应用场景 8 第2章 高并发IO的底层原理 10 2.1 IO读写的基本原理 10 2.1.1 内核缓冲区与进程缓冲区 11 2.1.2 典型的系统调用流程 11 2.2 四种主要的IO模型 13 2.2.1 同步阻塞IO 14 2.2.2 同步非阻塞IO 15 2.2.3 IO多路复用 16 2.2.4 异步IO 17 2.3 通过合理配置来支持百万级并发连接 18 第3章 Java NIO核心详解 21 3.1 Java NIO简介 21 3.1.1 NIO和OIO的对比 21 3.1.2 通道 22 3.1.3 选择器 22 3.1.4 缓冲区 23 3.2 详解NIO Buffer类及其属性 23 3.2.1 Buffer类 23 3.2.2 Buffer类的重要属性 23 3.3 详解NIO Buffer类的重要方法 26 3.3.1 allocate() 26 3.3.2 put() 27 3.3.3 flip() 27 3.3.4 get() 29 3.3.5 rewind() 30 3.3.6 mark()和reset() 32 3.3.7 clear() 33 3.3.8 使用Buffer类的基本步骤 34 3.4 详解NIO Channel类 34 3.4.1 FileChannel 35 3.4.2 使用FileChannel完成文件复制的实战案例 37 3.4.3 SocketChannel 39 3.4.4 使用SocketChannel发送文件的实战案例 41 3.4.5 DatagramChannel 43 3.4.6 使用DatagramChannel发送数据的实战案例 45 3.5 详解NIO Selector 47 3.5.1 选择器与注册 47 3.5.2 SelectableChannel 48 3.5.3 SelectionKey 48 3.5.4 选择器使用流程 48 3.5.5 使用NIO实现Discard服务器的实战案例 50 3.5.6 使用SocketChannel在服务端接收文件的实战案例 53 第4章 鼎鼎大名的Reactor模式 59 4.1 Reactor模式的重要性 59 4.1.1 为什么首先学习Reactor模式 59 4.1.2 Reactor模式简介 60 4.1.3 多线程OIO的致命缺陷 60 4.2 单线程Reactor模式 62 4.2.1 什么是单线程Reactor 62 4.2.2 单线程Reactor的参考代码 63 4.2.3 单线程Reactor模式的EchoServer的实战案例 66 4.2.4 单线程Reactor模式的缺点 69 4.3 多线程Reactor模式 69 4.3.1 多线程版本的Reactor模式演进 69 4.3.2 多线程版本Reactor的实战案例 69 4.3.3 多线程版本Handler的实战案例 72 4.4 Reactor模式的优缺点 74 第5章 Netty核心原理与基础实战 76 5.1 第一个Netty实战案例DiscardServer 76 5.1.1 创建第一个Netty项目 76 5.1.2 第一个Netty服务端程序 77 5.1.3 业务处理器NettyDiscardHandler 79 5.1.4 运行NettyDiscardServer 80 5.2 解密Netty中的Reactor模式 80 5.2.1 回顾Reactor模式中IO事件的处理流程 81 5.2.2 Netty中的Channel 81 5.2.3 Netty中的Reactor 82 5.2.4 Netty中的Handler 83 5.2.5 Netty中的Pipeline 84 5.3 详解Bootstrap 86 5.3.1 父子通道 86 5.3.2 EventLoopGroup 87 5.3.3 Bootstrap启动流程 88 5.3.4 ChannelOption 91 5.4 详解Channel 93 5.4.1 Channel的主要成员和方法 93 5.4.2 EmbeddedChannel 94 5.5 详解Handler 95 5.5.1 ChannelInboundHandler入站处理器 96 5.5.2 ChannelOutboundHandler出站处理器 97 5.5.3 ChannelInitializer通道初始化处理器 99 5.5.4 ChannelInboundHandler的生命周期的实战案例 99 5.6 详解Pipeline 103 5.6.1 Pipeline入站处理流程 103 5.6.2 Pipeline出站处理流程 104 5.6.3 ChannelHandlerContext 106 5.6.4 HeadContext与TailContext 107 5.6.5 Pipeline入站和出站的双向链接操作 109 5.6.6 截断流水线的入站处理传播过程 112 5.6.7 在流水线上热插拔Handler 114 5.7 详解ByteBuf 117 5.7.1 ByteBuf的优势 117 5.7.2 ByteBuf的组成部分 117 5.7.3 ByteBuf的重要属性 118 5.7.4 ByteBuf的方法 118 5.7.5 ByteBuf基本使用的实战案例 120 5.7.6 ByteBuf的引用计数 122 5.7.7 ByteBuf的分配器 124 5.7.8 ByteBuf缓冲区的类型 126 5.7.9 两类ByteBuf使用的实战案例 127 5.7.10 ByteBuf的自动创建与自动释放 130 5.7.11 ByteBuf浅层复制的高级使用方式 136 5.8 Netty的零拷贝 138 5.8.1 通过CompositeByteBuf实现零拷贝 139 5.8.2 通过wrap操作实现零拷贝 141 5.9 EchoServer的实战案例 142 5.9.1 NettyEchoServer 142 5.9.2 NettyEchoServerHandler 143 5.9.3 NettyEchoClient 144 5.9.4 NettyEchoClientHandler 146 第6章 Decoder与Encoder核心组件 148 6.1 Decoder原理与实战 148 6.1.1 ByteToMessageDecoder解码器处理流程 148 6.1.2 自定义Byte2IntegerDecoder整数解码器 149 6.1.3 ReplayingDecoder解码器 152 6.1.4 整数的分包解码器的实战案例 153 6.1.5 字符串的分包解码器的实战案例 156 6.1.6 MessageToMessageDecoder解码器 161 6.2 常用的内置Decoder 161 6.2.1 LineBasedFrameDecoder解码器 162 6.2.2 DelimiterBasedFrameDecoder解码器 163 6.2.3 LengthFieldBasedFrameDecoder解码器 164 6.2.4 多字段Head-Content协议数据包解析的实战案例 167 6.3 Encoder原理与实战 170 6.3.1 MessageToByteEncoder编码器 170 6.3.2 MessageToMessageEncoder编码器 171 6.4 解码器和编码器的结合 173 6.4.1 ByteToMessageCodec编解码器 173 6.4.2 CombinedChannelDuplexHandler组合器 174 第7章 序列化与反序列化：JSON和Protobuf 176 7.1 详解粘包和拆包 177 7.1.1 半包问题的实战案例 177 7.1.2 什么是半包问题 179 7.1.3 半包问题的根因分析 179 7.2 使用JSON协议通信 180 7.2.1 JSON的核心优势 180 7.2.2 JSON序列化与反序列化开源库 181 7.2.3 JSON序列化与反序列化的实战案例 182 7.2.4 JSON传输的编码器和解码器 184 7.2.5 JSON传输的服务端的实战案例 185 7.2.6 JSON传输的客户端的实战案例 186 7.3 使用Protobuf协议通信 188 7.3.1 一个简单的proto文件的实战案例 188 7.3.2 通过控制台命令生成POJO和Builder 189 7.3.3 通过Maven插件生成POJO和Builder 190 7.3.4 Protobuf序列化与反序列化的实战案例 191 7.4 Protobuf编解码的实战案例 194 7.4.1 Netty内置的Protobuf基础编码器/解码器 194 7.4.2 Protobuf传输的服务端的实战案例 195 7.4.3 Protobuf传输的客户端的实战案例 197 7.5 详解Protobuf协议语法 198 7.5.1 proto文件的头部声明 199 7.5.2 Protobuf的消息结构体与消息字段 200 7.5.3 Protobuf字段的数据类型 201 7.5.4 proto文件的其他语法规范 202 第8章 基于Netty单体IM系统的开发实战 204 8.1 自定义Protobuf编解码器 204 8.1.1 自定义Protobuf编码器 205 8.1.2 自定义Protobuf解码器 206 8.1.3 IM系统中Protobuf消息格式的设计 207 8.2 IM的登录流程 209 8.2.1 图解登录/响应流程的环节 209 8.2.2 客户端涉及的主要模块 210 8.2.3 服务端涉及的主要模块 210 8.3 客户端的登录处理的实战案例 211 8.3.1 LoginConsoleCommand和User POJO 212 8.3.2 LoginSender 213 8.3.3 ClientSession 216 8.3.4 LoginResponseHandler 218 8.3.5 客户端流水线的装配 219 8.4 服务端的登录响应的实战案例 220 8.4.1 服务端流水线的装配 220 8.4.2 LoginRequestHandler 221 8.4.3 LoginProcesser 223 8.4.4 EventLoop线程和业务线程相互隔离 224 8.5 详解Session服务器会话 227 8.5.1 通道的容器属性 227 8.5.2 ServerSession服务端会话类 229 8.5.3 SessionMap会话管理器 230 8.6 点对点单聊的实战案例 230 8.6.1 单聊的端到端流程 231 8.6.2 客户端的ChatConsoleCommand收集聊天内容 231 8.6.3 客户端的CommandController发送POJO 232 8.6.4 服务端的ChatRedirectHandler进行消息转发 233 8.6.5 服务端的ChatRedirectProcesser进行异步消息转发 234 8.6.6 客户端的ChatMsgHandler聊天消息处理器 235 8.7 详解心跳检测 236 8.7.1 网络连接的假死现象 236 8.7.2 服务端的空闲检测 237 8.7.3 客户端的心跳发送 238 第9章 HTTP原理与Web服务器实战 241 9.1 高性能Web应用架构 241 9.1.1 十万级并发的Web应用架构 241 9.1.2 千万级高并发的Web应用架构 243 9.2 详解HTTP应用层协议 246 9.2.1 HTTP简介 247 9.2.2 HTTP的请求URL 248 9.2.3 HTTP的请求报文 248 9.2.4 HTTP的响应报文 251 9.2.5 HTTP中GET和POST的区别 254 9.3 HTTP的演进 254 9.3.1 HTTP的1.0版本 255 9.3.2 HTTP的1.1版本 258 9.3.3 HTTP的2.0版本 261 9.4 基于Netty实现简单的Web服务器 263 9.4.1 基于Netty的HTTP服务器演示实例 263 9.4.2 基于Netty的HTTP请求的处理流程 264 9.4.3 Netty内置的HTTP报文解码流程 266 9.4.4 基于Netty的HTTP响应编码流程 268 9.4.5 HttpEchoHandler回显业务处理器的实战案例 269 9.4.6 使用Postman发送多种类型的请求体 273 第10章 高并发HTTP通信的核心原理 278 10.1 需要进行HTTP连接复用的高并发场景 278 10.1.1 反向代理Nginx与Java Web应用服务之间的HTTP 高并发通信 278 10.1.2 微服务网关与微服务Provider实例之间的HTTP高并发通信 279 10.1.3 分布式微服务Provider实例之间的RPC的HTTP高并发通信 280 10.1.4 Java通过HTTP客户端访问REST接口服务的HTTP 高并发通信 280 10.2 详解传输层TCP 281 10.2.1 TCP/IP的分层模型 281 10.2.2 HTTP报文传输原理 283 10.2.3 TCP的报文格式 285 10.2.4 TCP的三次握手 288 10.2.5 TCP的四次挥手 290 10.2.6 三次握手、四次挥手的常见面试题 292 10.3 TCP连接状态的原理与实验 293 10.3.1 TCP/IP连接的11种状态 293 10.3.2 通过netstat指令查看连接状态 295 10.4 HTTP长连接原理 297 10.4.1 HTTP长连接和短连接 297 10.4.2 不同HTTP版本中的长连接选项 298 10.5 服务端HTTP长连接技术 299 10.5.1 应用服务器Tomcat的长连接配置 299 10.5.2 Nginx承担服务端角色时的长连接配置 302 10.5.3 服务端长连接设置的注意事项 304 10.6 客户端HTTP长连接技术原理与实验 306 10.6.1 HttpURLConnection短连接技术 306 10.6.2 HTTP短连接的通信实验 309 10.6.3 Apache HttpClient客户端的HTTP长连接技术 311 10.6.4 Apache HttpClient客户端长连接实验 319 10.6.5 Nginx承担客户端角色时的长连接技术 323 第11章 WebSocket原理与实战 326 11.1 WebSocket协议简介 326 11.1.1 Ajax短轮询和Long Poll长轮询的原理 327 11.1.2 WebSocket与HTTP之间的关系 327 11.2 WebSocket回显演示程序开发 328 11.2.1 WebSocket回显程序的客户端代码 328 11.2.2 WebSocket相关的Netty内置处理类 331 11.2.3 WebSocket的回显服务器 333 11.2.4 WebSocket的业务处理器 335 11.3 WebSocket协议通信的原理 337 11.3.1 抓取WebSocket协议的本机数据包 337 11.3.2 WebSocket 握手过程 338 11.3.3 WebSocket通信报文格式 341 第12章 SSL/TLS核心原理与实战 344 12.1 什么是SSL/TLS 344 12.1.1 SSL/TLS协议的版本演进 344 12.1.2 SSL/TLS协议的分层结构 346 12.2 加密算法原理与实战 347 12.2.1 哈希单向加密算法原理与实战 347 12.2.2 对称加密算法原理与实战 349 12.2.3 非对称加密算法原理与实战 351 12.2.4 数字签名原理与实战 356 12.3 SSL/TLS运行过程 361 12.3.1 SSL/TLS第一阶段握手 361 12.3.2 SSL/TLS第二阶段握手 363 12.3.3 SSL/TLS第三阶段握手 367 12.3.4 SSL/TLS第四阶段握手 369 12.4 详解Keytool工具 370 12.4.1 数字证书与身份识别 370 12.4.2 存储密钥与证书文件格式 373 12.4.3 使用Keytool工具管理密钥和证书 374 12.5 使用Java程序管理密钥与证书 377 12.5.1 使用Java操作数据证书所涉及的核心类 378 12.5.2 使用Java程序创建密钥与仓库 378 12.5.3 使用Java程序导出证书文件 383 12.5.4 使用Java程序将数字证书导入信任仓库 385 12.6 OIO通信中的SSL/TLS使用实战 389 12.6.1 JSSE安全套接字扩展核心类 390 12.6.2 JSSE安全套接字的创建过程 391 12.6.3 OIO安全通信的Echo服务端实战 393 12.6.4 OIO安全通信的Echo客户端实战 395 12.7 单向认证与双向认证 396 12.7.1 SSL/TLS 单向认证 396 12.7.2 使用证书信任管理器 399 12.7.3 SSL/TLS 双向认证 402 12.8 Netty通信中的SSL/TLS使用实战 405 12.8.1 Netty安全通信演示实例 405 12.8.2 Netty内置SSLEngine处理器详解 406 12.8.3 Netty的简单安全聊天器服务端程序 409 12.9 HTTPS协议安全通信实战 412 12.9.1 使用Netty实现HTTPS回显服务端程序 412 12.9.2 通过HttpsURLConnection发送HTTPS请求 414 12.9.3 HTTPS服务端与客户端的测试用例 415 第13章 ZooKeeper分布式协调 417 13.1 ZooKeeper伪集群安装和配置 417 13.1.1 创建数据和日志 417 13.1.2 创建myid文本文件 419 13.1.3 创建和修改配置文件 419 13.1.4 配置文件示例 421 13.1.5 启动ZooKeeper伪集群 422 13.2 使用ZooKeeper 进行分布式存储 423 13.2.1 详解ZooKeeper存储模型 424 13.2.2 zkCli客户端指令清单 424 13.3 ZooKeeper应用开发实战 426 13.3.1 ZkClient开源客户端 427 13.3.2 Curator开源客户端 427 13.3.3 准备Curator开发环境 428 13.3.4 创建Curator客户端实例 429 13.3.5 通过Curator创建节点 431 13.3.6 通过Curator读取节点 432 13.3.7 通过Curator更新节点 433 13.3.8 通过Curator删除节点 435 13.4 分布式命名服务实战 436 13.4.1 ID生成器 437 13.4.2 ZooKeeper分布式ID生成器的实战案例 438 13.4.3 集群节点的命名服务的实战案例 440 13.4.4 结合ZooKeeper实现SnowFlake ID算法 442 13.5 分布式事件监听的重点 447 13.5.1 Watcher标准的事件处理器 448 13.5.2 NodeCache节点缓存的监听 451 13.5.3 PathCache子节点监听 454 13.5.4 TreeCache节点树缓存 457 13.6 分布式锁原理与实战 461 13.6.1 公平锁和可重入锁的原理 461 13.6.2 ZooKeeper分布式锁的原理 463 13.6.3 分布式锁的基本流程 464 13.6.4 加锁的实现 465 13.6.5 释放锁的实现 471 13.6.6 分布式锁的使用 472 13.6.7 Curator的InterProcessMutex可重入锁 473 13.6.8 ZooKeeper分布式锁的优缺点 474 第14章 分布式缓存Redis实战 476 14.1 Redis入门 476 14.1.1 Redis的安装和配置 476 14.1.2 Redis客户端命令 479 14.1.3 Redis键的命名规范 480 14.2 Redis数据类型 481 14.2.1 String 481 14.2.2 List 482 14.2.3 Hash 484 14.2.4 Set 485 14.2.5 ZSet 486 14.3 Jedis基础编程的实战案例 487 14.3.1 Jedis操作String 488 14.3.2 Jedis操作List 490 14.3.3 Jedis操作Hash 491 14.3.4 Jedis操作Set 493 14.3.5 Jedis操作ZSet 494 14.4 JedisPool连接池的实战案例 497 14.4.1 JedisPool的配置 497 14.4.2 JedisPool的创建和预热 499 14.4.3 JedisPool的使用 501 14.5 使用spring-data-redis完成CRUD的实战案例 502 14.5.1 CRUD中应用缓存的场景 502 14.5.2 配置spring-redis.xml 504 14.5.3 RedisTemplate模板API 506 14.5.4 使用RedisTemplate模板API完成CRUD的实战案例 509 14.5.5 使用RedisCallback回调完成CRUD的实战案例 511 14.6 Spring的Redis缓存注解 513 14.6.1 使用Spring缓存注解完成CRUD的实战案例 514 14.6.2 spring-redis.xml中配置的调整 515 14.6.3 @CachePut和@Cacheable注解 517 14.6.4 @CacheEvict注解 518 14.6.5 @Caching组合注解 519 14.7 详解SpEL 520 14.7.1 SpEL运算符 521 14.7.2 缓存注解中的SpEL表达式 524 第15章 亿级高并发IM架构与实战 526 15.1 支撑亿级流量的高并发IM架构的理论基础 526 15.1.1 亿级流量的系统架构的开发实战 527 15.1.2 高并发架构的技术选型 527 15.1.3 详解IM消息的序列化协议选型 528 15.1.4 详解长连接和短连接 528 15.2 分布式IM的命名服务的实战案例 529 15.2.1 IM节点的POJO类 530 15.2.2 IM节点的ImWorker类 531 15.3 Worker集群的负载均衡的实战案例 534 15.3.1 ImLoadBalance负载均衡器 535 15.3.2 与WebGate的整合 537 15.4 即时通信消息的路由和转发的实战案例 538 15.4.1 IM路由器WorkerRouter 538 15.4.2 IM转发器PeerSender 541 15.5 在线用户统计的实战案例 543 15.5.1 Curator的分布式计数器 543 15.5.2 用户上线和下线的统计 545 ---------------------------8071119 - Java高并发编程详解：深入理解并发核心库--------------------------- 推荐序一 推荐序二 推荐序三 推荐序四 前 言 第1章 JMH 1 1.1 JMH简介 1 1.2 JMH快速入门 1 1.2.1 用main方法进行测试 1 1.2.2 用JMH进行微基准测试 3 1.3 JMH的基本用法 6 1.3.1 @Benchmark标记基准测试方法 7 1.3.2 Warmup以及Measurement 8 1.3.3 四大BenchmarkMode 10 1.3.4 OutputTimeUnit 14 1.3.5 三大State的使用 14 1.3.6 @Param的妙用 19 1.3.7 JMH的测试套件（Fixture） 23 1.3.8 CompilerControl 26 1.4 编写正确的微基准测试以及高级用法 27 1.4.1 编写正确的微基准测试用例 28 1.4.2 一些高级的用法 38 1.5 JMH的Profiler 45 1.5.1 StackProfiler 45 1.5.2 GcProfiler 47 1.5.3 ClassLoaderProfiler 51 1.5.4 CompilerProfiler 54 1.6 本章总结 56 第2章 Java并发包之原子类型详解 57 2.1 AtomicInteger详解 58 2.1.1 性能测试对比 58 2.1.2 AtomicInteger的基本用法 61 2.1.3 AtomicInteger内幕 66 2.1.4 AtomicInteger总结 68 2.2 AtomicBoolean详解 69 2.2.1 AtomicBoolean的基本用法 69 2.2.2 AtomicBoolean内幕 71 2.2.3 Try Lock显式锁的实现 71 2.2.4 AtomicBoolean总结 74 2.3 AtomicLong详解 74 2.4 AtomicReference详解 76 2.4.1 AtomicReference的应用场景 77 2.4.2 AtomicReference的基本用法 83 2.4.3 AtomicReference的内幕 84 2.4.4 AtomicReference总结 86 2.5 AtomicStampedReference详解 86 2.5.1 CAS算法ABA问题 86 2.5.2 AtomicStampedReference详解 87 2.5.3 AtomicStampedReference总结 89 2.6 AtomicArray详解 89 2.7 AtomicFieldUpdater详解 90 2.7.1 原子性更新对象属性 90 2.7.2 注意事项 91 2.7.3 AtomicFieldUpdater总结 93 2.8 sun.misc.Unsafe详解 93 2.8.1 如何获取Unsafe 94 2.8.2 JNI、Java和C/C++混合编程 95 2.8.3 危险的Unsafe 98 2.8.4 sun.misc.Unsafe总结 100 2.9 本章总结 100 第3章 Java并发包之工具类详解 102 3.1 CountDownLatch工具详解 102 3.1.1 等待所有子任务结束 103 3.1.2 CountDownLatch的其他方法及总结 106 3.2 CyclicBarrier工具详解 107 3.2.1 等待所有子任务结束 107 3.2.2 CyclicBarrier的循环特性 110 3.2.3 CyclicBarrier的其他方法以及总结 114 3.2.4 CyclicBarrier VS. CountDownLatch 116 3.3 Exchanger工具详解 116 3.3.1 一对线程间的数据交换 116 3.3.2 Exchanger的方法详解 121 3.3.3 Exchanger总结 123 3.4 Semaphore工具详解 124 3.4.1 Semaphore限制同时在线的用户数量 124 3.4.2 使用Semaphore定义try lock 127 3.4.3 Semaphore其他方法详解 129 3.4.4 扩展Semaphore增强release 135 3.4.5 Semaphore总结 138 3.5 Phaser工具详解 138 3.5.1 Phaser的基本用法 138 3.5.2 Phase（阶段）以及Phaser方法详解 144 3.5.3 Phaser层级关系 148 3.5.4 Phaser总结 149 3.6 Lock&ReentrantLock详解 150 3.6.1 Lock及ReentrantLock方法详解 150 3.6.2 正确使用显式锁Lock 152 3.6.3 ReentrantLock VS. Synchronized关键字 158 3.6.4 显式锁Lock总结 164 3.7 ReadWriteLock&ReentrantRead-WriteLock详解 165 3.7.1 读写锁的基本使用方法 165 3.7.2 读写锁的方法 167 3.7.3 基准测试性能对比 167 3.7.4 读写锁总结 170 3.8 Condition详解 171 3.8.1 初识Condition 171 3.8.2 Condition接口方法详解 174 3.8.3 使用Condition之生产者消费者 177 3.8.4 Condition总结 181 3.9 StampedLock详解 181 3.9.1 读写锁的饥饿写问题 182 3.9.2 StampedLock的使用 183 3.9.3 与其他锁的性能对比 185 3.9.4 StampedLock总结 191 3.10 Guava之Monitor详解 192 3.10.1 Monitor及Guard 192 3.10.2 Monitor的其他方法 194 3.10.3 Monitor总结 194 3.11 Guava之RateLimiter详解 194 3.11.1 RateLimiter的基本使用 195 3.11.2 RateLimiter的限流操作——漏桶算法 196 3.11.3 令牌环桶算法 201 3.11.4 RateLimiter总结 204 3.12 本章总结 204 第4章 Java并发包之并发容器详解 205 4.1 链表 206 4.1.1 基本的链表 206 4.1.2 优先级链表 210 4.1.3 跳表（SkipList） 213 4.1.4 链表总结 221 4.2 BlockingQueue（阻塞队列） 221 4.2.1 ArrayBlockingQueue 222 4.2.2 PriorityBlockingQueue 226 4.2.3 LinkedBlockingQueue 228 4.2.4 DelayQueue 228 4.2.5 SynchronousQueue 231 4.2.6 LinkedBlockingDeque 233 4.2.7 LinkedTransferQueue 234 4.2.8 BlockingQueue总结 236 4.3 ConcurrentQueue（并发队列） 237 4.3.1 并发队列的性能 239 4.3.2 并发队列在使用中需要注意的问题 241 4.3.3 并发队列总结 245 4.4 ConcurrentMap（并发映射） 245 4.4.1 ConcurrentHashMap简介 245 4.4.2 ConcurrentSkipListMap简介 247 4.4.3 并发映射总结 247 4.5 写时拷贝算法（Copy On Write） 248 4.5.1 CopyOnWrite读实现操作分析 249 4.5.2 CopyOnWrite写实现操作分析 249 4.5.3 CopyOnWrite总结 250 4.6 高并发无锁（Lock Free）数据结构的实现 250 4.6.1 高并发无锁链表的实现 250 4.6.2 Lock Free数据结构的测试 253 4.6.3 本节总结 255 4.7 本章总结 255 第5章 Java并发包之ExecutorService详解 256 5.1 Executor&ExecutorService详解 256 5.1.1 ThreadPoolExecutor详解 257 5.1.2 ScheduledExecutorService详解 265 5.1.3 关闭ExecutorService 271 5.1.4 Executors详解 273 5.1.5 ExecutorService总结 276 5.2 Future和Callback 277 5.2.1 Future详解 277 5.2.2 ExecutorService与Future 280 5.2.3 Future的不足之处 282 5.2.4 Google Guava的Future 282 5.2.5 Future总结 284 5.3 ForkJoinPool 详解 284 5.3.1 Fork/Join Framework介绍 284 5.3.2 ForkJoinTask详解 285 5.3.3 ForkJoinPool总结 289 5.4 CompletionService详解 289 5.4.1 ExecutorService执行批量任务的缺陷 289 5.4.2 CompletionService详解 291 5.4.3 CompletionService总结 294 5.5 CompletableFuture详解 294 5.5.1 CompletableFuture的基本用法 294 5.5.2 任务的异步运行 296 5.5.3 异步任务链 296 5.5.4 合并多个Future 298 5.5.5 多Future的并行计算 299 5.5.6 错误处理 299 5.5.7 JDK 9对CompletableFuture的进一步支持 300 5.5.8 CompletableFuture总结 300 5.6 本章总结 301 第6章 Java Streams详解 302 6.1 Stream介绍及其基本操作 302 6.1.1 如何创建Stream 303 6.1.2 Stream之Intermediate操作 306 6.1.3 Stream之Terminal操作 312 6.1.4 NumericStream详解 317 6.1.5 Stream总结 320 6.2 Collector在Stream中的使用 320 6.2.1 初识Collector 321 6.2.2 Collectors用法详解 324 6.2.3 自定义Collector 335 6.2.4 Collector总结 336 6.3 Parallel Stream详解 337 6.3.1 并行流Parallel Stream 337 6.3.2 Spliterator 详解 340 6.3.3 Spliterator总结 343 6.4 本章总结 344 第7章 Metrics（Powerful Toolkit For Measure） 345 7.1 Metrics快速入门 345 7.1.1 如何监控度量应用程序 345 7.1.2 Metrics环境搭建 346 7.2 五大Metric详解 346 7.2.1 Meter 347 7.2.2 Gauge 349 7.2.3 Counter 360 7.2.4 Histogram 362 7.2.5 Timer 370 7.3 Reporter详解 372 7.3.1 ConsoleReporter 373 7.3.2 LogReporter 376 7.3.3 JMXReporter 378 7.3.4 CsvReporter 379 7.4 Metrics Plugins 380 7.4.1 Health Check 381 7.4.2 JVM Instrumentation 386 7.5 深入Metrics源码 387 7.5.1 MetricRegistry如何工作 388 7.5.2 Reporter如何工作 392 7.5.3 拾遗补漏 394 7.6 本章总结 396 |