HTTP轮询的瓶颈与WebSocket优势

在实时性要求高的场景（如在线聊天、股票行情推送），传统HTTP轮询存在明显缺陷：

• 资源浪费：客户端需要不断发起请求，即使没有数据更新
• 延迟高：轮询间隔导致数据到达延迟（通常1-5秒）
• 服务端压力：大量无效请求占用连接资源

而WebSocket通过单TCP长连接实现全双工通信，但实际落地时会遇到：

• NAT超时：运营商NAT表过期导致连接中断（通常5-30分钟）
• 帧碎片化：大消息被拆分成多个帧可能引发粘包问题
• 写冲突：多线程同时向Session写数据需同步控制

技术方案对比

| 方案 | 优点 | 缺点 | 吞吐量参考（单机） | |--------------------|-----------------------------|-------------------------|----------------| | Spring WebSocket | 集成Spring生态，注解开发便捷 | 底层依赖容器实现 | 3万消息/秒 | | Tomcat原生API | 避免Spring抽象层损耗 | 需手动处理协议升级等细节 | 3.5万消息/秒 | | Netty | 自定义协议灵活，性能最优 | 学习曲线陡峭 | 10万+消息/秒 |

后端核心实现（Spring Boot）

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

    // 线程安全的Session存储
    private final ConcurrentHashMap<String, WebSocketSession> sessions = new ConcurrentHashMap<>();

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(new CustomHandler(), "/ws")
                .setAllowedOrigins("*") // 生产环境应指定具体域名
                .addInterceptors(new HttpSessionHandshakeInterceptor());
    }

    class CustomHandler extends TextWebSocketHandler {
        @Override
        protected void handleTextMessage(WebSocketSession session, TextMessage message) {
            // 处理消息（注意线程安全）
            synchronized (session) {
                session.sendMessage(new TextMessage("ECHO: " + message.getPayload()));
            }
        }

        @Override
        public void afterConnectionEstablished(WebSocketSession session) {
            sessions.put(session.getId(), session); // 记录会话
        }
    }
}

前端关键代码

let socket = new WebSocket('wss://yourdomain.com/ws');
let heartbeatInterval = null;

// 带自动重连的建立连接
function connect() {
  socket.onopen = () => {
    console.log('Connected');
    // 心跳检测（每30秒发送一次）
    heartbeatInterval = setInterval(() => {
      socket.send('HEARTBEAT');
    }, 30000);
  };

  socket.onclose = () => {
    clearInterval(heartbeatInterval);
    setTimeout(connect, 5000); // 5秒后重连
  };
}

进阶优化方案

STOMP协议简化路由

@Configuration
@EnableWebSocketMessageBroker
public class StompConfig implements WebSocketMessageBrokerConfigurer {
    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/topic"); // 客户端订阅地址前缀
        config.setApplicationDestinationPrefixes("/app"); // 服务端接收地址前缀
    }
}

WSS证书配置（Tomcat）

<Connector port="8443" protocol="org.apache.coyote.http11.Http11NioProtocol">
    <SSLHostConfig>
        <Certificate 
            certificateFile="conf/cert.pem" 
            certificateKeyFile="conf/privkey.pem"
            type="RSA" />
    </SSLHostConfig>
</Connector>

生产环境避坑指南

1. 502 Bad Gateway
2. 检查Nginx配置：proxy_read_timeout需大于心跳间隔

3. 确认负载均衡器支持WebSocket协议

4. 连接数限制

5. Linux调整文件描述符限制：

   ulimit -n 65535
   sysctl -w fs.file-max=100000

6. 内存泄漏

7. 定期检查未关闭的Session
8. 使用WeakReference存储Session对象

开放性问题

• 如何设计支持千万级连接的鉴权方案？
• 在K8s环境下如何实现WebSocket服务的优雅伸缩？
• 如何平衡心跳间隔与移动设备电量消耗？