Java WebSocketClient 重连设置教程

要设置 WebSocketClient 重连，您可以使用以下步骤：

创建 WebSocketClient 实例并设置重连参数：

WebSocketClient client = new WebSocketClient();
client.setMaxIdleTimeout(5000);
client.getPolicy().setIdleTimeout(5000);
client.setConnectTimeout(1000);
client.setStopTimeout(5000);
client.setMaskInput(true);
client.setMaskOutput(true);
client.getPolicy().setMaxBinaryMessageSize(1024 * 1024 * 10);
client.getPolicy().setMaxTextMessageSize(1024 * 1024 * 10);
client.getPolicy().setMaxTextMessageBufferSize(1024 * 1024 * 10);
client.getPolicy().setMaxBinaryMessageBufferSize(1024 * 1024 * 10);
client.getPolicy().setAsyncWriteTimeout(60000);
client.setTcpNoDelay(true);
client.setWebSocketFactory(new WebSocketClientFactory());
client.setReconnectInterval(5000);

实现 WebSocketAdapter 并重写 onClose 方法，在该方法中添加重连逻辑：

public class MyWebSocketAdapter extends WebSocketAdapter {
    private WebSocketClient client;
    private URI uri;

    public MyWebSocketAdapter(URI uri, WebSocketClient client) {
        this.uri = uri;
        this.client = client;
    }

    @Override
    public void onClose(int statusCode, String reason) {
        System.out.println('Connection closed with status ' + statusCode + ' and reason: ' + reason);
        try {
            client.reconnect();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

连接 WebSocket 并设置适配器：

URI uri = new URI('ws://localhost:8080');
client.start();
client.connect(new MyWebSocketAdapter(uri, client), uri);

现在，当 WebSocket 连接关闭时，它将自动重新连接。您可以通过设置重连间隔来控制重连频率。