java orgjava_websocketclientWebSocketClient 设置重连

WebSocketClient 类中没有提供内置的重连机制，但可以通过在连接断开时手动重新连接来实现重连。以下是一个示例：

import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class MyWebSocketClient extends WebSocketClient {
    
    private final static int RECONNECT_INTERVAL = 5; // 重连间隔时间，单位为秒
    private ScheduledExecutorService executorService;
    
    public MyWebSocketClient(URI serverUri) {
        super(serverUri);
    }

    @Override
    public void onOpen(ServerHandshake handshakedata) {
        System.out.println("WebSocket连接已打开");
    }

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

    @Override
    public void onClose(int code, String reason, boolean remote) {
        System.out.println("WebSocket连接已关闭，原因：" + reason);
        // 连接关闭时启动重连
        executorService.schedule(() -> {
            try {
                if (!this.isOpen()) {
                    this.reconnect();
                }
            } catch (URISyntaxException e) {
                e.printStackTrace();
            }
        }, RECONNECT_INTERVAL, TimeUnit.SECONDS);
    }

    @Override
    public void onError(Exception ex) {
        System.out.println("WebSocket出现错误：" + ex.getMessage());
    }
    
    // 连接方法
    public void connect() throws URISyntaxException {
        super.connect();
        executorService = Executors.newSingleThreadScheduledExecutor();
    }
    
    // 重连方法
    public void reconnect() throws URISyntaxException {
        System.out.println("正在尝试重连...");
        this.close();
        this.connect();
    }
}

在这个示例中，当连接关闭时会启动一个定时器，在一定时间后尝试重新连接。如果连接成功，则定时器会被取消。如果连接失败，则定时器会在下一次触发时再次尝试连接。可以根据需要调整重连间隔时间