3.1 WebSocket 服务端
在 Reactor Netty 上搭建 WebSocket 服务端:upgrade 握手、websocket() 回调、文本与二进制帧收发、inbound/outbound 双流管道、帧类型判断与 ping/pong 心跳处理。附可编译运行示例。
tag
在 Reactor Netty 上搭建 WebSocket 服务端:upgrade 握手、websocket() 回调、文本与二进制帧收发、inbound/outbound 双流管道、帧类型判断与 ping/pong 心跳处理。附可编译运行示例。
Reactor Netty HTTP 客户端的弹性模式:retryWhen 指数退避与抖动、timeout 传播与取消语义、onErrorResume 降级策略、重试/超时/降级的组合顺序、Resilience4j Reactor 适配与幂等性保障。附参数对照表。
Reactor Netty HTTP 客户端连接池深度配置:ConnectionProvider 创建与参数调优、固定池与弹性池的选择、连接复用与空闲驱逐策略、最大连接数与等待队列上限、LIFO/FIFO 复用策略与多服务隔离。附可运行示例。
Reactor Netty HTTP 客户端全面深入:HttpClient.create 配置链、GET/POST/PUT/DELETE 请求发送、请求头与请求体构建、响应状态码分支处理、URI 查询参数编码、压缩解码与 keep-alive 复用。附可编译运行示例。
从 TCP 滑动窗口与 Netty 写水位线出发,深入理解 Reactor Netty HTTP 层的背压机制:Flux 到 send/sendString 的异步衔接、WRITE_BUFFER_WATER_MARK 配置、isWritable 检查与慢客户端保护、超时断开与内存安全策略。
在 Reactor Netty 的 handle 回调中构建完整的请求响应管线:URI 路由分发与路径参数提取、请求体异步聚合与 JSON 解码、Content-Type 字符集声明、中间件链式组合与统一错误处理、阻塞操作 subscribeOn 隔离。附可编译运行示例。
从零搭建 Reactor Netty 最小 HTTP 服务器:HttpServer.create 配置链、端口绑定与 handle 回调、LoopResources 线程池配置、优雅关闭与 DisposableServer 生命周期管理。附可直接 javac 编译运行的完整示例。
《Java 响应式编程·系统构建与数据访问》全 50 篇目录与学习路径:14 章 42 节 + 序 前言 目录 + 附录 A–E。三条学习路径:顺序通读从 Reactor Netty 到 R2DBC,底层深入聚焦背压与线程模型,代码速查直达网关与缓存配置。
卷二所需环境与版本:JDK 25、Maven 3.9、Reactor BOM 2025.0.8、R2DBC PostgreSQL、Caffeine Async、Lettuce Reactive。介绍贯穿项目 eventd v2 的模块结构(gateway/api/data/monitor/resilience/saga)以及三种阅读路径。
本序声明卷二的定位——把卷一手写的 Publisher/Subscriber 能力组装成可运行的 HTTP 服务和数据管道,覆盖 Reactor Netty、WebFlux、R2DBC、响应式安全与监控;同时声明与卷一(背压原理)和卷三(流处理引擎)的边界。
《Java 响应式编程·系统构建与数据访问》全 50 篇:从 Reactor Netty HTTP 服务器与客户端、WebFlux 注解与函数式路由、R2DBC 响应式数据访问与事务,到响应式缓存、安全、监控、弹性模式与事件驱动集成,最后以 eventd v2 全链路验收收尾。依赖 Reactor Netty 1.3.x + WebFlux + R2DBC PostgreSQL + Caffeine Async + Lettuce Reactive。