淦!——我的Harmony OS for PC首秀——必须做开源

这是鸿蒙PC的正式上架的打字应用，相对来说的前瞻性还是有的，做成开源也是为了让更多的创意，点子放进来，有想法我来逐步的完善这款应用，希望可以帮助到更多的刚入门的技术人员们，毕竟现在技术人员绝对不止一个亿了，用电脑的人们会更加的多，我也不想着给我自己创造什么价值，最好的就是让所有人都有进步，毕竟，我们祖国的目标是人人如龙。

开源地址：https://gitcode.com/feng8403000/shifudazi

一、环境说明与基础技术点说明

开发环境：DevEco Studio 6.0.1

SDK版本：HarmonyOS Next (API 21)

编程语言：ArkTS (TypeScript)

UI框架：ArkUI

存储：关系型数据库 (RelationalStore)

多线程：Worker (用于处理复杂的后台统计计算)

RelationalStore说明

大家对【RelationalStore】可能不熟悉：

RelationalStore 是鸿蒙（HarmonyOS）系统原生提供的关系型数据库模块，隶属于 ArkData（方舟数据管理），基于 SQLite 引擎构建，为应用提供结构化数据的持久化、事务、加密、分布式同步等能力。

HarmonyOS 系统级数据持久化方案之一，包路径为【@ohos.data.relationalStore】，是关系型数据管理的标准 API。

底层依赖：基于 SQLite，兼容 SQL 语法，同时针对鸿蒙设备做了轻量优化与安全增强。

使用环境：面向结构化数据（如订单、聊天记录、用户信息），支持表结构、JOIN 查询、事务、索引、加密、分布式同步与向量检索等。

其它数据库解决方案对比：

方案	数据模型	适用场景	核心优势
RelationalStore	关系型表	复杂结构化数据、事务、跨设备同步	完整 SQL 能力、事务保障、分布式支持
Preferences	键值对	简单配置（如主题、音量）	轻量、内存缓存、快速读写
KV-Store	键值对	非结构化 / 半结构化数据	分布式能力强、跨设备同步简单。

RelationalStore 基础使用示例：

这是一套基础的使用代码，可以参考使用，在线仓库里有具体的使用示例。

import relationalStore from '@ohos.data.relationalStore';

// 1. 配置与获取数据库实例
const storeConfig = {
  name: 'user_db.db',
  securityLevel: relationalStore.SecurityLevel.S1
};
let rdbStore: relationalStore.RdbStore | null = null;

relationalStore.getRdbStore(storeConfig, (err, store) => {
  if (err) {
    console.error(`获取数据库失败: ${err.message}`);
    return;
  }
  rdbStore = store;

  // 2. 建表（用户表）
  const createTableSql = `
    CREATE TABLE IF NOT EXISTS users (
      id INTEGER PRIMARY KEY AUTOINCREMENT,
      name TEXT NOT NULL,
      age INTEGER
    )
  `;
  rdbStore.executeSql(createTableSql, (err) => {
    if (err) {
      console.error(`建表失败: ${err.message}`);
      return;
    }

    // 3. 插入数据
    const values = { name: '张三', age: 25 };
    rdbStore.insert('users', values, (err, rowId) => {
      if (err) {
        console.error(`插入失败: ${err.message}`);
        return;
      }
      console.log(`插入成功，行ID: ${rowId}`);
    });
  });
});

注：

单条数据建议不超过 2MB，避免性能下降。

数据库操作建议异步执行，避免阻塞主线程。

多线程：Worker 说明

在鸿蒙（HarmonyOS）应用开发中，Worker 是用于实现多线程并发处理的核心机制，其设计目标是将耗时任务（如数据计算、文件解析、网络请求）从主线程（UI 线程）剥离，避免主线程阻塞导致的界面卡顿。

概念	说明
主线程	负责 UI 渲染、事件响应，禁止执行耗时操作（单次阻塞超过 50ms 会触发卡顿检测）。
Worker 线程	独立于主线程的后台线程，可执行耗时任务，不能直接操作 UI 组件。
通信机制	主线程与 Worker 线程通过消息传递交互（序列化数据），支持双向通信。
线程隔离	Worker 线程有独立的上下文，无法访问主线程的变量、对象和 UI API。

本项目采用的是内置 Worker，相对优势下标可见，毕竟我没有写跨模块与跨应用，所以单应用内容使用内置 Worker 是最为合适的了。

特性	内置 Worker（本项目）	外置 Worker
文件位置	项目内部 `entry/ets/workers/`	单独的 HAR 包或共享库
引用方式	`entry/ets/workers/TypingWorker.ts`	`'@bundle:bundleName/moduleName/ets/workers/xxx'`
打包方式	随主应用打包	独立打包，可复用
适用场景	单应用内部使用	多模块/跨应用共享

内置 Worker，ArkTS 示例：

完整开发流程分为主线程创建 Worker、Worker 线程处理任务、双向通信、销毁 Worker 四步。

主线程侧代码：

import worker from '@ohos.worker';

// 1. 创建Worker实例（指定Worker脚本路径）
const workerInstance = new worker.ThreadWorker('entry/ets/workers/MyWorker.ts');

// 2. 接收Worker线程的消息
workerInstance.onmessage = (e) => {
  console.log(`主线程接收结果: ${JSON.stringify(e.data)}`);
  // 处理结果（如更新UI）
  // 注意：主线程可操作UI，Worker线程不可
};

// 3. 监听Worker错误
workerInstance.onerror = (err) => {
  console.error(`Worker错误: ${err.message}`);
};

// 4. 向Worker线程发送任务数据
const taskData = {
  type: 'calculate',
  data: [1, 2, 3, 4, 5]
};
workerInstance.postMessage(taskData);

// 5. 任务完成后销毁Worker（避免内存泄漏）
const destroyWorker = () => {
  workerInstance.terminate();
};

Worker 线程侧代码：

// Worker线程的全局对象是 workerPort，而非 window
import worker, { ThreadWorkerGlobalScope, MessageEvents } from '@ohos.worker';

// 获取Worker全局作用域
const workerPort: ThreadWorkerGlobalScope = worker.workerPort;

// 监听主线程发送的消息
workerPort.onmessage = (e: MessageEvents) => {
  const { type, data } = e.data;
  if (type === 'calculate') {
    // 执行耗时任务：计算数组元素的累加和
    const sum = data.reduce((a: number, b: number) => a + b, 0);
    // 向主线程返回结果
    workerPort.postMessage({ result: sum });
  }
};

// 监听错误
workerPort.onerror = (err) => {
  console.error(`Worker内部错误: ${err.message}`);
};

API 与通信规则

主线程 API	作用
`new ThreadWorker(scriptPath)`	创建 Worker 实例
`postMessage(data)`	向 Worker 发送数据（支持 JSON、ArrayBuffer 等可序列化类型）
`onmessage`	接收 Worker 的消息回调
`terminate()`	主动销毁 Worker，释放资源

Worker 线程 API	作用
`workerPort.postMessage(data)`	向主线程发送结果
`workerPort.onmessage`	接收主线程的任务指令
`workerPort.close()`	Worker 内部主动关闭线程

注：

支持可序列化数据：基本类型（number/string/boolean）、JSON 对象、ArrayBuffer、TypedArray。

不支持：函数、DOM 对象、循环引用对象、鸿蒙 UI 组件对象。

单个应用最多创建 8 个 Worker 线程，超出会抛出异常。

避免创建过多 Worker，建议通过任务队列复用线程。