HarmonyOS 6.1+ 新特性实战(24):Network Kit WebSocket心跳重连与消息补偿方案
WebSocket收到open事件只代表连接在那一刻建立,移动网络切换、代理空闲回收和应用退后台都会让链路进入半断开。可靠通信层需要同时观察心跳、消息序号和网络状态,并限制重连节奏。
方案面向HarmonyOS 6.1.1 Release SDK(API 24),系统Kit调用进入适配层,命令约束、状态归并和恢复策略进入可测试的业务层。范围包含状态与资源生命周期设计、失败恢复和验收合同,不包含业务内容生产、服务端协议改造以及特定厂商网页或媒体源的兼容承诺。

把半断开变成可观察状态
方案定义connectionId、sessionId、lastAckAt、nextSequence和expectedSequence。每次connect生成新的connectionId,旧连接的open、message、error和close回调都先比对版本。客户端心跳记录发送时间,只有服务端ack才能更新lastAckAt。
状态数量不是越多越好。每个状态必须回答三个问题:当前允许哪些命令、收到迟到事件怎样处理、页面退出后是否还可以更新UI。下面的状态对象携带operationId,新的操作开始后,旧操作回调会被拒绝。
export enum ReliableSocketState {
IDLE = 'idle',
CONNECTING = 'connecting',
OPEN = 'open',
SUSPECT = 'suspect',
RECONNECTING = 'reconnecting',
CLOSED = 'closed'
}
export interface ReliableSocketSnapshot {
state: ReliableSocketState;
progress: number;
message: string;
operationId: number;
updatedAt: number;
}
export type ReliableSocketEvent =
| { type: 'START'; operationId: number }
| { type: 'PROGRESS'; operationId: number; progress: number }
| { type: 'SUCCESS'; operationId: number }
| { type: 'FAIL'; operationId: number; message: string };
export function acceptEvent(
snapshot: ReliableSocketSnapshot,
event: ReliableSocketEvent
): boolean {
return event.type === 'START' || event.operationId === snapshot.operationId;
}
| 设计对象 | 保存内容 | 不应该保存的内容 |
|---|---|---|
| 页面状态 | 可展示阶段、进度、错误摘要 | 系统对象和页面Context |
| 适配器 | Kit实例、监听注册、资源句柄 | ArkUI组件引用 |
| 业务记录 | operationId、版本、恢复点 | 未脱敏的敏感原始数据 |
| 诊断信息 | 阶段耗时、错误码、能力检测 | Token、图片原始内容 |
心跳检测区分发送与确认
重连延迟采用指数退避并加入随机抖动,上限固定;网络不可用时停止计时,恢复后立即尝试一次。发出的业务命令携带幂等requestId,未确认消息进入有界队列。收到序号缺口时暂停增量应用,先请求补偿区间,再恢复实时流。
这套分层把系统事实和产品行为分开:Kit适配器负责获得事实,领域对象决定是否接受事件,页面只渲染快照。更换API版本或加入真机能力时,只需要替换适配器;状态归并和异常策略仍可在模拟器中重复验证。
指数退避还要加入随机抖动
下面是主题专属的接入或核心算法代码。示例刻意保留资源创建、前置条件和清理逻辑,因为高频故障往往出现在成功调用之外。
import { webSocket } from '@kit.NetworkKit';
export class ReconnectPolicy {
private attempt: number = 0;
private readonly baseMs: number = 1000;
private readonly maxMs: number = 30000;
nextDelay(randomValue: number): number {
const exponential = Math.min(this.maxMs,
this.baseMs * Math.pow(2, this.attempt));
this.attempt++;
const jitter = Math.floor(exponential * 0.2 * randomValue);
return exponential + jitter;
}
reset(): void {
this.attempt = 0;
}
}
export class SocketVersion {
private connectionId: number = 0;
begin(): number {
return ++this.connectionId;
}
accepts(id: number): boolean {
return id === this.connectionId;
}
create(): webSocket.WebSocket {
return webSocket.createWebSocket();
}
}
代码迁入业务工程时,应把错误码转换为稳定的领域错误,不让页面直接判断系统错误字符串。对于异步回调,还要在写入状态前比较operationId或资源版本;仅检查组件是否存在,无法阻止旧任务污染新页面。
消息序号用于发现缺口
| 故障输入 | 状态变化 | 恢复动作 |
|---|---|---|
| 心跳发送无ack | 进入SUSPECT | 关闭旧连接后重连 |
| 网络完全断开 | 暂停退避计时 | 等待网络恢复 |
| 收到序号缺口 | 暂停应用增量 | 请求缺失区间 |
| 旧连接迟到消息 | connectionId不匹配 | 直接丢弃 |
异常注入按钮用于稳定复现应用侧恢复路径。真实错误发生时,诊断记录同时保存错误码、权限结果、设备能力和用户可见状态;敏感原始数据不进入日志,截图只呈现与问题直接相关的结果。
前后台切换怎样保存会话意图
页面层不直接调用Kit,而是通过动作按钮驱动同一份状态模型。这样既能在系统能力可用时接真实适配器,也能在模拟器缺少硬件时验证错误页面、幂等逻辑和资源清理。
@Component
struct ReliableSocketPanel {
@State stateText: string = 'IDLE';
@State progress: number = 0;
@State logs: string[] = [];
private append(message: string): void {
const time = new Date().toLocaleTimeString();
this.logs = [`${time} ${message}`, ...this.logs].slice(0, 8);
}
private startDemo(): void {
this.stateText = 'CONNECTING';
this.progress = 20;
this.append('开始:Network Kit WebSocket可靠连接');
}
private injectFailure(): void {
this.stateText = 'CLOSED';
this.append('已注入可恢复故障');
}
build() {
Column({ space: 12 }) {
Text('Network Kit WebSocket可靠连接').fontSize(24).fontWeight(FontWeight.Bold)
Text(this.stateText).fontSize(18).fontColor('#2563EB')
Progress({ value: this.progress, total: 100 }).width('100%')
Row({ space: 12 }) {
Button('开始实验').onClick(() => this.startDemo())
Button('注入故障').onClick(() => this.injectFailure())
}
ForEach(this.logs, (item: string) => Text(item).fontSize(13))
}.padding(20).width('100%')
}
}
故障注入覆盖服务器不回心跳、Wi-Fi切蜂窝、离线三十秒、乱序消息、重复消息和前后台切换。面板显示connectionId、退避次数、最后ack、队列长度和expectedSequence;恢复后消息只应用一次,序号连续且旧连接计数不再增长。
重连成功不应立即清空未确认队列,只有服务端根据requestId确认处理后才能移除。队列达到上限时,读状态类消息可以合并,写命令应阻止继续提交并给出明确提示。TLS和认证失败不能进入无限重连;凭证失效转到需要登录,证书错误直接停止。前台恢复时先检查网络和会话有效期,再决定复用还是重建。服务端若不提供消息序号与补偿接口,客户端只能做到连接恢复,无法保证断线期间事件完整,这个边界必须体现在协议合同中。监控指标至少包括连接成功率、重连分布、心跳超时和补偿次数,单纯记录error字符串不足以判断链路质量。
验收记录至少包括SDK版本、模拟器系统版本、操作顺序、预期状态、实际状态和截图编号。快速点击、返回再进入、故障后重试和页面销毁是必测项;涉及资源的主题还要显示活动对象计数,涉及异步任务的主题要验证迟到结果不会改变当前页面。
断网与乱序故障注入验收
这套方案的技术闭环由“输入约束—状态模型—Kit适配—异常恢复—可观察验收”组成。业务状态不持有系统对象,适配器不直接操作页面,异常路径有明确的恢复动作,后续SDK升级时可以分别回归每一层。
官方资料:WebSocket相关开发文档
更多推荐



所有评论(0)