微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

STOMP Websocket 连接立即断开

如何解决STOMP Websocket 连接立即断开

我正在尝试编写一个 Java Websocket 程序,它将侦听第三方 Web 套接字连接上的所有事件。但是一旦建立连接,我就会收到连接关闭日志。请在这里帮忙。我正在使用 Spring STOMP 处理程序:

public class WebsocketThread implements Runnable {
    @Override
    public void run() {
    WebSocketClient client = new StandardWebSocketClient();

    WebSocketStompClient stompClient = new WebSocketStompClient(client);
    stompClient.setMessageConverter(new MappingJackson2MessageConverter());


    stompClient.setMessageConverter(new MappingJackson2MessageConverter());

    String wsUrl = "wss://realtime.jive.com/ws/v2/0iEoonpIcKNHOZOwp7j2z-rJYVFiDFyAxV8jkZmW2xvcC1bbR23W1xLxf7-ZWmCbT7yMAy1kuEJYejgMZOZyUQQ";
    stompClient.connect(wsUrl,new StompSessionHandler() {

        @Override
        public void afterConnected(StompSession session,StompHeaders connectedHeaders) {
            System.out.println("Connected");
        }

        @Override
        public void handleException(StompSession session,StompCommand command,StompHeaders headers,byte[] payload,Throwable exception) {
            System.out.println("Exception " + exception);
        }

        @Override
        public void handleTransportError(StompSession session,Throwable exception) {
            System.out.println("Exception " + exception);
        }

        @Override
        public Type getPayloadType(StompHeaders headers) {
            System.out.println("Payload Type {}" + headers);
            return null;
        }

        @Override
        public void handleFrame(StompHeaders headers,Object payload) {
            System.out.println("Payload " + payload);
        }
    });

    new Scanner(system.in).nextLine();
}
}

我收到了这些日志:

    10:46:22.236 [Thread-0] DEBUG org.springframework.web.socket.client.standard.StandardWebSocketClient - Connecting to wss://realtime.jive.com/ws/v2/0iEoonpIcKNHOZOwp7j2z-rJYVFiDFyAxV8jkZmW2xvcC1bbR23W1xLxf7-ZWmCbT7yMAy1kuEJYejgMZOZyUQQ
10:46:26.521 [SimpleAsyncTaskExecutor-1] DEBUG org.springframework.messaging.simp.stomp.DefaultStompSession - Connection established in session id=d067e8ef-f358-3118-ee75-defea35a5904
10:46:27.299 [WebSocketClient-SecureIO-2] DEBUG org.springframework.messaging.simp.stomp.DefaultStompSession - Connection closed in session id=d067e8ef-f358-3118-ee75-defea35a5904
10:46:27.299 [WebSocketClient-SecureIO-2] DEBUG org.springframework.web.socket.adapter.NativeWebSocketSession - Closing StandardWebSocketSession[id=59d37a9a-9f47-2db2-8287-71dbd9f2e149,uri=null]
Exception org.springframework.messaging.simp.stomp.ConnectionLostException: Connection closed

请让我知道我在这里遗漏了什么。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。