harmonyos中实现低延迟实时通信必须使用websocket而非http轮询，需先在module.json5中声明ohos.permission.internet权限，再导入@ohos.net.websocket模块；创建连接前须绑定open、message、error、close事件回调；connect()返回promise并依赖服务端返回http 101确认握手；发送支持json字符串或arraybuffer，接收需按类型解析；断线重连需手动实现心跳机制与定时器清理。
在HarmonyOS应用中实现聊天消息秒回、股价实时刷新或协同编辑等场景，必须用WebSocket建立持久双向通道，不能靠轮询HTTP——每次HTTP请求都重建TCP连接，300ms延迟起步，而WebSocket一次握手后全程复用连接，端到端延迟压到20ms内。
初始化WebSocket客户端并申请必要权限
第一步打开module.json5文件，在requestPermissions数组里添加互联网权限声明：
"ohos.permission.INTERNET"
这一步漏掉会导致connect()直接失败且无明确报错，只在Log中输出“Network permission denied”——【没有该权限，createWebSocket()能执行但后续所有网络操作均静默拒绝】。
接着在ArkTS代码顶部导入模块：
import websocket from '@ohos.net.websocket';
创建连接对象并绑定事件监听
调用createWebSocket()生成实例，立即为关键生命周期事件注册回调：
const ws = websocket.createWebSocket();
ws.on('open', () => { console.info('WebSocket已连接'); });
ws.on('message', (err, data) => { if (!err) { console.info('收到服务器消息:', data); } });
ws.on('error', (err) => { console.error('WebSocket错误:', err.code, err.message); });
ws.on('close', () => { console.info('连接已关闭'); });
注意：必须在connect()前完成on()绑定，否则open或message事件会丢失——鸿蒙的事件分发机制不缓存未订阅前的事件。
发起连接并处理握手结果
使用connect()方法传入ws协议地址：
ws.connect('ws://your-server.com/chat', { header: { 'X-App-Version': '1.2.0' } });
该方法返回Promise.then()捕获连接结果：
WebSocket 8.18.2 是该协议规范的一个重要迭代版本，主要优化了连接稳定性与数据传输效率。它通过全双工通信机制，允许客户端与服务器在单一长连接上实时交换数据，大幅降低传统 HTTP 轮询的开销。该版本增强了心跳保活、自动重连及二进制帧传输能力，适用于即时通讯、在线游戏及金融行情推送等低延迟场景，为开发者提供更可靠的实时网络交互基础。
ws.connect('ws://your-server.com/chat').then((success) => { if (success) { console.info('升级请求已发出'); } else { console.warn('连接参数异常，未发起握手'); } });
真正决定成败的是服务器响应：若返回HTTP 101状态码，触发open回调；若返回200，则视为普通HTTP请求，open永远不会触发——【服务端未正确实现WebSocket握手时，客户端只会安静等待，不会报错】。
发送与接收结构化数据
方法一：发送JSON字符串（推荐）
ws.send(JSON.stringify({ type: 'chat', to: 'user_123', content: '你好' }));
方法二：发送ArrayBuffer（适合二进制流）
const encoder = new TextEncoder(); const data = encoder.encode('binary payload'); ws.send(data.buffer);
接收端需主动解析：
ws.on('message', (err, data) => { if (typeof data === 'string') { const msg = JSON.parse(data); // 处理文本消息 } else if (data instanceof ArrayBuffer) { const decoder = new TextDecoder(); const text = decoder.decode(data); // 处理二进制转文本 } });
断线重连与心跳保活
第一步：监听close事件启动重连逻辑
let reconnectTimer; ws.on('close', () => { clearTimeout(reconnectTimer); reconnectTimer = setTimeout(() => { ws.connect('ws://your-server.com/chat'); }, 3000); });
第二步：手动实现心跳（鸿蒙未内置自动心跳）
let heartbeatInterval; ws.on('open', () => { heartbeatInterval = setInterval(() => { ws.send(JSON.stringify({ type: 'ping' })); }, 25000); });
第三步：收到pong响应时重置超时计时器
ws.on('message', (err, data) => { const msg = typeof data === 'string' ? JSON.parse(data) : {}; if (msg.type === 'pong') { clearInterval(heartbeatInterval); heartbeatInterval = setInterval(() => { ws.send(JSON.stringify({ type: 'ping' })); }, 25000); } });
第四步：连接异常时清除定时器
ws.on('error', () => { clearInterval(heartbeatInterval); });
