springboot websocket 重连

为了实现WebSocket重连，我们可以使用JavaScript的WebSocket API。在客户端，我们可以使用以下代码来实现WebSocket的重连：

var ws;

function connect() {
    ws = new WebSocket("ws://localhost:8080/ws");
    ws.onopen = function() {
        console.log("WebSocket connected");
    };
    ws.onclose = function() {
        console.log("WebSocket disconnected");
        setTimeout(function() {
            connect();
        }, 5000);
    };
    ws.onerror = function() {
        console.log("WebSocket error");        ws.close();
    };
}

connect();

在上面的代码中，我们定义了一个名为connect的函数，该函数用于创建WebSocket连接。如果连接成功，我们将在控制台中打印一条消息。如果连接关闭，我们将等待5秒钟，然后尝试重新连接。如果连接出现错误，我们将关闭WebSocket连接。

在服务器端，我们需要实现一个WebSocketHandler，该处理程序将处理WebSocket连接。以下是一个简单的WebSocketHandler实现，它将向客户端发送当前时间戳：

@Component
public class MyWebSocketHandler extends TextWebSocketHandler {

    @Override
    public void handleTextMessage(WebSocketSession session, TextMessage message) throws IOException {
        session.sendMessage(new TextMessage("Current timestamp: " + System.currentTimeMillis()));
    }
}

在上面的代码中，我们定义了一个名为MyWebSocketHandler的类，该类继承自TextWebSocketHandler。我们重写了handleTextMessage方法，该方法将在收到文本消息时被调用。在该方法中，我们向客户端发送当前时间戳。

为了启用WebSocket支持，我们需要在Spring Boot应用程序中添加@EnableWebSocket注解。以下是一个简单的Spring Boot应用程序，它启用了WebSocket支持：

@SpringBootApplication
@EnableWebSocket
public class WSServerApplication {

    public static void main(String[] args) {
        SpringApplication.run(WSServerApplication.class, args);
    }

    @Bean
    public WebSocketHandler myWebSocketHandler() {
        return new MyWebSocketHandler();
    }

    @Bean
    public WebSocketHandlerDecoratorFactory webSocketHandlerDecoratorFactory() {
        return new WebSocketHandlerDecoratorFactory() {
            @Override
            public WebSocketHandler decorate(WebSocketHandler handler) {
                return new WebSocketHandlerDecorator(handler) {
                    @Override
                    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
                        super.afterConnectionEstablished(session);
                        session.setTextMessageSizeLimit(1024 * 1024);
                        session.setBinaryMessageSizeLimit(1024 * 1024);
                    }
                };
            }
        };
    }
}

在上面的代码中，我们定义了一个名为WSServerApplication的类，该类使用@SpringBootApplication和@EnableWebSocket注解启用了WebSocket支持。我们还定义了一个名为myWebSocketHandler的bean，该bean将处理WebSocket连接。我们还定义了一个名为webSocketHandlerDecoratorFactory的bean，该bean将设置WebSocket会话的文本消息大小限制和二进制消息大小限制。