先弄清楚:你的项目是否真需要响应式编程

响应式编程不是写业务代码的万能模板,这套资料的核心主题是 Project Reactor。它解决的是高并发、大流量场景下的系统阻塞与资源浪费问题。当你面对大量 I/O 操作、数据库查询或远程接口调用时,传统同步阻塞会让线程一直等待,导致服务器资源被迅速耗尽。Reactor 提供了一套非阻塞的事件驱动机制,让少量线程能处理海量并发请求。在决定是否使用这套资料前,先审视你的工作场景:如果你在做传统的内部管理系统,响应式编程带来的复杂度往往大于收益;但如果你在做网关、消息流转、高并发读取或微服务底座,它就是解决性能瓶颈的关键工具。

资料怎么用:从规范到执行原理的阅读顺序

这套资料的内容编排很务实,建议按既定顺序逐步推进,不要跳跃。第一部分讲响应式流规范,这是底层基石,重点理解背压机制如何防止消费者被生产者压垮。第二部分是 Project Reactor 框架的核心,也就是 Mono 和 Flux 两个关键组件的具体用法。这两个组件是整个框架的积木。第三部分是整份资料最有价值的环节:执行原理与源码解析。这部分会剖析框架底层是如何装配各个操作符的。在看这部分时,不要只盯着视频结论,必须打开本地的集成开发环境,跟着把同样的操作符链写一遍。重点观察不同装配方式下,事件是如何在各个操作符之间传递的,通过手动断点调试去验证源码的实际执行路径,这样才能把纸面的原理变成自己的认知。

学完能做什么:具备独立排查与重构的能力

资料里的每个操作符演示都不是孤立存在的,它们对应着真实的业务组装逻辑。看完这套内容,你应当具备三项具体能力。第一,能独立排查现有的响应式代码问题,比如由于装配位置错误导致的事件丢失或线程阻塞,能通过源码执行逻辑快速定位。第二,能对现有的同步阻塞接口进行非阻塞重构,把传统的同步调用改写为基于 Mono 和 Flux 的响应式流。第三,能看懂主流框架底层的响应式实现,在遇到复杂性能调优时,不再停留在盲目修改参数的阶段,而是深入到源码层面理解资源调度机制。对于有 Java 并发基础但没接触过响应式编程的人来说,这套资料刚好能帮你跨过概念理解与底层源码的门槛。


掌握Reactor框架实战开发、通过源码级解析熟悉Mono,Flux的各种用法

课程目录

*   01 前言/

  *   01 前言.mp4 (9.46 MB), 03:21

  *   02 响应式编程-reactor.txt (0.00 MB)

*   02 基本概念/

  *   01 响应式编程基本概念.mp4 (33.24 MB), 11:22

*   03 响应式流规范/

  *   01 响应式流规范.mp4 (24.07 MB), 08:23

  *   02 响应式流规范实现示例.mp4 (28.93 MB), 09:45

*   04 Project Reactor/

  *   01 project reactor介绍.mp4 (22.92 MB), 07:44

*   05 入门/

  *   01 5-1 响应式编程入门.mp4 (28.85 MB), 09:02

*   06 reactor执行原理/

  *   01 reactor执行原理-subscribe阶段.mp4 (25.18 MB), 09:11

  *   02 执行原理-onSubscribe和request阶段.mp4 (28.15 MB), 09:09

  *   03 执行原理-onNext阶段.mp4 (23.40 MB), 07:52

*   07 Mono&Flux介绍/

  *   01 Mono和Flux.mp4 (22.11 MB), 07:13

