1# 键值型数据库跨设备数据同步 2 3 4## 场景介绍 5 6键值型数据库适合不涉及过多数据关系和业务关系的业务数据存储，比SQL数据库存储拥有更好的读写性能，同时因其在分布式场景中降低了解决数据库版本兼容问题的复杂度，和数据同步过程中冲突解决的复杂度而被广泛使用。 7 8 9## 基本概念 10 11在使用键值型数据库跨设备数据同步前，请先了解以下概念。 12 13 14### 单版本数据库 15 16单版本是指数据在本地是以单个条目为单位的方式保存，当数据在本地被用户修改时，不管它是否已经被同步出去，均直接在这个条目上进行修改。多个设备全局只保留一份数据，多个设备的相同记录（主码相同）会按时间最新保留一条记录，数据不分设备，设备之间修改相同的key会覆盖。同步也以此为基础，按照它在本地被写入或更改的顺序将当前最新一次修改逐条同步至远端设备，常用于联系人、天气等应用存储场景。 17 18 19 20 21### 多设备协同数据库 22 23多设备协同分布式数据库建立在单版本数据库之上，对应用程序存入的键值型数据中的Key前面拼接了本设备的DeviceID标识符，这样能保证每个设备产生的数据严格隔离。数据以设备的维度管理，不存在冲突；支持按照设备的维度查询数据。 24 25底层按照设备的维度管理这些数据，多设备协同数据库支持以设备的维度查询分布式数据，但是不支持修改远端设备同步过来的数据。需要分开查询各设备数据的可以使用设备协同版本数据库。常用于图库缩略图存储场景。 26 27 28 29 30## 同步方式 31 32数据管理服务提供了两种同步方式：手动同步和自动同步。键值型数据库可选择其中一种方式实现同应用跨设备数据同步。 33 34 35- **手动同步**：由应用程序调用sync接口来触发，需要指定同步的设备列表和同步模式。同步模式分为PULL_ONLY（将远端数据拉取到本端）、PUSH_ONLY（将本端数据推送到远端）和PUSH_PULL（将本端数据推送到远端同时也将远端数据拉取到本端）。[带有Query参数的同步接口](../reference/apis/js-apis-distributedKVStore.md#sync-1)，支持按条件过滤的方法进行同步，将符合条件的数据同步到远端。手动同步功能，仅系统应用可用。 36 37- **自动同步**：由分布式数据库自动将本端数据推送到远端，同时也将远端数据拉取到本端来完成数据同步，同步时机包括设备上线、应用程序更新数据等，应用不需要主动调用sync接口。 38 39 40## 运作机制 41 42底层通信组件完成设备发现和认证，会通知上层应用程序设备上线。收到设备上线的消息后数据管理服务可以在两个设备之间建立加密的数据传输通道，利用该通道在两个设备之间进行数据同步。 43 44 45### 数据跨设备同步机制 46 47 48 49如图所示，通过put、delete接口触发自动同步，将分布式数据通过通信适配层发送给对端设备，实现分布式数据的自动同步； 50 51手动同步则是手动调用sync接口触发同步，将分布式数据通过通信适配层发送给对端设备。 52 53 54### 数据变化通知机制 55 56增、删、改数据库时，会给订阅者发送数据变化的通知。主要分为本地数据变化通知和分布式数据变化通知。 57 58- **本地数据变化通知**：本地设备的应用内订阅数据变化通知，数据库增删改数据时，会收到通知。 59 60- **分布式数据变化通知**：同一应用订阅组网内其他设备数据变化的通知，其他设备增删改数据时，本设备会收到通知。 61 62 63## 约束限制 64 65- 设备协同数据库，针对每条记录，Key的长度≤896 Byte，Value的长度<4 MB。 66 67- 单版本数据库，针对每条记录，Key的长度≤1 KB，Value的长度<4 MB。 68 69- 键值型数据库不支持应用程序自定义冲突解决策略。 70 71- 每个应用程序最多支持同时打开16个键值型分布式数据库。 72 73- 单个数据库最多支持注册8个订阅数据变化的回调。 74 75- 手动同步功能，仅系统应用可用。 76 77 78## 接口说明 79 80以下是单版本键值型分布式数据库跨设备数据同步功能的相关接口，大部分为异步接口。异步接口均有callback和Promise两种返回形式，下表均以callback形式为例，更多接口及使用方式请见[分布式键值数据库](../reference/apis/js-apis-distributedKVStore.md)。 81 82| 接口名称 | 描述 | 83| -------- | -------- | 84| createKVManager(config: KVManagerConfig): KVManager | 创建一个KVManager对象实例，用于管理数据库对象。 | 85| getKVStore<T>(storeId: string, options: Options, callback: AsyncCallback<T>): void | 指定Options和storeId，创建并得到指定类型的KVStore数据库。 | 86| put(key: string, value: Uint8Array\|string\|number\|boolean, callback: AsyncCallback<void>): void | 插入和更新数据。 | 87| on(event: 'dataChange', type: SubscribeType, listener: Callback<ChangeNotification>): void | 订阅数据库中数据的变化。 | 88| get(key: string, callback: AsyncCallback<boolean \| string \| number \| Uint8Array>): void | 查询指定Key键的值。 | 89| sync(deviceIds: string[], mode: SyncMode, delayMs?: number): void | 在手动模式下，触发数据库同步。 | 90 91 92## 开发步骤 93 94此处以单版本键值型数据库跨设备数据同步的开发为例。以下是具体的开发流程和开发步骤。 95 96 97 98> **说明：** 99> 100> 数据只允许向数据安全标签不高于对端设备安全等级的设备同步数据，具体规则可见[跨设备同步访问控制机制](sync-app-data-across-devices-overview.md#跨设备同步访问控制机制)。 101 1021. 导入模块。 103 104 ```js 105 import distributedKVStore from '@ohos.data.distributedKVStore'; 106 ``` 107 1082. 请求权限。 109 110 1. 需要申请ohos.permission.DISTRIBUTED_DATASYNC权限，配置方式请参见[配置文件权限声明](../security/accesstoken-guidelines.md#配置文件权限声明)。 111 2. 同时需要在应用首次启动时弹窗向用户申请授权，使用方式请参见[向用户申请授权](../security/accesstoken-guidelines.md#向用户申请授权)。 112 1133. 根据配置构造分布式数据库管理类实例。 114 115 1. 根据应用上下文创建kvManagerConfig对象。 116 2. 创建分布式数据库管理器实例。 117 118 119 ```js 120 // Stage模型获取context 121 import UIAbility from '@ohos.app.ability.UIAbility'; 122 let kvManager; 123 let context = null; 124 125 class EntryAbility extends UIAbility { 126 onWindowStageCreate(windowStage) { 127 context = this.context; 128 } 129 } 130 131 // FA模型获取context 132 import featureAbility from '@ohos.ability.featureAbility'; 133 134 let context = featureAbility.getContext(); 135 136 // 获取context之后，构造分布式数据库管理类实例 137 try { 138 const kvManagerConfig = { 139 bundleName: 'com.example.datamanagertest', 140 context: context 141 } 142 kvManager = distributedKVStore.createKVManager(kvManagerConfig); 143 console.info('Succeeded in creating KVManager.'); 144 // 继续创建获取数据库 145 } catch (e) { 146 console.error(`Failed to create KVManager. Code:${e.code},message:${e.message}`); 147 } 148 ``` 149 1504. 获取并得到指定类型的键值型数据库。 151 152 1. 声明需要创建的分布式数据库ID描述。 153 2. 创建分布式数据库，建议关闭自动同步功能（autoSync:false），方便后续对同步功能进行验证，需要同步时主动调用sync接口。 154 155 156 ```js 157 try { 158 const options = { 159 createIfMissing: true, 160 encrypt: false, 161 backup: false, 162 autoSync: false, 163 // kvStoreType不填时，默认创建多设备协同数据库 164 kvStoreType: distributedKVStore.KVStoreType.SINGLE_VERSION, 165 // 多设备协同数据库：kvStoreType: distributedKVStore.KVStoreType.DEVICE_COLLABORATION, 166 securityLevel: distributedKVStore.SecurityLevel.S1 167 }; 168 kvManager.getKVStore('storeId', options, (err, kvStore) => { 169 if (err) { 170 console.error(`Failed to get KVStore: Code:${err.code},message:${err.message}`); 171 return; 172 } 173 console.info('Succeeded in getting KVStore.'); 174 // 进行相关数据操作 175 }); 176 } catch (e) { 177 console.error(`An unexpected error occurred. Code:${e.code},message:${e.message}`); 178 } 179 ``` 180 1815. 订阅分布式数据变化。 182 183 ```js 184 try { 185 kvStore.on('dataChange', distributedKVStore.SubscribeType.SUBSCRIBE_TYPE_ALL, (data) => { 186 console.info(`dataChange callback call data: ${data}`); 187 }); 188 } catch (e) { 189 console.error(`An unexpected error occurred. code:${e.code},message:${e.message}`); 190 } 191 ``` 192 1936. 将数据写入分布式数据库。 194 195 1. 构造需要写入分布式数据库的Key（键）和Value（值）。 196 2. 将键值数据写入分布式数据库。 197 198 199 ```js 200 const KEY_TEST_STRING_ELEMENT = 'key_test_string'; 201 const VALUE_TEST_STRING_ELEMENT = 'value_test_string'; 202 try { 203 kvStore.put(KEY_TEST_STRING_ELEMENT, VALUE_TEST_STRING_ELEMENT, (err) => { 204 if (err !== undefined) { 205 console.error(`Failed to put data. Code:${err.code},message:${err.message}`); 206 return; 207 } 208 console.info('Succeeded in putting data.'); 209 }); 210 } catch (e) { 211 console.error(`An unexpected error occurred. Code:${e.code},message:${e.message}`); 212 } 213 ``` 214 2157. 查询分布式数据库数据。 216 217 1. 构造需要从单版本分布式数据库中查询的Key（键）。 218 2. 从单版本分布式数据库中获取数据。 219 220 221 ```js 222 const KEY_TEST_STRING_ELEMENT = 'key_test_string'; 223 const VALUE_TEST_STRING_ELEMENT = 'value_test_string'; 224 try { 225 kvStore.put(KEY_TEST_STRING_ELEMENT, VALUE_TEST_STRING_ELEMENT, (err) => { 226 if (err !== undefined) { 227 console.error(`Failed to put data. Code:${err.code},message:${err.message}`); 228 return; 229 } 230 console.info('Succeeded in putting data.'); 231 kvStore.get(KEY_TEST_STRING_ELEMENT, (err, data) => { 232 if (err != undefined) { 233 console.error(`Failed to get data. Code:${err.code},message:${err.message}`); 234 return; 235 } 236 console.info(`Succeeded in getting data. Data:${data}`); 237 }); 238 }); 239 } catch (e) { 240 console.error(`Failed to get data. Code:${e.code},message:${e.message}`); 241 } 242 ``` 243 2448. 同步数据到其他设备。 245 246 选择同一组网环境下的设备以及同步模式（需用户在应用首次启动的弹窗中确认选择同步模式），进行数据同步。 247 248 > **说明：** 249 > 250 > 在手动同步的方式下，其中的deviceIds通过调用[devManager.getTrustedDeviceListSync](../reference/apis/js-apis-device-manager.md#gettrusteddevicelistsync)方法得到，deviceManager模块的接口均为系统接口，仅系统应用可用。 251 252 253 ```js 254 import deviceManager from '@ohos.distributedHardware.deviceManager'; 255 256 let devManager; 257 // create deviceManager 258 deviceManager.createDeviceManager('bundleName', (err, value) => { 259 if (!err) { 260 devManager = value; 261 // deviceIds由deviceManager调用getTrustedDeviceListSync方法得到 262 let deviceIds = []; 263 if (devManager !== null) { 264 //需要权限：ohos.permission.ACCESS_SERVICE_DM，仅系统应用可以获取 265 let devices = devManager.getTrustedDeviceListSync(); 266 for (let i = 0; i < devices.length; i++) { 267 deviceIds[i] = devices[i].deviceId; 268 } 269 } 270 try { 271 // 1000表示最大延迟时间为1000ms 272 kvStore.sync(deviceIds, distributedKVStore.SyncMode.PUSH_ONLY, 1000); 273 } catch (e) { 274 console.error(`An unexpected error occurred. Code:${e.code},message:${e.message}`); 275 } 276 } 277 }); 278 ``` 279
