java写websocket断线重连

在 Java 中实现 WebSocket 的断线重连可以通过以下步骤来完成：

1. 导入相关的包：

import java.net.URI;
import java.net.URISyntaxException;
import java.util.concurrent.TimeUnit;

import javax.websocket.CloseReason;
import javax.websocket.ClientEndpoint;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.WebSocketContainer;

2. 创建 WebSocket 客户端类，并实现相应的注解方法：

@ClientEndpoint
public class WebSocketClient {
    private Session session;

    @OnOpen
    public void onOpen(Session session) {
        this.session = session;
        System.out.println("WebSocket 连接已打开");
    }

    @OnMessage
    public void onMessage(String message) {
        System.out.println("收到消息：" + message);
    }

    @OnClose
    public void onClose(Session session, CloseReason reason) {
        System.out.println("WebSocket 连接已关闭：" + reason);
        // 在连接关闭时进行重连
        reconnect();
    }

    @OnError
    public void onError(Throwable throwable) {
        System.out.println("WebSocket 错误：" + throwable.getMessage());
        // 在发生错误时进行重连
        reconnect();
    }

    private void reconnect() {
        try {
            System.out.println("尝试重新连接...");
            TimeUnit.SECONDS.sleep(5); // 重新连接的延迟时间，可根据实际情况调整
            WebSocketContainer container = ContainerProvider.getWebSocketContainer();
            container.connectToServer(this, new URI("ws://your-websocket-url"));
        } catch (URISyntaxException | DeploymentException | InterruptedException e) {
            System.out.println("重新连接失败：" + e.getMessage());
            // 发生异常时进行重连
            reconnect();
        }
    }
}

3. 在需要使用 WebSocket 的地方创建 WebSocket 客户端实例并连接到服务器：

public class Main {
    public static void main(String[] args) throws URISyntaxException, DeploymentException {
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
        WebSocketClient client = new WebSocketClient();
        container.connectToServer(client, new URI("ws://your-websocket-url"));
    }
}

在上述代码中，通过 `@OnClose` 和 `@OnError` 注解来处理连接关闭和错误事件，并在这两个方法中调用 `reconnect()` 方法进行重连。`reconnect()` 方法中使用 `WebSocketContainer` 的 `connectToServer()` 方法重新连接到服务器。

需要注意的是，为了避免无限重连，`reconnect()` 方法中使用了延迟等待，以免过快地进行重连操作。你可以根据实际需求调整延迟时间。

另外，将代码中的 `"ws://your-websocket-url"` 替换为你要连接的实际 WebSocket 服务器地址。

希望以上信息对你有帮助！如有任何问题，请随时向我提问。