*   08 Mono/

  *   01 Mono.just.mp4 (16.76 MB), 05:03

  *   02 empty创建一个空序列.mp4 (6.15 MB), 01:57

  *   03 justOrEmpty创建一个Mono.mp4 (6.74 MB), 02:05

  *   04 用never创建MonoNever.mp4 (5.86 MB), 02:00

  *   05 Mono高级创建方法create.mp4 (37.11 MB), 12:08

  *   06 Mono.from.mp4 (15.42 MB), 04:33

  *   07 fromSupplier.mp4 (3.42 MB), 01:07

  *   08 fromCallable.mp4 (1.30 MB), 00:24

  *   09 fromRunnable.mp4 (3.73 MB), 01:13

  *   10 fromFuture.mp4 (7.09 MB), 01:52

  *   11 fromDirect.mp4 (8.84 MB), 02:35

  *   12 defer.mp4 (5.55 MB), 01:46

  *   13 delay.mp4 (3.84 MB), 01:16

  *   14 firstWithSignal.mp4 (10.90 MB), 03:27

  *   15 ignoreElements.mp4 (16.41 MB), 05:47

  *   16 Mono.error.mp4 (11.88 MB), 03:32

  *   17 subscribe.mp4 (31.02 MB), 08:33

*   09 Flux/

  *   01 Flux.just.mp4 (10.85 MB), 03:31

*   10 线程调度Scheduler/

  *   01 调度器.mp4 (23.52 MB), 07:06

  *   02 immediate.mp4 (8.32 MB), 02:41

  *   03 single.mp4 (19.67 MB), 06:04

  *   04 boundedElastic.mp4 (38.46 MB), 11:27

  *   05 parallel.mp4 (16.08 MB), 05:04

  *   06 fromExecutorService.mp4 (9.18 MB), 02:52

  *   07 publishOn.mp4 (24.75 MB), 08:11

  *   08 publishon原理.mp4 (41.11 MB), 11:48

  *   09 publishon为什么只跑在一根线程上.mp4 (7.85 MB), 02:14

  *   10 publishon消费拉取元素的时机.mp4 (8.71 MB), 02:22

  *   11 publishon之前为什么也会切线程.mp4 (17.68 MB), 05:55

  *   12 连续调用publishon.mp4 (18.44 MB), 06:00

  *   13 subscribeOn.mp4 (16.64 MB), 05:41

  *   14 subscribeOn源码分析.mp4 (24.88 MB), 07:19

  *   15 subscribeOn为什么异步消费会被阻塞.mp4 (16.68 MB), 05:13

  *   16 subscribeOn和publishOn混用.mp4 (22.71 MB), 06:35

*   11 背压/

  *   01 什么是背压.mp4 (12.75 MB), 04:35

  *   02 背压的核心问题.mp4 (16.57 MB), 05:00

  *   03 背压示例.mp4 (15.71 MB), 05:33

  *   04 背压策略.mp4 (15.27 MB), 05:09

  *   05 背压源码分析.mp4 (37.17 MB), 12:41

  *   06 响应式流规范中的背压实现-Publisher.mp4 (34.12 MB), 10:33

  *   07 响应式流规范中的背压实现-Subscriber.mp4 (11.16 MB), 03:28

  *   08 响应式流规范中的背压实现-Subscription.mp4 (14.93 MB), 04:57

  *   09 自定义背压实现测试.mp4 (11.24 MB), 03:35

*   12 跨线程传递-context/

  *   01 Context.mp4 (11.26 MB), 03:46

  *   02 基于Context创建Mono.mp4 (23.01 MB), 07:33

  *   03 contextWrite设置上下文.mp4 (14.61 MB), 04:32

  *   04 通过subscribe设置上下文.mp4 (5.52 MB), 01:57

  *   05 transformDeferredContextual使用.mp4 (6.43 MB), 02:25

*   13 测试/

  *   01 测试工具StepVerifier.mp4 (19.95 MB), 05:40

  *   02 withVirtualTime虚拟时间.mp4 (8.92 MB), 03:06

*   14 调试/

  *   01 reactor的调试.mp4 (36.55 MB), 10:45

  *   02 checkPoint.mp4 (7.14 MB), 02:27

  *   03 log记录事件日志.mp4 (10.30 MB), 03:25