鸿蒙本地缓存持久化全解(Preferences、ArkDB、图片缓存、过期清理策略)

// common/PreferencesUtil.etsimport preferences from '@ohos.data.preferences';import common from '@ohos.app.ability.common';const STORE_NAME = "app_global_store";export class PreferencesUtil {  private static ins: PreferencesUtil;  private dataPreferences: preferences.Preferences | null = null;  private context: common.UIAbilityContext;  static getInstance(ctx: common.UIAbilityContext): PreferencesUtil {    if (!this.ins) {      this.ins = new PreferencesUtil();      this.ins.context = ctx;    }    return this.ins;  }  // 初始化存储实例  async init() {    this.dataPreferences = await preferences.getPreferences(this.context, STORE_NAME);  }  // 存储字符串、数字、布尔、对象  async set(key: string, value: any) {    if (!this.dataPreferences) await this.init();    let saveVal: string;    if (typeof value === "object") {      saveVal = JSON.stringify(value);    } else {      saveVal = String(value);    }    await this.dataPreferences!.putSync(key, saveVal);    await this.dataPreferences!.flush();  }  // 读取数据，支持对象自动解析  async get<T>(key: string, defVal: T): Promise<T> {    if (!this.dataPreferences) await this.init();    const val = this.dataPreferences!.getSync(key, String(defVal));    try {      return JSON.parse(val) as T;    } catch (e) {      return val as unknown as T;    }  }  // 删除单条缓存  async remove(key: string) {    if (!this.dataPreferences) await this.init();    await this.dataPreferences!.deleteSync(key);    await this.dataPreferences!.flush();  }  // 清空全部缓存  async clearAll() {    if (!this.dataPreferences) await this.init();    await this.dataPreferences!.clearSync();    await this.dataPreferences!.flush();  }}

