鸿蒙网络请求全栈封装|统一拦截器、Token自动续期、异常重试、弱网缓存、全局报错处理

// config/HttpConfig.etsexport default class HttpConfig {  // 正式/测试地址  public static BASE_URL: string = "https://xxx.com/api"  // 超时时间 10s  public static TIME_OUT: number = 10000  // 重试次数  public static RETRY_COUNT: number = 2  // 重试间隔  public static RETRY_DELAY: number = 800}

// store/TokenStore.etsimport AppStorage from '@ohos.appstorage'export class TokenUtil {  // 获取Token  staticgetToken(): string {    return AppStorage.get('token') || ''  }  // 设置Token  staticsetToken(token: string) {    AppStorage.setOrCreate('token', token)  }  // 清除Token  staticclearToken() {    AppStorage.delete('token')  }}

// utils/HttpRequest.etsimport http from '@ohos.net.http'import promptAction from '@ohos.promptAction'import HttpConfig from '../config/HttpConfig'import { TokenUtil } from '../store/TokenStore'// 存储当前请求队列（用于取消重复请求）const pendingRequest: Set<string> = new Set()// 基础请求封装async function request<T>(  url: string,  method: http.RequestMethod,  data?: Object,  header?: Object): Promise<T> {  // 1. 请求唯一key防抖  const reqKey = url + JSON.stringify(data)  if (pendingRequest.has(reqKey)) {    return Promise.reject("重复请求已拦截")  }  pendingRequest.add(reqKey)  // 2. 创建请求实例  const httpRequest = http.createHttp()  // 3. 统一请求头  const headers: Object = {    'Content-Type': 'application/json;charset=UTF-8',    'token': TokenUtil.getToken(),    ...header  }  // 4. 请求配置  const option: http.HttpRequestOptions = {    method: method,    header: headers,    readTimeout: HttpConfig.TIME_OUT,    connectTimeout: HttpConfig.TIME_OUT,    extraData: data  }  try {    // 5. 发起请求    const res = await httpRequest.request(HttpConfig.BASE_URL + url, option)    pendingRequest.delete(reqKey)    httpRequest.destroy()    // 6. 统一解析后端返回格式    const result: any = JSON.parse(res.result.toString())    // 7. 业务状态码拦截    if (result.code === 200) {      return result.data    } else if (result.code === 401) {      // Token过期触发续期      return refreshToken(() => request(url, method, data, header))    } else {      promptAction.showToast({ message: result.msg || "请求失败" })      return Promise.reject(result)    }  } catch (err) {    pendingRequest.delete(reqKey)    httpRequest.destroy()    promptAction.showToast({ message: "网络异常，请检查网络" })    return Promise.reject(err)  }}

// 全局锁：防止多次同时刷新let isRefreshing: boolean = falseasync function refreshToken(callback: Function) {  if (isRefreshing) return  isRefreshing = true  try {    // 1. 请求刷新Token接口    const res = await request<any>('/user/refresh', http.RequestMethod.POST, {      refreshToken: TokenUtil.getToken()    })    // 2. 保存新Token    TokenUtil.setToken(res.token)    // 3. 重发之前失败的接口    return callback()  } catch (e) {    // 刷新失败 → 清空登录态、跳转登录    TokenUtil.clearToken()    promptAction.showToast({ message: "登录已过期，请重新登录" })  } finally {    isRefreshing = false  }}

async function retryRequest<T>(fn: ()=>Promise<T>, count = 0):Promise<T> {  try {    return await fn()  } catch (e) {    if(count < HttpConfig.RETRY_COUNT){      // 延迟重试      await new Promise(res=>setTimeout(res, HttpConfig.RETRY_DELAY))      return retryRequest(fn, count + 1)    }    return Promise.reject(e)  }}

export function get<T>(url: string, data?: Object): Promise<T> {  return retryRequest(()=> request(url, http.RequestMethod.GET, data))}export function post<T>(url: string, data?: Object): Promise<T> {  return retryRequest(()=> request(url, http.RequestMethod.POST, data))}

// api/IndexApi.etsimport {get, post} from '../utils/HttpRequest'// 首页数据export const getHomeData = (params: any) => get('/home/data', params)// 登录export const loginApi = (params: any) => post('/user/login', params)// 提交表单export const submitFormApi = (params: any) => post('/form/submit', params)

aboutToDisappear(){  pendingRequest.clear()}