课程简介

一条系统、高效的学习路径，共四个模块，从“系统架构”和“实时算法”两方面入手，由浅入深、自底而上带你扎实掌握实时流计算

① 模块一：实时流计算入门

这部分会介绍流计算系统的整体架构和使用场景，以及入门需掌握的编程基础，比如 NIO 和异步编程，以及异步系统中的 OOM 和反向压力问题，学完你会对实时流计算有个整体的认识，对“流”的本质有个初步理解

②模块二：自己动手做一个流计算框架

这部分会介绍如何从 JDK 里最基础的工具类，一步步开发出一个分布式流计算框架。通过这种自己动手的方式，你会更深刻理解流计算系统的核心概念及实现原理

③模块三：核心技术篇

这部分详细讲解流计算能够解决哪些类型的问题（流数据操作、时间维度聚合计算、关联图谱分析、事件序列分析、模型学习和预测）。还讨论了流计算过程中重要的状态管理问题，带你思考如何将前面的流计算框架扩展为分布式系统。你会掌握实时流计算中的各种算法，帮你解决各种实时业务场景中的问题

④模块四：开源流计算框架原理解析及实战

这部分会对比分析 4 种开源流计算框架的具体实现，来巩固你对流计算核心概念和技术的理解，并带你正确理解这些框架的 API 设计，以便你在实际业务场景中灵活应用，实现各种复杂的业务逻辑

此外，专栏还会通过两个实践案例（实时风控和实时数据同步），带你将开源流计算框架运用到具体的业务场景中

课程目录

• 21讲吃透实时流计算-拉钩专栏
• 开篇词 攻克实时流计算难点，掌握大数据未来！_6417
• 开篇词 攻克实时流计算难点，掌握大数据未来！
• 01 实时流计算的通用架构_6418
• 01 实时流计算的通用架构
• 02 异步和高并发：为什么 NIO 是异步和高并发编程的基础？_6419
• 02 异步和高并发：为什么 NIO 是异步和高并发编程的基础？
• 03 反向压力：如何避免异步系统中的 OOM 问题？_6420
• 03 反向压力：如何避免异步系统中的 OOM 问题？
• 04 流与异步：为什么说掌握流计算先要理解异步编程？_6421
• 04 流与异步：为什么说掌握流计算先要理解异步编程？
• 05 有向无环图（DAG）：如何描述、分解流计算过程？_6422
• 05 有向无环图（DAG）：如何描述、分解流计算过程？
• 06 CompletableFuture：如何理解 Java 8 新引入的异步编程类？_6423
• 06 CompletableFuture：如何理解 Java 8 新引入的异步编程类？
• 07 死锁：为什么流计算应用突然卡住，不处理数据了_6424
• 07 死锁：为什么流计算应用突然卡住，不处理数据了
• 08 性能调优：如何优化流计算应用？_6425
• 08 性能调优：如何优化流计算应用？
• 09 流数据操作：最基本的流计算功能_6426
• 09 流数据操作：最基本的流计算功能
• 开篇词-攻克实时流计算难点，掌握大数据未来.md
• 01-实时流计算的通用架构.md
• 02-异步和高并发：为什么 NIO 是异步和高并发编程的基础.md
• 03.md
• 04-流与异步：为什么说掌握流计算先要理解异步编程.md
• 05-有向无环图（DAG）：如何描述、分解流计算过程.md
• 06-CompletableFuture：如何理解 Java 8 新引入的异步编程类.md
• 07-死锁：为什么流计算应用突然卡住，不处理数据了.md
• 08-性能调优：如何优化流计算应用.md
• 09-流数据操作：最基本的流计算功能.md