检测internet上的websocket连接中断连接丢失stomp客户端java

import org.springframework.messaging.converter.MappingJackson2MessageConverter;
import org.springframework.messaging.simp.stomp.*;
import org.springframework.web.socket.client.standard.StandardWebSocketClient;
import org.springframework.web.socket.messaging.WebSocketStompClient;

import java.lang.reflect.Type;

public class WebSocketClientExample {
    public static void main(String[] args) throws Exception {
        String url = "ws://example.com/websocket"; // WebSocket服务器的URL

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

        StompSessionHandler sessionHandler = new StompSessionHandlerAdapter() {
            @Override
            public void afterConnected(StompSession session, StompHeaders connectedHeaders) {
                System.out.println("Connected to WebSocket");
            }

            @Override
            public void handleTransportError(StompSession session, Throwable exception) {
                System.out.println("WebSocket transport error: " + exception.getMessage());
            }

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

        StompSession stompSession = stompClient.connect(url, sessionHandler).get(); // 连接到WebSocket服务器

        // 检测连接中断
        stompSession.addDisconnectHandler(() -> {
            System.out.println("Disconnected from WebSocket");
        });

        // 检测连接丢失
        stompSession.addErrorHandler((error) -> {
            System.out.println("WebSocket error: " + error.getMessage());
        });

        // 订阅消息
        stompSession.subscribe("/topic/messages", new StompFrameHandler() {
            @Override
            public Type getPayloadType(StompHeaders headers) {
                return String.class;
            }

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

        // 发送消息
        stompSession.send("/app/sendMessage", "Hello, WebSocket!");

        Thread.sleep(5000); // 等待接收消息

        stompSession.disconnect(); // 断开WebSocket连接
    }
}