闭包在WebSocket心跳检测中核心作用是捕获并持久化定时器ID、连接状态、重连次数等私有变量，避免全局污染且使心跳逻辑与特定连接实例绑定。
闭包在 WebSocket 心跳检测中，核心作用是**捕获并持久化定时器 ID、连接状态、重连次数等私有变量**，避免全局污染，同时让心跳逻辑与特定连接实例绑定。关键不是“用闭包实现心跳”，而是用闭包把心跳相关的状态和控制逻辑封装在 WebSocket 实例的作用域内。
用闭包封装心跳定时器和状态
每次新建 WebSocket 连接时，通过立即执行函数（IIFE）或工厂函数创建一个独立的作用域，把 heartbeatTimer、isAlive、retryCount 等变量封闭其中，外部无法直接修改，但心跳发送/响应逻辑可安全访问：
function createHeartbeatManager(ws) {
let heartbeatTimer = null;
let isAlive = false;
let retryCount = 0;
const MAX_RETRY = 3;
function startHeartbeat() {
// 发送 ping
if (ws.readyState === WebSocket.OPEN) {
ws.send(JSON.stringify({ type: 'ping' }));
isAlive = false; // 等待 pong 响应
}
heartbeatTimer = setTimeout(() => {
if (!isAlive) {
console.warn('WebSocket heartbeat timeout');
ws.close();
if (retryCount < MAX_RETRY) {
retryCount++;
reconnect();
}
} else {
isAlive = false; // 重置，等待下一次 pong
}
}, 30000); // 30s 超时
}
function handlePong() {
isAlive = true;
}
function stopHeartbeat() {
if (heartbeatTimer) clearTimeout(heartbeatTimer);
}
// 暴露可控接口
return {
start: startHeartbeat,
pong: handlePong,
stop: stopHeartbeat,
resetRetry: () => { retryCount = 0; }
};
}
// 使用示例
const ws = new WebSocket('wss://example.com');
const hb = createHeartbeatManager(ws);
ws.onopen = () => {
hb.start();
};
ws.onmessage = (e) => {
const data = JSON.parse(e.data);
if (data.type === 'pong') hb.pong();
};
ws.onclose = () => {
hb.stop();
hb.resetRetry();
};
闭包确保每个连接独立维护心跳状态
多个 WebSocket 实例共存时（如多房间、多服务），每个调用 createHeartbeatManager(ws) 都会生成**全新的一组闭包变量**。A 连接的心跳超时不会影响 B 连接的 retryCount 或 heartbeatTimer，从根本上避免状态交叉干扰。
- 不用全局变量或单例管理多个连接的心跳
- 连接销毁后，闭包内变量随作用域被 GC 回收（前提是无其他引用）
- 重连时可复用同一闭包管理器，只需重置内部状态
注意闭包与事件监听器的生命周期匹配
闭包本身不会导致内存泄漏，但若事件监听器（如 ws.onmessage）引用了闭包外的大对象，或未及时解绑，可能阻止 GC。务必保证：
当用户要求为 Java 代码添加注释、修改注释、审查注释、整理注释格式，或要求按照代码注释规范处理 Java 文件时，使用本技能。本技能用于统一生成和维护 Java 类注释模板、按 Git 对比 release 判断版本号、补充每行代码上方中文块注释、调整注释空行规则，并保持 Java 文件 UTF-8 无 BOM 编码。典型触发场景包括：补充类注释、更新 @version、检查 @author 来源、整理行尾注释、把注释放到代码上一行、检查注释是否符合规范、构建前检查 Java 注释风格。
立即学习“Java免费学习笔记（深入）”；
- 心跳管理器的生命周期与 WebSocket 实例一致：连接关闭时调用
stop() - 避免在
onmessage中创建新闭包并长期持有（例如频繁setTimeout未清理） - 使用箭头函数或绑定
this时，确认不意外延长作用域链
更简洁的写法：用类 + 私有字段（ES2022+）
如果环境支持，可用类语法替代显式闭包，语义更清晰，且私有字段（#）天然提供封装：
class WebSocketHeartbeat {
#ws;
#timer = null;
#isAlive = false;
#retryCount = 0;
constructor(ws) {
this.#ws = ws;
}
start() {
this.#sendPing();
this.#timer = setInterval(() => {
if (!this.#isAlive) {
this.#ws.close();
if (this.#retryCount < 3) {
this.#retryCount++;
this.#reconnect();
}
} else {
this.#isAlive = false;
}
}, 30000);
}
pong() {
this.#isAlive = true;
}
stop() {
if (this.#timer) clearInterval(this.#timer);
}
#sendPing() {
if (this.#ws.readyState === WebSocket.OPEN) {
this.#ws.send(JSON.stringify({ type: 'ping' }));
}
}
}
本质仍是闭包思想——私有字段被限制在实例作用域内，外部不可见、不可篡改。
