鸿蒙网络异常重试与断网重连实战(全局网络监听、弱网适配、请求容错)

"requestPermissions": [  {    "name": "ohos.permission.GET_NETWORK_INFO",    "reason": "监听网络状态，实现断网重连、弱网提示",    "usedScene": {      "abilities": ["EntryAbility"],      "when": "inuse"    }  }]

// common/NetMonitor.etsimport connection from '@ohos.net.connection';// 网络类型枚举export enum NetType {  NONE = 0,    // 无网络  WIFI = 1,     // Wi-Fi  CELLULAR = 2, // 移动流量  OTHER = 3     // 以太网等其他网络}type NetChangeCallback = (type: NetType, isConnected: boolean) => void;export class NetMonitor {  private static instance: NetMonitor;  private netCallbackId: number | null = null;  private callbackList: NetChangeCallback[] = [];  public currentNetType: NetType = NetType.NONE;  public isNetAvailable: boolean = false;  static getInstance(): NetMonitor {    if (!this.instance) {      this.instance = new NetMonitor();    }    return this.instance;  }  // 初始化网络监听  initMonitor() {    // 先获取当前网络状态    this.getNowNetStatus();    // 注册全局网络切换监听    this.netCallbackId = connection.on('netAvailable', (netHandle) => {      this.handleNetChange(true);    });    connection.on('netUnavailable', () => {      this.handleNetChange(false);    });  }  // 获取当前网络类型  private async getNowNetStatus() {    let netCap = await connection.getDefaultNetCapabilities();    let netType = netCap.bearerTypes[0];    this.isNetAvailable = true;    if (netType === connection.NetBearType.BEARER_WIFI) {      this.currentNetType = NetType.WIFI;    } else if (netType === connection.NetBearType.BEARER_CELLULAR) {      this.currentNetType = NetType.CELLULAR;    } else {      this.currentNetType = NetType.OTHER;    }  }  // 网络切换分发回调  private handleNetChange(available: boolean) {    this.isNetAvailable = available;    if (!available) {      this.currentNetType = NetType.NONE;    } else {      this.getNowNetStatus();    }    this.callbackList.forEach(cb => cb(this.currentNetType, this.isNetAvailable));  }  // 订阅网络变化  subscribe(cb: NetChangeCallback) {    this.callbackList.push(cb);  }  // 销毁监听（页面销毁调用）  destroy() {    if (this.netCallbackId !== null) {      connection.off('netAvailable', this.netCallbackId);      connection.off('netUnavailable');      this.netCallbackId = null;    }    this.callbackList = [];  }}

import { NetMonitor, NetType } from '../common/NetMonitor';@Entry@Componentstruct NetPage {  @State hasNet: boolean = true;  netMonitor = NetMonitor.getInstance();  aboutToAppear() {    this.hasNet = this.netMonitor.isNetAvailable;    // 订阅网络变化    this.netMonitor.subscribe((type, connect) => {      this.hasNet = connect;    });  }  aboutToDisappear() {    // 页面销毁无需销毁全局监听，全局监听在Ability统一释放  }  build() {    Column() {      if (!this.hasNet) {        // 断网占位页面        Column({ space: 15 }) {          Text("当前无网络连接")            .fontSize(20)            .fontColor("#666")          Text("请检查Wi-Fi或移动流量，点击刷新重试")            .fontSize(14)            .fontColor("#999")          Button("重新加载")            .onClick(() => this.refreshData())        }        .width('100%')        .height('100%')        .justifyContent(FlexAlign.Center)      } else {        Text("网络正常，展示业务列表数据")          .fontSize(16)      }    }  }  refreshData() {    // 重新请求页面接口  }}

// common/HttpUtil.etsimport http from '@ohos.net.http';import { NetMonitor } from './NetMonitor';// 请求配置类型interface RequestOpt {  url: string;  method: http.RequestMethod;  data?: Object;  timeout?: number;  retryCount?: number; // 最大重试次数}export class HttpUtil {  private static readonly DEF_TIMEOUT = 8000;  private static readonly DEF_RETRY = 2; // 默认重试2次  static async request(opt: RequestOpt): Promise<Object> {    const { url, method, data, timeout = this.DEF_TIMEOUT, retryCount = this.DEF_RETRY } = opt;    // 先判断全局网络    if (!NetMonitor.getInstance().isNetAvailable) {      throw new Error("无网络，请检查网络连接");    }    let curRetry = 0;    // 循环重试逻辑    while (curRetry <= retryCount) {      try {        return await this.sendHttp(url, method, data, timeout);      } catch (err) {        curRetry++;        // 达到最大重试次数，抛出异常        if (curRetry > retryCount) {          throw err;        }        // 重试间隔300ms，避免瞬间并发        await this.sleep(300);      }    }    throw new Error("请求失败，已达最大重试次数");  }  private static sendHttp(url: string, method: http.RequestMethod, data?: Object, timeout?: number): Promise<Object> {    return new Promise((resolve, reject) => {      let httpReq = http.createHttp();      httpReq.request(url, {        method: method,        extraData: data ? JSON.stringify(data) : "",        header: { "Content-Type": "application/json" },        readTimeout: timeout,        connectTimeout: timeout      }, (err, res) => {        httpReq.destroy();        if (err) {          reject(err);          return;        }        // 服务端异常状态码判定        if (res.responseCode >= 500) {          reject(new Error(`服务器异常${res.responseCode}`));          return;        }        resolve(JSON.parse(res.result as string));      })    })  }  // 延时工具  private static sleep(ms: number): Promise<void> {    return new Promise(resolve => setTimeout(resolve, ms));  }}

import { HttpUtil } from '../common/HttpUtil';import promptAction from '@ohos.promptAction';async function loadList() {  try {    let res = await HttpUtil.request({      url: "https://xxx/api/list",      method: http.RequestMethod.GET,      retryCount: 3 // 自定义最大重试3次    });    console.log("接口数据：", res);  } catch (error) {    promptAction.showToast({ message: error.message });  }}

@Entry@Componentstruct WeakNetDemo {  @State loading: boolean = false;  async submit() {    // 加载锁拦截重复请求    if (this.loading) return;    this.loading = true;    try {      await HttpUtil.request({        url: "https://xxx/api/submit",        method: http.RequestMethod.POST,        timeout: 5000 // 弱网短超时      })    } catch (e) {      promptAction.showToast({ message: "提交失败，请稍后重试" });    } finally {      this.loading = false;    }  }  build() {    Button(this.loading ? "加载中..." : "提交")      .width(200)      .backgroundColor(this.loading ? "#cccccc" : "#007DFF")      .onClick(() => this.submit())  }}