1. 项目概述为什么Java开发者绕不开WebSocket如果你是一名Java后端开发者最近在面试或者做项目时大概率会被问到或用到WebSocket。这玩意儿早就不是什么新鲜技术了但热度一直不减从“Java面试八股文”到“SpringBoot WebSocket”配置再到各种实时聊天、在线协作、股票行情推送的场景它都是核心。简单来说HTTP协议是“你问我答”一次请求一次响应对话就结束。而WebSocket协议就像是电话接通后双方可以随时说话建立起一条持久、双向的通信通道。这对于需要服务器主动向客户端推送数据的场景来说是刚需。我见过不少项目为了模拟“实时”效果用HTTP轮询隔几秒请求一次把服务器搞得疲惫不堪不仅浪费资源延迟还高。也见过一些新手直接上Socket编程复杂度陡增还得自己处理粘包、心跳、断线重连这些脏活累活。WebSocket就是在HTTP握手之后升级协议专门用来解决这类问题的标准方案。所以无论你是要做一个简单的在线客服系统还是一个复杂的多人在线游戏大厅或者一个需要实时展示数据的监控大屏搞懂并在Java里用好WebSocket都是一项必备技能。这篇文章我就结合自己踩过的坑和项目经验带你从原理到实战彻底搞明白它。2. WebSocket核心原理与机制拆解要用好一个技术先得知道它到底是怎么工作的。WebSocket的机制并不复杂但理解透彻能帮你避开很多坑。2.1 握手从HTTP到WebSocket的升级WebSocket连接并非凭空建立它始于一次普通的HTTP请求也就是著名的“握手”Handshake过程。客户端比如浏览器会发起一个看起来有些特殊的HTTP请求GET /chat HTTP/1.1 Host: server.example.com Upgrade: websocket Connection: Upgrade Sec-WebSocket-Key: dGhlIHNhbXBsZSBub25jZQ Sec-WebSocket-Version: 13关键就在这几个头部Upgrade: websocket和Connection: Upgrade明确告诉服务器“我想把协议升级成WebSocket”。Sec-WebSocket-Key一个由客户端随机生成的Base64编码的密钥用于握手验证防止误连接。Sec-WebSocket-Version指定使用的WebSocket协议版本13是目前最普遍、最稳定的版本。服务器如果同意升级就会返回一个类似这样的响应HTTP/1.1 101 Switching Protocols Upgrade: websocket Connection: Upgrade Sec-WebSocket-Accept: s3pPLMBiTxaQ9kYGzzhZRbKxOo这个Sec-WebSocket-Accept的值很重要它不是随便生成的。服务器需要将客户端传来的Sec-WebSocket-Key加上一个固定的GUID字符串“258EAFA5-E914-47DA-95CA-C5AB0DC85B11”然后进行SHA-1哈希计算最后将结果进行Base64编码得到这个值。客户端会验证这个值确保对面是一个真正的WebSocket服务器而不是一个普通的HTTP服务器误处理了请求。这个设计巧妙地利用了HTTP基础设施来完成初始连接又通过验证机制保证了安全性。握手成功后TCP连接并不会关闭而是被复用于WebSocket通信。之后的通信就不再是HTTP报文了而是遵循WebSocket数据帧格式的二进制数据实现了全双工通信。2.2 数据帧轻量级的通信单元握手之后所有数据都以“帧”Frame的形式传输。WebSocket帧设计得非常轻量头部开销很小。一个帧包含几个关键部分FIN位指示这是否是消息的最后一个帧。一个消息Message可能被拆分成多个帧Fragmentation传输。操作码Opcode定义帧的类型比如0x1表示文本帧0x2表示二进制帧0x8表示连接关闭0x9表示Ping0xA表示Pong。掩码Mask这是WebSocket协议一个重要的安全设计。所有从客户端发往服务器的数据帧都必须被掩码Masking Key不为0而从服务器发往客户端的数据帧则不能掩码。掩码是为了防止代理服务器缓存污染等攻击。虽然对于Java服务端开发者来说我们主要是解析客户端发来的掩码数据但必须理解这个机制否则无法正确解码消息。载荷长度Payload Length指示后面跟着的实际数据长度。扩展数据与载荷数据可选的扩展数据和实际的应用数据。理解帧结构有助于你明白为什么WebSocket高效以及当你在Wireshark里抓包看到乱码时因为被掩码了知道那是正常现象。2.3 心跳保活与连接管理TCP连接建立后可能因为网络空闲被中间设备如防火墙、Nginx断开。为了维持连接需要心跳机制也就是Ping/Pong帧。服务器可以定期向客户端发送一个Ping帧操作码0x9客户端收到后必须回复一个Pong帧操作码0xA。这既检测了连接是否存活也告诉中间设备“这个连接还在用别关”。在实际项目中心跳间隔需要根据网络环境和业务需求来设定通常设置在30秒到几分钟之间。间隔太短浪费资源太长则可能导致连接已死但未被及时发现。一个常见的坑是只实现了客户端发Ping服务器没处理Pong或者反之。WebSocket协议规定收到Ping必须回复Pong但很多底层库会自动处理。你需要确认你使用的库或框架是否提供了心跳配置或者是否需要自己实现。3. Java中实现WebSocket的几种主流方式了解了原理我们来看看在Java生态里具体怎么干。从底层到上层主要有三种路径选择哪种取决于你的项目复杂度、控制欲和开发效率要求。3.1 原生Java APIJSR 356与javax.websocket从Java EE 7开始WebSocket被标准化为JSR 356核心包是javax.websocketJakarta EE中为jakarta.websocket。这是最“标准”的玩法Tomcat、Jetty等Servlet容器都内置了实现。核心注解ServerEndpoint标注在类上定义WebSocket服务端的端点URI类似WebServlet。OnOpen标注在方法上当新的WebSocket连接建立时触发。OnMessage标注在方法上当收到客户端消息时触发。OnClose标注在方法上当连接关闭时触发。OnError标注在方法上当通信发生错误时触发。一个最简单的示例如下import javax.websocket.*; import javax.websocket.server.ServerEndpoint; import java.io.IOException; ServerEndpoint(/echo) public class EchoEndpoint { OnOpen public void onOpen(Session session) { System.out.println(连接建立: session.getId()); } OnMessage public void onMessage(String message, Session session) throws IOException { System.out.println(收到消息: message); // 原样发回给客户端 session.getBasicRemote().sendText(服务器回声: message); } OnClose public void onClose(Session session) { System.out.println(连接关闭: session.getId()); } OnError public void onError(Session session, Throwable error) { System.err.println(连接 session.getId() 发生错误:); error.printStackTrace(); } }优点标准无需额外依赖适合嵌入到任何支持Java EE/Jakarta EE的容器中。缺点功能较为基础。例如广播消息需要自己维护一个ConcurrentHashMap来存储所有Session不支持直接订阅特定主题如STOMP配置心跳、消息大小限制等需要依赖容器本身的配置不够直观。实操心得使用原生API时务必在OnOpen方法中将session存入一个全局线程安全的集合如ConcurrentHashMap并在OnClose和OnError中确保将其移除。这是内存泄漏的高发区。我曾遇到过因为未正确移除失效session导致Map越来越大最终引发OutOfMemoryError的线上问题。3.2 Spring框架集成Spring WebSocket与STOMP对于Spring Boot项目绝大多数人都会选择spring-boot-starter-websocket。它封装了原生的WebSocket API提供了更强大、更易用的功能特别是与STOMP协议的集成。STOMP是什么你可以把它理解为WebSocket之上的一个“应用层协议”。WebSocket解决了“如何高效传输数据帧”的问题而STOMP定义了“这些数据帧应该是什么格式、代表什么含义”比如订阅SUBSCRIBE、发送SEND、确认ACK等。它让WebSocket通信变得像消息队列一样有了清晰的目的地和消息格式。Spring WebSocket的核心配置import org.springframework.context.annotation.Configuration; import org.springframework.messaging.simp.config.MessageBrokerRegistry; import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker; import org.springframework.web.socket.config.annotation.StompEndpointRegistry; import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer; Configuration EnableWebSocketMessageBroker // 启用WebSocket消息代理 public class WebSocketConfig implements WebSocketMessageBrokerConfigurer { Override public void registerStompEndpoints(StompEndpointRegistry registry) { // 定义WebSocket握手端点客户端通过这个URL连接 registry.addEndpoint(/ws).setAllowedOriginPatterns(*).withSockJS(); } Override public void configureMessageBroker(MessageBrokerRegistry registry) { // 启用一个简单的内存消息代理处理以“/topic”和“/queue”为前缀的消息 registry.enableSimpleBroker(/topic, /queue); // 配置客户端发送消息的目的地前缀为“/app” registry.setApplicationDestinationPrefixes(/app); } }然后你可以像写Spring MVC的Controller一样写WebSocket控制器import org.springframework.messaging.handler.annotation.MessageMapping; import org.springframework.messaging.handler.annotation.SendTo; import org.springframework.stereotype.Controller; Controller public class GreetingController { MessageMapping(/hello) // 处理发送到 /app/hello 的消息 SendTo(/topic/greetings) // 将返回值广播到 /topic/greetings public Greeting greeting(HelloMessage message) { return new Greeting(Hello, message.getName() !); } }优点高度集成与Spring Security无缝结合轻松实现连接认证和授权。消息模型清晰STOMP协议让发布-订阅、点对点消息模式变得非常简单。SockJS支持提供了优雅降级方案。当浏览器不支持WebSocket时会自动降级为轮询、长轮询等模式保证了兼容性。管理方便通过SimpMessagingTemplate可以轻松地从任何地方如Service层向客户端发送消息。缺点引入了一定的复杂性需要理解STOMP的概念。对于极其简单的双向通信可能显得“杀鸡用牛刀”。3.3 高性能选择Netty当你需要处理数十万甚至上百万的并发长连接时比如IM系统、游戏服务器原生的javax.websocket或Spring的简单代理可能就力不从心了。这时Netty几乎是唯一的选择。Netty是一个异步事件驱动的网络应用框架它允许你从更底层、更灵活地处理WebSocket协议。你需要自己编解码WebSocket帧管理连接生命周期。核心组件WebSocketServerProtocolHandlerNetty提供的Handler用于处理WebSocket握手和帧的编解码。TextWebSocketFrame/BinaryWebSocketFrame分别代表文本和二进制WebSocket帧。一个简化的Netty WebSocket服务器初始化示例import io.netty.bootstrap.ServerBootstrap; import io.netty.channel.*; import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.socket.SocketChannel; import io.netty.channel.socket.nio.NioServerSocketChannel; import io.netty.handler.codec.http.HttpObjectAggregator; import io.netty.handler.codec.http.HttpServerCodec; import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler; import io.netty.handler.stream.ChunkedWriteHandler; public class NettyWebSocketServer { public void run(int port) throws Exception { EventLoopGroup bossGroup new NioEventLoopGroup(); EventLoopGroup workerGroup new NioEventLoopGroup(); try { ServerBootstrap b new ServerBootstrap(); b.group(bossGroup, workerGroup) .channel(NioServerSocketChannel.class) .childHandler(new ChannelInitializerSocketChannel() { Override protected void initChannel(SocketChannel ch) { ChannelPipeline pipeline ch.pipeline(); // 处理HTTP请求用于握手 pipeline.addLast(new HttpServerCodec()); pipeline.addLast(new ChunkedWriteHandler()); pipeline.addLast(new HttpObjectAggregator(65536)); // 处理WebSocket握手和帧 pipeline.addLast(new WebSocketServerProtocolHandler(/ws)); // 自定义的业务逻辑处理器 pipeline.addLast(new MyWebSocketFrameHandler()); } }); ChannelFuture f b.bind(port).sync(); f.channel().closeFuture().sync(); } finally { workerGroup.shutdownGracefully(); bossGroup.shutdownGracefully(); } } }优点极致性能高并发资源消耗低完全可控。缺点开发复杂度最高需要深入理解Netty的线程模型和异步编程所有功能如心跳、会话管理、集群都需要自己实现。选择建议对于大多数业务系统管理后台、实时通知、简单聊天Spring WebSocket STOMP是平衡了功能、开发效率和社区支持的最佳选择。只有当你面临真正的性能瓶颈且团队有足够的Netty经验时才考虑直接使用Netty。4. 从零搭建一个Spring Boot WebSocket应用理论说再多不如动手做一遍。我们用一个经典的“简易群聊室”例子贯穿服务端和前端把流程走通。4.1 后端服务搭建与核心代码实现首先创建一个Spring Boot项目引入依赖dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-websocket/artifactId /dependency dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-security/artifactId !-- 用于简单认证演示 -- /dependency第一步配置类WebSocketConfig这里的配置比上面基础示例更完整一些我们加入拦截器用于记录日志和简单的权限检查。Configuration EnableWebSocketMessageBroker public class WebSocketConfig implements WebSocketMessageBrokerConfigurer { Override public void registerStompEndpoints(StompEndpointRegistry registry) { registry.addEndpoint(/chat-websocket) .setAllowedOriginPatterns(*) // 生产环境务必指定具体域名 .addInterceptors(new HttpSessionHandshakeInterceptor()) .withSockJS(); // 启用SockJS降级支持 } Override public void configureMessageBroker(MessageBrokerRegistry registry) { // 启用一个基于内存的简单消息代理负责将消息路由到订阅了 /topic 或 /user 的客户端 registry.enableSimpleBroker(/topic, /queue); // 设置应用程序目的地的前缀所有目的地以 /app 开头的消息都会被路由到带 MessageMapping 注解的方法 registry.setApplicationDestinationPrefixes(/app); // 设置点对点消息的前缀可选用于用户专属队列默认是 /user registry.setUserDestinationPrefix(/user); } // 可选配置消息转换、心跳等 Override public void configureWebSocketTransport(WebSocketTransportRegistration registration) { registration.setMessageSizeLimit(128 * 1024); // 设置消息大小限制 128KB registration.setSendTimeLimit(20 * 1000); // 设置发送超时时间 20秒 registration.setSendBufferSizeLimit(512 * 1024); // 设置发送缓冲区大小限制 512KB } }第二步消息模型简单的POJO// 客户端发送的消息 Data // 使用Lombok需引入依赖 public class ChatMessage { private MessageType type; // 枚举JOIN, CHAT, LEAVE private String sender; private String content; private String roomId; } // 服务器广播的消息 Data public class Greeting { private String content; public Greeting(String content) { this.content content; } }第三步控制器ChatControllerController Slf4j public class ChatController { // 处理用户加入聊天室 MessageMapping(/chat.addUser) SendTo(/topic/chatroom) public Greeting addUser(Payload ChatMessage chatMessage, SimpMessageHeaderAccessor headerAccessor) { // 将用户名存入WebSocket Session属性方便后续使用 headerAccessor.getSessionAttributes().put(username, chatMessage.getSender()); log.info(用户 {} 加入了聊天室, chatMessage.getSender()); return new Greeting(chatMessage.getSender() 加入了聊天); } // 处理用户发送的聊天消息 MessageMapping(/chat.sendMessage) SendTo(/topic/chatroom) public Greeting sendMessage(Payload ChatMessage chatMessage) { log.info(收到来自 {} 的消息{}, chatMessage.getSender(), chatMessage.getContent()); return new Greeting(chatMessage.getSender() : chatMessage.getContent()); } // 处理点对点消息私聊示例 MessageMapping(/chat.private.{userId}) public void sendPrivateMessage(Payload ChatMessage chatMessage, DestinationVariable String userId) { log.info(发送私聊消息给用户 {}: {}, userId, chatMessage.getContent()); // 通过 messagingTemplate 发送给特定用户 // 这里需要实现通常结合Spring Security获取当前用户 } }第四步从业务层主动推送消息WebSocket的一个强大之处是服务器可以随时主动推送。我们可以在任何Spring Bean中注入SimpMessagingTemplate来实现。Service public class NotificationService { Autowired private SimpMessagingTemplate messagingTemplate; public void broadcastSystemAlert(String alertMessage) { // 向所有订阅了 /topic/alerts 的客户端广播系统警报 messagingTemplate.convertAndSend(/topic/alerts, new Greeting([系统警报] alertMessage)); } public void notifyUser(String userId, String message) { // 向指定用户发送点对点消息消息会发往 /user/{userId}/queue/notifications messagingTemplate.convertAndSendToUser(userId, /queue/notifications, new Greeting(message)); } }4.2 前端连接与交互实战后端准备好了前端这里以原生JavaScript SockJS STOMP为例需要连接并交互。HTML部分!DOCTYPE html html head title简易群聊室/title script srchttps://cdn.jsdelivr.net/npm/sockjs-client1/dist/sockjs.min.js/script script srchttps://cdn.jsdelivr.net/npm/stomp/stompjs7.0.0/bundles/stomp.umd.min.js/script /head body div input typetext idusername placeholder输入昵称/ button onclickconnect()连接/button button onclickdisconnect() disabled iddisconnectBtn断开/button /div div input typetext idmessage placeholder输入消息/ button onclicksendMessage() disabled idsendBtn发送/button /div div idchatArea styleborder:1px solid #ccc; height:300px; overflow-y:scroll;/div script let stompClient null; let username null; function connect() { username document.getElementById(username).value.trim(); if(!username) { alert(请输入昵称); return; } // 使用SockJS作为传输层连接后端注册的端点 const socket new SockJS(http://localhost:8080/chat-websocket); stompClient Stomp.over(socket); stompClient.connect({}, function(frame) { console.log(连接成功: frame); // 启用发送按钮 document.getElementById(sendBtn).disabled false; document.getElementById(disconnectBtn).disabled false; document.getElementById(username).disabled true; // 订阅群聊广播频道 stompClient.subscribe(/topic/chatroom, function(message) { showMessage(JSON.parse(message.body).content); }); // 发送“加入”消息到后端 stompClient.send(/app/chat.addUser, {}, JSON.stringify({ type: JOIN, sender: username, content: , roomId: default })); }, function(error) { console.error(连接失败: , error); }); } function disconnect() { if (stompClient ! null) { stompClient.disconnect(); } console.log(连接已断开); document.getElementById(sendBtn).disabled true; document.getElementById(disconnectBtn).disabled true; document.getElementById(username).disabled false; } function sendMessage() { const messageContent document.getElementById(message).value.trim(); if(messageContent stompClient) { const chatMessage { type: CHAT, sender: username, content: messageContent, roomId: default }; // 发送消息到后端指定的目的地 stompClient.send(/app/chat.sendMessage, {}, JSON.stringify(chatMessage)); document.getElementById(message).value ; } } function showMessage(message) { const chatArea document.getElementById(chatArea); const p document.createElement(p); p.textContent message; chatArea.appendChild(p); chatArea.scrollTop chatArea.scrollHeight; // 自动滚动到底部 } /script /body /html这段代码清晰地展示了前端WebSocket通信的流程建立连接SockJS STOMP - 订阅频道subscribe - 发送消息send - 接收并处理消息subscribe的回调函数。通过这个例子一个具备基本功能的实时群聊就实现了。5. 生产环境关键问题与实战避坑指南把Demo跑起来只是第一步要上线还有一堆“坑”等着你。下面是我在多个项目中总结出来的核心问题和解决方案。5.1 连接数管理与资源优化WebSocket是长连接每个连接都会占用一个线程或一个事件循环和内存。连接数暴涨是首要威胁。问题表象服务器CPU或内存使用率异常升高新连接建立缓慢甚至失败可能伴随OutOfMemoryError或Too many open files错误。根因分析线程模型Tomcat等传统Servlet容器默认使用“一个连接一个线程”的BIO模型虽然NIO Connector有所改进大量空闲连接会耗尽线程资源。Session管理在内存中无限制地存储Session对象且未及时清理失效连接。心跳缺失连接僵死但未被服务器感知资源无法释放。解决方案调整容器配置以Tomcat为例在application.properties中调整WebSocket相关参数。# 增大WebSocket工作线程池适用于BIONIO下是poller线程 server.tomcat.max-threads200 # 增大HTTP升级请求即WebSocket握手请求的处理队列 server.tomcat.accept-count100 # 对于NIO Connector调整poller线程数 (在代码中通过TomcatConnectorCustomizer配置)使用Netty或Undertow对于预期连接数超过几千的场景强烈建议使用基于Netty的Spring WebFlux响应式栈或直接使用Undertow作为嵌入式服务器它们的NIO事件驱动模型能轻松应对数万并发连接。实现连接心跳与超时确保心跳机制Ping/Pong正常工作。在服务端配置WebSocketTransportRegistration时可以设置setTimeToFirstMessage和心跳间隔。对于Spring SimpleBroker可以配置心跳Override public void configureMessageBroker(MessageBrokerRegistry registry) { registry.enableSimpleBroker(/topic) .setTaskScheduler(taskScheduler) // 需要注入一个TaskScheduler .setHeartbeatValue(new long[]{10000, 10000}); // 服务器发心跳间隔客户端回应心跳间隔毫秒 }定期清理无效Session实现一个定时任务遍历你维护的Session集合检查session.isOpen()关闭并移除那些已失效的连接。5.2 集群部署与会话共享单机WebSocket服务有单点故障和容量瓶颈。一旦引入多台服务器问题来了用户A连接到了服务器1他发送的消息如何被连接到服务器2的用户B收到核心挑战WebSocket Session是服务器本地内存对象无法在集群间共享。解决方案引入外部消息代理Message Broker将发布-订阅的逻辑从内存移到外部中间件。RabbitMQ / Kafka作为外部代理这是Spring官方推荐的生产方案。不再使用enableSimpleBroker()而是配置一个全功能的外部STOMP代理。Override public void configureMessageBroker(MessageBrokerRegistry registry) { // 使用RabbitMQ作为STOMP代理 registry.enableStompBrokerRelay(/topic, /queue) .setRelayHost(rabbitmq-host) .setRelayPort(61613) // STOMP协议端口 .setClientLogin(guest) .setClientPasscode(guest) .setSystemLogin(guest) .setSystemPasscode(guest); registry.setApplicationDestinationPrefixes(/app); }工作原理所有服务器实例都连接到同一个RabbitMQ。当服务器1收到发往/topic/chat的消息时它会将消息转发给RabbitMQ。RabbitMQ负责将消息分发给所有订阅了该主题的服务器包括服务器1自己和服务器2再由各服务器推送给本地连接的客户端。这样就实现了跨服务器的消息广播。会话同步非必须对于需要跟踪“在线用户列表”这类场景Session本身不共享但在线状态信息需要共享。可以将用户登录/登出、连接建立/断开的事件发布到Redis或数据库所有服务器实例监听这些事件来维护一个全局的、最终一致的在线状态视图。5.3 安全与认证授权WebSocket连接在握手阶段仍然是HTTP请求因此可以在握手前后进行安全控制。握手拦截认证最常用的方法。在registerStompEndpoints方法中添加的拦截器HandshakeInterceptor可以在握手前beforeHandshake和握手后afterHandshake执行逻辑。通常在这里从HTTP Session或Token中获取用户信息并存入WebSocket Session的属性中。public class AuthHandshakeInterceptor implements HandshakeInterceptor { Override public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, MapString, Object attributes) throws Exception { // 从请求参数或Header中获取Token例如JWT String token ... // 解析逻辑 User user userService.validateToken(token); if (user null) { return false; // 握手拒绝 } attributes.put(user, user); // 存入属性后续可在Controller中通过 Header 或 SimpMessageHeaderAccessor 获取 return true; } // afterHandshake 方法... }Spring Security集成Spring Security提供了对WebSocket的细粒度授权支持。你可以像保护HTTP端点一样保护STOMP的目的地。Configuration EnableWebSocketSecurity public class WebSocketSecurityConfig extends AbstractSecurityWebSocketMessageBrokerConfigurer { Override protected void configureInbound(MessageSecurityMetadataSourceRegistry messages) { messages .simpDestMatchers(/app/private/**).authenticated() // 发送到/app/private/**的消息需要认证 .simpSubscribeDestMatchers(/user/queue/**, /topic/secrets/**).authenticated() // 订阅这些目的地需要认证 .anyMessage().permitAll(); } // 禁用CSRF因为WebSocket不使用Cookie进行身份验证是常见的 Override protected boolean sameOriginDisabled() { return true; } }防止CSWSH跨站WebSocket劫持这是OWASP提到的一种攻击类似CSRF。关键在于验证Origin头。在生产环境中setAllowedOriginPatterns(*)是极其危险的。必须严格限制为可信的源。registry.addEndpoint(/ws).setAllowedOriginPatterns(https://mydomain.com, https://www.mydomain.com);同时确保认证信息如Token不是通过URL参数传递容易被日志记录而是通过安全的Cookie或Header传递。5.4 常见异常排查与性能调优连接频繁断开状态码1006这是最常见的错误之一原因多样。网络问题防火墙、代理服务器、Nginx超时配置不当。检查Nginx的proxy_read_timeout,proxy_send_timeout需要设置得足够长例如proxy_read_timeout 3600s;。心跳未配置或超时服务器或客户端未发送/响应心跳导致连接被中间设备掐断。确保双方都正确配置了心跳。SockJS心跳如果使用SockJS它有自己的心跳机制默认25秒需要确保服务器能正确处理SockJS的心跳帧。消息大小限制默认情况下WebSocket消息大小有限制如Tomcat默认是8KB。发送大消息如图片、文件分片时会失败。解决方案在配置中调大限制如前文configureWebSocketTransport所示。更佳实践是大文件不应通过WebSocket传输应使用HTTP上传然后通过WebSocket传递文件ID或URL。内存泄漏除了未清理的Session集合还要注意消息积压如果客户端处理消息速度慢于服务器发送速度可能导致消息在服务器端缓冲区积压。需要监控SimpMessagingTemplate的发送队列或在客户端进行流量控制。订阅泄漏在动态订阅/取消订阅的场景下确保unsubscribe被正确调用否则服务端会持续为已失效的连接准备消息。监控与日志生产环境必须要有监控。连接数监控暴露WebSocket当前连接数的MetricsSpring Boot Actuator可以集成。消息速率监控监控消息流入流出的速率。错误日志集中收集确保OnError方法中的异常被妥善记录到日志系统便于排查。WebSocket是一个强大的工具但它把HTTP无状态、短连接的模式变成了有状态、长连接这对架构设计、资源管理和问题排查都提出了新的要求。从简单的实时通知到复杂的协同编辑理解其原理选择合适的实现方案并妥善处理上述生产环境问题你就能让WebSocket在你的Java应用中稳定、高效地运行起来。
![[光学原理与应用-521]：对光的错误理解与纠偏](http://pic.xiahunao.cn/yaotu/[光学原理与应用-521]：对光的错误理解与纠偏)
