【发布时间】：2018-02-06 10:39:37
【问题描述】：
我正在尝试连接到网络套接字wss://ws-feed.gdax.com
我已经在 JavaScript (See here) 中完成了这项工作，但我正在尝试将连接服务器端移动到我的 Spring Boot 应用程序中。
到目前为止我有：
@SpringBootApplication
public class DemoApplication implements CommandLineRunner {
private Logger LOG = LoggerFactory.getLogger(DemoApplication.class);
public static void main(String[] args) {
SpringApplication.run(DemoApplication.class, args);
}
@Override
public void run(String... args) throws Exception {
WebSocketContainer container = ContainerProvider.getWebSocketContainer();
container.setDefaultMaxTextMessageBufferSize(64*1024);
WebSocketClient simpleWebSocketClient = new StandardWebSocketClient(container);
List<Transport> transports = new ArrayList<>(1);
transports.add(new WebSocketTransport(simpleWebSocketClient));
SockJsClient sockJsClient = new SockJsClient(transports);
WebSocketStompClient stompClient = new WebSocketStompClient(sockJsClient);
stompClient.setMessageConverter(new MappingJackson2MessageConverter());
LOG.info("Connecting To [wss://ws-feed.gdax.com]");
StompSession session = stompClient.connect("wss://ws-feed.gdax.com", new GDAXHandler()).get();
}
private class GDAXHandler extends WebSocketHttpHeaders implements StompSessionHandler {
@Override
public void afterConnected(StompSession session, StompHeaders connectedHeaders) {
LOG.info("Connected");
String payload = "{\"type\": \"subscribe\",\"channels\":[{\"name\": \"ticker\",\"product_ids\": [\"ETH-EUR\"]}]\"}";
LOG.info("Sending [" + payload + "]");
session.send("/", payload);
}
@Override
public void handleException(StompSession session, StompCommand command, StompHeaders headers, byte[] payload, Throwable exception) {
LOG.error("Exception", exception);
}
@Override
public void handleTransportError(StompSession session, Throwable exception) {
LOG.error("Transport Error", exception);
}
@Override
public Type getPayloadType(StompHeaders headers) {
return String.class;
}
@Override
public void handleFrame(StompHeaders headers, Object payload) {
LOG.info("Frame [" + payload + "]");
}
}
}
如果我运行这个应用程序，输出是：
INFO Tomcat 在端口启动：8080 (http)
INFO 连接到 [wss://ws-feed.gdax.com]
INFO 启动 ApplicationContext 时出错。要显示自动配置报告，请在启用“调试”的情况下重新运行您的应用程序。
错误传输错误 org.springframework.messaging.simp.stomp.ConnectionLostException：连接关闭
原因： org.springframework.messaging.simp.stomp.ConnectionLostException： 连接关闭于 org.springframework.messaging.simp.stomp.DefaultStompSession.afterConnectionClosed(DefaultStompSession.java:487) ~[spring-messaging-4.3.13.RELEASE.jar:4.3.13.RELEASE] 在 org.springframework.web.socket.messaging.WebSocketStompClient$WebSocketTcpConnectionHandlerAdapter.afterConnectionClosed(WebSocketStompClient.java:354) ~[spring-websocket-4.3.13.RELEASE.jar:4.3.13.RELEASE] 在 org.springframework.web.socket.sockjs.client.AbstractClientSockJsSession.afterTransportClosed(AbstractClientSockJsSession.java:324) ~[spring-websocket-4.3.13.RELEASE.jar:4.3.13.RELEASE] 在 org.springframework.web.socket.sockjs.client.WebSocketTransport$ClientSockJsWebSocketHandler.afterConnectionClosed(WebSocketTransport.java:172) ~[spring-websocket-4.3.13.RELEASE.jar:4.3.13.RELEASE] ...
它甚至从未达到Connected 状态。我做错了什么？
【问题讨论】：
-
尝试直接使用
WebSocketClient，不要换行到WebSocketStompClient。根据您的 JavaScript 示例，只有普通的 WebSocket 交互，没有任何 STOMP 子协议。 -
@ArtemBilan 太棒了！我完全误解了 STOMP 是什么。
标签： java spring websocket stomp spring-websocket