系列数据架构篇·第31篇。有金融行业的读者问“之前的分布式数据对象DDO虽然好用但那是内存级的断电就没了。如果我要做一个跨设备的记账App数据怎么持久化怎么保证手机记的账和手表看到的一致” 这触及了鸿蒙分布式架构的核心难点。今天我们将电商Demo的后台数据层升级引入分布式数据库Distributed Data Store, DDS实现一个支持CRDT无冲突复制数据类型的跨设备账本。我们将解决网络分区、数据冲突、离线写入三大分布式难题。全程基于API23含官方文档未涉及的“最终一致性”调优参数。一、前言为什么DDO不够用必须用DDS在之前的分布式流转篇中我们使用了DistributedDataObjectDDO。它适合临时状态同步如购物车、播放进度但不适合持久化数据存储。特性DistributedDataObject (DDO)Distributed Data Store (DDS)生命周期随Ability销毁而消失持久化存储重启不丢失数据模型JS对象简单直观数据库表支持复杂查询一致性最终一致无冲突解决机制CRDT/LastWriteWin可控性强适用场景购物车、游戏状态记账本、备忘录、联系人核心痛点用户在手表上离线记了一笔账手机没开机。等手机联网后这笔账必须能自动同步过来且不能覆盖手机后来产生的数据。这就是离线写入与冲突解决。二、核心概念CRDT与SyncModeHarmonyOS DDS底层采用了CRDTConflict-free Replicated Data Types技术。简单来说它定义了一套数学规则让不同设备上的数据即使同时修改也能自动合并不需要中央服务器裁决。关键配置SyncMode同步模式SYNC_MODE_PUSH_ONLY只推不改适合日志上报。SYNC_MODE_PULL_ONLY只拉不改适合数据备份。SYNC_MODE_FULL_SYNC全量同步默认记账本必选。ConflictResolutionPolicy冲突解决策略LAST_WRITE_WIN最后修改时间胜出简单粗暴适合单用户多设备。CUSTOM自定义策略复杂但最安全适合金融场景。三、代码实现构建分布式记账本3.1 定义数据库Schema首先定义账本的数据结构。在entry/src/main/ets/db/schema.ets中import { distributedKVStore } from kit.ArkData // 账本条目结构 export interface BillEntry { id: string; // 唯一ID (UUID) amount: number; // 金额 category: string; // 分类 timestamp: number; // 创建时间戳 deviceId: string; // 创建设备ID version: number; // 版本号用于CRDT } // 数据库配置 export const BILL_DB_CONFIG: distributedKVStore.Options { createIfMissing: true, encrypt: true, // 金融数据必须加密 backup: false, // 分布式数据库由系统自动备份 kvStoreType: distributedKVStore.KVStoreType.DEVICE_COLLABORATION, // 设备协同型 securityLevel: distributedKVStore.SecurityLevel.S3, // 最高安全等级 syncPolicy: { syncMode: distributedKVStore.SyncMode.SYNC_MODE_FULL_SYNC, conflictResolutionPolicy: distributedKVStore.ConflictResolutionPolicy.LAST_WRITE_WIN } }3.2 封装分布式数据库管理器创建entry/src/main/ets/common/BillDBManager.etsimport { distributedKVStore } from kit.ArkData import { BusinessError } from kit.BasicServicesKit import { schema, BillEntry, BILL_DB_CONFIG } from ../db/schema export class BillDBManager { private static instance: BillDBManager | null null private kvStore: distributedKVStore.KVStore | null null private context: Context null! private constructor() {} static getInstance(): BillDBManager { if (!BillDBManager.instance) { BillDBManager.instance new BillDBManager() } return BillDBManager.instance } // 初始化数据库 async init(context: Context): Promisevoid { this.context context try { const kvManagerConfig: distributedKVStore.KVManagerConfig { context: context, bundleName: com.example.shop } const kvManager distributedKVStore.createKVManager(kvManagerConfig) // 获取/创建数据库 this.kvStore await kvManager.getKVStoredistributedKVStore.KVStore( bill_db, BILL_DB_CONFIG ) // 注册数据变更监听跨设备同步时会触发 this.kvStore.on(dataChange, distributedKVStore.SubscribeType.SUBSCRIBE_TYPE_ALL, (data) { console.log(分布式数据变更:, data.insertEntries, data.updateEntries) // 这里可以通知UI刷新 }) console.log(分布式数据库初始化成功) } catch (err) { const e err as BusinessError console.error(数据库初始化失败: ${e.code}, ${e.message}) } } // 新增账单离线也可写入 async addBill(entry: BillEntry): Promisevoid { if (!this.kvStore) return try { // Key使用UUIDValue是序列化后的对象 const key bill_${entry.id} const value JSON.stringify(entry) await this.kvStore.put(key, value) console.log(账单写入成功等待同步...) } catch (err) { console.error(写入失败:, err) } } // 手动触发同步通常在网络恢复或应用前台时调用 async syncData(): Promisevoid { if (!this.kvStore) return try { // 获取所有在线设备ID const devices await distributedKVStore.getOnlineDevices() if (devices.length 0) { await this.kvStore.sync(devices, distributedKVStore.SyncMode.SYNC_MODE_FULL_SYNC) console.log(数据同步请求已发送) } } catch (err) { console.error(同步失败:, err) } } // 查询所有账单 async queryAllBills(): PromiseBillEntry[] { if (!this.kvStore) return [] try { const keys await this.kvStore.getEntries(bill_) const bills: BillEntry[] [] for (const key of keys) { const value await this.kvStore.get(key) bills.push(JSON.parse(value as string)) } // 按时间戳排序 return bills.sort((a, b) b.timestamp - a.timestamp) } catch (err) { console.error(查询失败:, err) return [] } } }3.3 在UI中集成记账页面在穿戴设备或手机端的记账页面中调用import { BillDBManager } from ../common/BillDBManager Entry Component struct BillPage { private dbManager: BillDBManager BillDBManager.getInstance() State billList: BillEntry[] [] aboutToAppear(): void { this.dbManager.init(getContext(this)) this.loadBills() } async loadBills(): Promisevoid { this.billList await this.dbManager.queryAllBills() } // 新增一笔账 async addNewBill(): Promisevoid { const newBill: BillEntry { id: uuid_${Date.now()}, // 实际应使用系统UUID工具 amount: 99.8, category: 餐饮, timestamp: Date.now(), deviceId: watch_01, // 实际应从系统获取 version: 1 } await this.dbManager.addBill(newBill) // 写入后立即刷新列表本地已写入远端正在同步 this.loadBills() // 提示用户“已保存正在同步” promptAction.showToast({ message: 账单已保存将在联网后同步 }) } build() { Column() { Button(记一笔早餐 99.8元) .onClick(() this.addNewBill()) List() { ForEach(this.billList, (item: BillEntry) { ListItem() { Row() { Text(item.category) Blank() Text(¥${item.amount}) } } }) } } } }四、踩坑记录官方文档没写的分布式细节UUID生成分布式环境下绝对不能用时间戳或自增ID作为主键否则必然冲突。必须使用util.generateUUID()生成全局唯一ID。网络分区处理当设备长时间离线后重新联网DDS会自动同步但可能会触发dataChange事件风暴。建议在UI层做防抖处理避免列表频繁刷新导致卡顿。加密性能损耗开启encrypt: true后读写性能会下降约20%。对于非敏感数据如商品浏览历史可以不加密。但对于账本必须加密。同步时机系统会在设备上线、网络恢复、应用前台时自动触发同步无需手动调用sync。但为了确保关键数据如刚记的账尽快同步建议在put操作后手动调用一次sync。数据大小限制单条KV记录的大小不能超过4MB。对于账单这种小数据完全足够但如果是图片或文件需要存在文件系统数据库中只存路径。