spring boot集成websocket实现实时推送需选对模式：原生@serverendpoint适合轻量点对点，stomp+消息代理支持订阅/发布、适用于复杂场景；均需加依赖、开出口、配跨域；关键在监听连接生命周期、避免遍历session广播、用simpmessagingtemplate可靠推送；前端须用stomp客户端库、实现心跳与自动重连。
在 Spring Boot 中集成 WebSocket 实现实时消息推送，核心是建立持久、双向的连接通道，让服务端能主动推数据给前端，而不是等前端轮询。关键不在于堆砌代码，而在于选对模式、配好路径、管住连接。
明确用哪种实现方式
Spring Boot 支持两类主流集成路径：
-
原生 @ServerEndpoint 方式：轻量直接，适合点对点通知（如单用户订单状态变更）、小规模广播（如后台向所有在线管理员发告警）。依赖
javax.websocket，需手动管理 Session 和连接池。 -
STOMP + 消息代理方式：基于 WebSocket 构建消息语义，支持订阅/发布（
/topic）、点对点发送（/user）、消息确认、心跳等。适合聊天、行情推送、协同编辑等复杂场景。需配置MessageBroker，推荐生产环境使用。
后端基础配置三步走
无论选哪种方式，以下三件事必须做：
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
-
加依赖：在
pom.xml中引入spring-boot-starter-websocket；若用 STOMP，还需确保 Spring Messaging 相关类已就位（Boot 2.7+ 默认包含）。 -
开出口：通过
@Configuration类注册ServerEndpointExporter（原生方式），或配置WebSocketMessageBrokerConfigurer（STOMP 方式）来定义端点路径（如/ws）和允许跨域。 -
处理跨域：开发阶段常见
localhost:5173 → localhost:8080跨域问题。STOMP 配置中调用registry.setAllowedOrigins("*")或指定域名；原生方式可在@ServerEndpoint注解中加configurator = MyConfigurator.class自定义握手头。
消息推送的关键控制点
真正决定推送是否稳定、可控的，是这几个细节：
-
连接生命周期要监听：务必实现
@OnOpen、@OnClose、@OnError方法（原生）或重写afterConnectionEstablished等钩子（STOMP），用于记录在线用户、清理资源、触发重连逻辑。 -
广播不能靠遍历 Session：原生方式若用
ConcurrentHashMap<string session></string>存连接，推送时逐个session.getBasicRemote().sendText()容易因某个 Session 失效导致异常中断整条广播。应加 try-catch 并异步处理失败会话。 -
STOMP 推送更可靠：用
SimpMessagingTemplate.convertAndSend("/topic/notice", data)即可向所有订阅者发消息；用convertAndSendToUser("userId", "/queue/notify", data)可精准推给指定用户（需前端连接时带上 token 认证）。
前端连接与收发要点
前端不是简单 new WebSocket 就完事：
- 连接地址注意协议：HTTP 开发环境用
ws://localhost:8080/ws，HTTPS 生产环境必须用wss://。 - STOMP 必须用客户端库（如
@stomp/stompjs），不能直接用原生 WebSocket API 发送 STOMP 帧；否则服务端无法解析。 - 务必实现心跳与自动重连：浏览器页面切后台或网络抖动时连接易断。建议前端每 25 秒发一次
PING，服务端响应PONG；断连后按指数退避（1s→2s→4s…）尝试重连。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
