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 调用会失败。需配合消息队列与状态管理：
立即学习“Java免费学习笔记（深入）”；
- 维护一个
isConnected标志和待发消息队列（如数组或 Queue） - send 方法先检查状态：已连接则直接发；未连接则 push 到队列
- 重连成功后，遍历队列依次 send，并清空队列
- 可加简单去重或过期逻辑（如 60s 前的消息丢弃）
完整示例结构（关键片段）
// 不含完整类封装，聚焦 Promise + 重试核心逻辑
async function connectWithRetry(url, { maxRetries = 5, baseDelay = 1000 } = {}) {
for (let i = 0; i <= maxRetries; i++) {
try {
const ws = new WebSocket(url);
const connected = await new Promise((resolve, reject) => {
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));
}
}
} 
