WebSocket收到open事件只代表连接在那一刻建立,移动网络切换、代理空闲回收和应用退后台都会让链路进入半断开。可靠通信层需要同时观察心跳、消息序号和网络状态,并限制重连节奏。

方案面向HarmonyOS 6.1.1 Release SDK(API 24),系统Kit调用进入适配层,命令约束、状态归并和恢复策略进入可测试的业务层。范围包含状态与资源生命周期设计、失败恢复和验收合同,不包含业务内容生产、服务端协议改造以及特定厂商网页或媒体源的兼容承诺。

Network Kit WebSocket心跳重连与消息补偿方案架构方案图

把半断开变成可观察状态

方案定义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相关开发文档

Logo

讨论HarmonyOS开发技术,专注于API与组件、DevEco Studio、测试、元服务和应用上架分发等。

更多推荐