Spring Boot中URL过长导致WebSocket连接失败问题求助

核心原因分析 #

你遇到的问题是Java WebSocket客户端（基于Jakarta WebSocket规范）默认限制了URI的最大长度，当URL超过这个阈值时，连接会被静默拒绝（无明显日志是因为默认日志级别未开启调试）。Postman能成功是因为它没有这个默认限制，或者限制值更高。

可行解决方案 #

1. 调整WebSocket容器的URI长度限制 #

StandardWebSocketClient依赖的底层容器（默认是Tomcat WebSocket）有默认的URI长度上限（Tomcat默认是8192字节）。你可以通过设置容器属性来扩大这个限制：

import jakarta.websocket.ContainerProvider;
import jakarta.websocket.WebSocketContainer;
import org.springframework.web.socket.client.standard.StandardWebSocketClient;
import org.springframework.web.socket.handler.TextWebSocketHandler;

public class WSDepthClient {

    private final StandardWebSocketClient client;

    public WSDepthClient(String url) {
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
        // 设置最大URI长度为64KB，可根据实际需求调整
        container.getProperties().put("org.apache.tomcat.websocket.maxUriLength", 65536);
        // 原有的消息缓冲区设置
        container.setDefaultMaxTextMessageBufferSize(10 * 1024 * 1024);
        client = new StandardWebSocketClient(container);
        client.execute(new DepthHandler(), url);
    }

    private class DepthHandler extends TextWebSocketHandler {

        @Override
        public void afterConnectionEstablished(WebSocketSession session) {
            System.out.println("Connection established successfully!"); 
        }

        @Override
        public void handleTransportError(WebSocketSession session, Throwable exception) {
            System.out.printf("Transport error: %s%n", exception.getMessage());
            // 打印完整堆栈，便于排查深层问题
            exception.printStackTrace();
        }

        // 其他方法...
    }
}

注意：如果你的应用使用Jetty作为底层容器，需要替换属性为jetty.websocket.maxUriLength；Undertow则对应io.undertow.websocket.max-uri-length。

2. 改用币安WebSocket的批量订阅API（推荐） #

币安官方支持通过连接后发送订阅消息的方式批量订阅多个交易对，无需将所有symbol拼在URL中，从根源上避免URL长度问题，同时支持动态调整订阅列表：

import com.fasterxml.jackson.databind.ObjectMapper;
import jakarta.websocket.ContainerProvider;
import jakarta.websocket.WebSocketContainer;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.client.standard.StandardWebSocketClient;
import org.springframework.web.socket.handler.TextWebSocketHandler;

import java.io.IOException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class WSDepthClient {

    private final StandardWebSocketClient client;
    private final List<String> targetSymbols;

    public WSDepthClient(List<String> targetSymbols) {
        this.targetSymbols = targetSymbols;
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
        container.setDefaultMaxTextMessageBufferSize(10 * 1024 * 1024);
        client = new StandardWebSocketClient(container);
        // 连接基础端点，无需携带symbol参数
        client.execute(new DepthHandler(), "wss://stream.binance.com/stream");
    }

    private class DepthHandler extends TextWebSocketHandler {

        private final ObjectMapper objectMapper = new ObjectMapper();

        @Override
        public void afterConnectionEstablished(WebSocketSession session) throws IOException {
            System.out.println("Connection established successfully!");
            // 构造批量订阅消息
            Map<String, Object> subscribeRequest = new HashMap<>();
            subscribeRequest.put("method", "SUBSCRIBE");
            // 转换为币安要求的格式：symbol@depth
            List<String> subscribeParams = targetSymbols.stream()
                    .map(symbol -> symbol + "@depth")
                    .toList();
            subscribeRequest.put("params", subscribeParams);
            subscribeRequest.put("id", 1); // 请求ID，可自定义

            // 发送订阅消息
            session.sendMessage(new TextMessage(objectMapper.writeValueAsString(subscribeRequest)));
        }

        @Override
        public void handleTransportError(WebSocketSession session, Throwable exception) {
            System.out.printf("Transport error: %s%n", exception.getMessage());
            exception.printStackTrace();
        }

        @Override
        protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
            // 处理收到的深度数据
            System.out.println("Received depth update: " + message.getPayload());
        }
    }
}

这种方式的优势：

• 彻底规避URL长度限制
• 支持后续动态添加/取消订阅（发送UNSUBSCRIBE消息即可）
• 符合币安WebSocket API的最佳实践

3. 拆分连接（备选方案） #

如果上述两种方式都无法实施，可以将300个symbol分成多组（比如每组200个），建立多个独立的WebSocket连接，确保每个URL的长度在客户端限制范围内。

排查辅助建议 #

• 开启WebSocket相关日志：在application.properties中添加以下配置，查看连接过程中的详细错误信息：

  logging.level.org.springframework.web.socket=DEBUG
  logging.level.jakarta.websocket=DEBUG
  

• 验证URL实际长度：计算拼接后的URL字节数，确认是否超过容器默认限制（Tomcat默认8192字节）。

内容的提问来源于stack exchange，提问作者Abubakr Shoaliev