快速体验
- 打开 InsCode(快马)平台 https://www.inscode.net
- 输入框内输入如下内容：
创建一个简单的WebSocket聊天应用，要求：1.使用WebFlux的WebSocketHandler 2.支持多房间聊天 3.包含前端HTML页面 4.有消息历史记录功能。请生成完整可运行项目，添加中文代码注释解释关键概念，适合新手学习。- 点击'项目生成'按钮，等待项目生成完整后预览效果
今天尝试用Spring WebFlux搭建一个实时聊天室，作为响应式编程的入门练习。整个过程比想象中顺利，特别适合像我这样刚接触Reactive编程的开发者。记录下关键步骤和踩坑经验，供同样想尝试WebFlux的朋友参考。
环境准备与项目初始化使用Spring Initializr创建项目时，除了基础的WebFlux依赖，需要额外添加reactor-netty（WebSocket支持）和lombok（简化代码）。第一次接触响应式编程可能会对Mono/Flux这些概念发懵，其实可以简单理解成"数据流的包装器"——就像快递盒，里面装着可能现在或未来到达的数据。
核心WebSocket配置创建WebSocketHandler时要注意三个关键方法：handle方法处理连接建立，需要返回Mono 表示异步操作完成；session.receive()获取消息流是个Flux，用map操作符转换消息格式；session.send()发送消息也需要返回Flux 。这里最容易犯的错误是忘记订阅（subscribe）数据流，导致消息无法发送。
多房间功能实现用ConcurrentHashMap存储不同房间的会话集合，每个连接建立时通过URL路径参数获取房间ID（比如/chat/room1）。特别注意线程安全问题，WebFlux虽然是异步非阻塞的，但共享变量的操作仍需使用原子类或同步容器。测试时发现如果直接使用普通HashMap，高并发时会出现会话丢失。
消息历史记录在内存中用Queue保存最近的50条消息，新用户加入时先推送历史记录。这里用Flux.fromIterable将集合转为响应式流，与实时消息流通过Flux.merge合并。注意历史记录应该深拷贝后再发送，避免后续修改影响已发送内容。
前端页面交互虽然重点是后端，但简单的前端能让测试更直观。用原生WebSocket API建立连接，onmessage事件用JSON.parse处理服务端消息。调试时发现Chrome开发者工具的WebSocket消息监控比打印日志更方便。
遇到的典型问题及解决： - 问题1：消息偶尔乱序 → 检查后发现是前端没有处理消息延迟，添加时间戳排序解决 - 问题2：连接意外断开 → 增加心跳检测机制，30秒无活动自动发送ping帧 - 问题3：内存持续增长 → 用JProfiler发现是未取消订阅的流造成，添加doOnCancel清理资源
整个项目最让我惊喜的是响应式编程的处理能力——用ab测试工具模拟1000并发连接时，传统Servlet容器线程池爆满，而WebFlux仅占用少量线程就轻松应对。虽然调试响应式链条比同步代码更费脑细胞，但ReactorDebugAgent这个工具能大幅提升异常定位效率。
这个聊天室项目在InsCode(快马)平台上可以直接体验，不需要配置任何环境，点击部署按钮就能看到实时运行效果。平台自动生成的WebFlux代码结构清晰，中文注释对新手特别友好，遇到问题时还能随时用内置的AI助手查看原理说明。对于想快速验证响应式编程效果的同学，这种开箱即用的体验确实省去了不少搭建环境的麻烦。
快速体验
- 打开 InsCode(快马)平台 https://www.inscode.net
- 输入框内输入如下内容：
创建一个简单的WebSocket聊天应用，要求：1.使用WebFlux的WebSocketHandler 2.支持多房间聊天 3.包含前端HTML页面 4.有消息历史记录功能。请生成完整可运行项目，添加中文代码注释解释关键概念，适合新手学习。- 点击'项目生成'按钮，等待项目生成完整后预览效果