import { PreferencesUtil } from '../common/PreferencesUtil';import common from '@ohos.app.ability.common';@Entry@Componentstruct PreDemo {  ctx = getContext(this) as common.UIAbilityContext  store = PreferencesUtil.getInstance(this.ctx)  @State userInfo: any = null  aboutToAppear() {    this.loadUserCache()  }  // 写入用户信息缓存  async saveUser() {    const user = { id: 1001, name: "鸿蒙开发者", isLogin: true }    await this.store.set("user_info", user)  }  // 读取缓存用户  async loadUserCache() {    const info = await this.store.get("user_info", null)    this.userInfo = info  }  build() {    Column({ space: 15 }) {      Text(`缓存用户：${JSON.stringify(this.userInfo)}`)      Button("保存登录信息").onClick(() => this.saveUser())      Button("清除登录缓存").onClick(() => this.store.remove("user_info"))    }    .width('100%')    .height('100%')    .justifyContent(FlexAlign.Center)  }}

// common/ArkDBUtil.etsimport relationalStore from '@ohos.data.relationalStore';import common from '@ohos.app.ability.common';const DB_NAME = "app_cache_db";const DB_VERSION = 1;// 建表语句：本地历史记录表const CREATE_TABLE_SQL = `CREATE TABLE IF NOT EXISTS search_history (  id INTEGER PRIMARY KEY AUTOINCREMENT,  keyword TEXT,  create_time INTEGER,  expire_time INTEGER)`;export class ArkDBUtil {  private static ins: ArkDBUtil;  private rdbStore: relationalStore.RdbStore | null = null;  private ctx: common.UIAbilityContext;  static getInstance(ctx: common.UIAbilityContext): ArkDBUtil {    if (!this.ins) {      this.ins = new ArkDBUtil();      this.ins.ctx = ctx;    }    return this.ins;  }  // 初始化数据库并创建表  async initDB() {    const config: relationalStore.StoreConfig = {      name: DB_NAME,      securityLevel: relationalStore.SecurityLevel.S1    }    this.rdbStore = await relationalStore.getRdbStore(this.ctx, config);    await this.rdbStore.executeSql(CREATE_TABLE_SQL);  }  // 插入历史记录  async addHistory(keyword: string, expire: number) {    if (!this.rdbStore) await this.initDB();    const values: relationalStore.ValuesBucket = {      keyword: keyword,      create_time: Date.now(),      expire_time: Date.now() + expire    }    await this.rdbStore!.insert("search_history", values);  }  // 查询未过期数据，分页  async getValidHistory(page: number, size: number): Promise<any[]> {    if (!this.rdbStore) await this.initDB();    const predicates = new relationalStore.RdbPredicates("search_history")    predicates.where("expire_time > ?").bindAsLong(Date.now())    predicates.orderByDesc("create_time")    predicates.limit(size, (page - 1) * size)    const res = await this.rdbStore!.query(predicates)    let list = []    while (res.goToNextRow()) {      list.push({        id: res.getLong(0),        keyword: res.getString(1),        create_time: res.getLong(2),        expire_time: res.getLong(3)      })    }    res.close()    return list  }  // 自动清理过期缓存  async clearExpireData() {    if (!this.rdbStore) await this.initDB();    const predicates = new relationalStore.RdbPredicates("search_history")    predicates.where("expire_time < ?").bindAsLong(Date.now())    await this.rdbStore!.delete(predicates)  }  // 关闭数据库释放资源  close() {    if (this.rdbStore) {      this.rdbStore.close()      this.rdbStore = null    }  }}

import { ArkDBUtil } from '../common/ArkDBUtil';import common from '@ohos.app.ability.common';@Entry@Componentstruct DbCachePage {  ctx = getContext(this) as common.UIAbilityContext  db = ArkDBUtil.getInstance(this.ctx)  @State historyList: any[] = []  aboutToAppear() {    this.loadHistory()  }  // 添加搜索记录，缓存有效期7天  async addSearch(key: string) {    // 7天过期毫秒    const sevenDay = 7 * 24 * 60 * 60 * 1000    await this.db.addHistory(key, sevenDay)    await this.loadHistory()  }  // 加载有效历史  async loadHistory() {    // 先清理过期数据    await this.db.clearExpireData()    const list = await this.db.getValidHistory(1, 20)    this.historyList = list  }  build() {    Column({ space: 12 }) {      Button("添加搜索记录").onClick(() => this.addSearch("鸿蒙ArkTS开发"))      ForEach(this.historyList, item => {        Text(item.keyword).fontSize(16)      })    }    .width('100%')    .padding(20)  }}

// common/ImageCacheUtil.etsimport fs from '@ohos.file.fs';import common from '@ohos.app.ability.common';import http from '@ohos.net.http';import crypto from '@ohos.crypto';export class ImageCacheUtil {  private static ins: ImageCacheUtil;  private cacheDir: string = "";  private ctx: common.UIAbilityContext;  // 默认缓存有效期3天  private static EXPIRE_MS = 3 * 24 * 60 * 60 * 1000;  static getInstance(ctx: common.UIAbilityContext): ImageCacheUtil {    if (!this.ins) {      this.ins = new ImageCacheUtil();      this.ins.ctx = ctx;    }    return this.ins;  }  // 初始化缓存目录  async initDir() {    const cachePath = this.ctx.cacheDir;    this.cacheDir = `${cachePath}/img_cache`;    try {      await fs.access(this.cacheDir);    } catch (e) {      await fs.mkdir(this.cacheDir);    }  }  // url转md5文件名  private getMd5Name(url: string): string {    const md5 = crypto.createHash("md5");    md5.update(url);    return md5.digest("hex");  }  // 获取本地缓存图片路径，无缓存则下载  async getImagePath(url: string): Promise<string> {    await this.initDir();    const fileName = this.getMd5Name(url);    const filePath = `${this.cacheDir}/${fileName}`;    try {      const stat = await fs.stat(filePath);      const modifyTime = stat.mtime.getTime();      // 判断是否过期      if (Date.now() - modifyTime < ImageCacheUtil.EXPIRE_MS) {        return filePath;      } else {        // 过期删除旧文件        await fs.unlink(filePath);      }    } catch (e) {      // 文件不存在，走下载逻辑    }    // 下载图片保存本地    await this.downloadImg(url, filePath);    return filePath;  }  // 下载图片写入本地文件  private async downloadImg(url: string, savePath: string) {    return new Promise<void>((resolve, reject) => {      const httpReq = http.createHttp();      httpReq.request(url, {        method: http.RequestMethod.GET,        readTimeout: 10000      }, async (err, res) => {        if (err) {          httpReq.destroy();          reject(err);          return;        }        const file = await fs.open(savePath, fs.OpenMode.CREATE | fs.OpenMode.WRITE_ONLY);        await fs.write(file.fd, res.result as ArrayBuffer);        await fs.close(file);        httpReq.destroy();        resolve();      })    })  }  // 清空全部图片缓存  async clearAllCache() {    await this.initDir();    const files = await fs.listFile(this.cacheDir);    for (const file of files) {      await fs.unlink(`${this.cacheDir}/${file}`);    }  }}