websocket断线重连需用promise封装连接过程实现await等待，配合指数退避重试、超时控制、消息队列缓存及重连后补发机制。

WebSocket 断线重连本身是异步、事件驱动的，不能直接用 await 等待连接建立成功；但可以通过 Promise 封装连接过程，让“等待连接就绪”变成可 await 的操作，再配合重试逻辑实现可控的异步重连机制。

封装 connect 为可 await 的 Promise

核心思路：创建一个 Promise，在 ws.onopen 中 resolve，在 ws.onerror 或 ws.onclose（非主动关闭时）中 reject。注意需设置超时，避免永久 pending。

• 每次调用封装函数都新建 WebSocket 实例和 Promise
• 监听 onopen → resolve(true)
• 监听 onerror 和 onclose（且 event.wasClean === false）→ reject(new Error('connect failed'))
• 启动定时器，超时后调用 ws.close() 并 reject

用 async/await + 指数退避实现重试

Promise 封装好后，可用循环 + await 实现带策略的重连。推荐使用指数退避（Exponential Backoff），避免频繁无效请求。

Alibabacloud Sdk Client Initialization For Java

在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。

下载

• 设定最大重试次数（如 5 次）和初始延迟（如 1000ms）
• 每次失败后延迟 = baseDelay * 2 ** attempt，上限建议 30s
• 用 for 循环 + await 控制流程，捕获 reject 并延时再试
• 成功则跳出循环，返回 ws 实例；失败则抛出最终错误

保持连接活跃并自动恢复发送队列

仅重连成功还不够——断线期间发出的 send 调用会失败。需配合消息队列与状态管理：

• 维护一个 isConnected 标志和待发消息队列（如数组或 Queue）
• send 方法先检查状态：已连接则直接发；未连接则 push 到队列
• 重连成功后，遍历队列依次 send，并清空队列
• 可加简单去重或过期逻辑（如 60s 前的消息丢弃）

完整示例结构（关键片段）

// 不含完整类封装，聚焦 Promise + 重试核心逻辑

async function connectWithRetry(url, { maxRetries = 5, baseDelay = 1000 } = {}) {
  for (let i = 0; i  {
        ws.onopen = () => resolve(ws);
        ws.onerror = () => reject(new Error('WebSocket error'));
        ws.onclose = (e) => {
          if (!e.wasClean) reject(new Error('Connection closed unexpectedly'));
        };
        setTimeout(() => {
          if (ws.readyState !== WebSocket.OPEN) {
            ws.close();
            reject(new Error('Connection timeout'));
          }
        }, 5000);
      });
      return connected;
    } catch (err) {
      if (i === maxRetries) throw err;
      const delay = Math.min(baseDelay * 2 ** i, 30000);
      await new Promise(r => setTimeout(r, delay));
    }
  }
}

Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南