database-distributedobject-guidelines.md 7.4 KB
Newer Older
L
li_juntao 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17
# 分布式数据对象开发指导

## 场景介绍

分布式数据对象通过屏蔽设备间复杂的数据交互处理,提供了与本地变量类似的极简操作,当设备1的应用A的分布式数据对象增、删、改数据后,设备2的应用A也可以获取到对应的数据变化,同时还能监听数据变更以及对端数据对象的上下线。分布式数据对象支持的数据类型包括数字型、字符型、布尔型等基本类型,同时也支持数组、基本类型嵌套等复杂类型。


## 接口说明

### 创建数据对象实例

创建一个分布式数据对象实例,用户可以通过source指定分布式对象中的属性。


**表1** 分布式数据对象实例创建接口
| 包名 | 接口名 | 描述 | 
| -------- | -------- | -------- |
W
wuyongning 已提交
18
| ohos.data.distributedDataObject| createDistributedObject(source: object): DistributedObject | 创建一个分布式数据对象实例,用于数据操作 <br>-&nbsp;source:设置distributedObject的属性。<br>-&nbsp;DistributedObject:返回值是创建好的分布式对象。| 
L
li_juntao 已提交
19 20 21 22 23 24

### 创建分布式数据对象sessionId

创建一个随机的sessionId,可将其设置为一个分布式数据对象的sessionId。

**表2** 分布式数据对象sessionId创建接口
L
li_juntao 已提交
25
| 包名 | 接口名 | 描述 |
L
li_juntao 已提交
26
| -------- | -------- | -------- |
L
li_juntao 已提交
27
| ohos.data.distributedDataObject| genSessionId(): string | 创建一个sessionId,可作为分布式数据对象的sessionId |
L
li_juntao 已提交
28 29 30 31 32 33

### 设置分布式数据对象sessionId

设置分布式数据对象的sessionId,sessionId是一次(多设备)协同的唯一标识,同步的多个数据对象需要关联同一个sessionId。

**表3** 分布式数据对象sessionId设置接口
L
li_juntao 已提交
34
| 类名 | 接口名 | 描述 |
L
li_juntao 已提交
35
| -------- | -------- | -------- |
W
wuyongning 已提交
36
| DistributedDataObject | setSessionId(sessionId?: string): boolean | 为分布式数据对象设置sessionId <br>&nbsp;sessionId:如果指定sessionId,则退出指定分布式组网;如果不指定,则全部退出。|
L
li_juntao 已提交
37 38 39 40 41 42 43 44 45

### 订阅数据变更

订阅数据变更需要指定Callback作为回调方法,订阅的数据对象发生数据变更后,Callback被回调。

**表4** 分布式数据对象数据变更订阅接口
| 类名 | 接口名 | 描述 | 
| -------- | -------- | -------- |
| DistributedDataObject| on(type: 'change', callback: Callback<{ sessionId: string, fields: Array&lt;string&gt; }>): void | 订阅数据变更。 | 
W
wuyongning 已提交
46
| DistributedDataObject| off(type: 'change', callback?: Callback<{ sessionId: string, fields: Array&lt;string&gt; }>): void | 注销订阅。需要删除的变更回调,若不设置则删除该对象所有的变更回调。 |
L
li_juntao 已提交
47 48 49 50 51 52

### 订阅数据对象上下线

订阅数据对象上下线需要指定Callback作为回调方法,订阅的数据对象上线/下线后,对端的数据对象会收到Callback回调。

**表5** 分布式数据对象数据上下线订阅接口
L
li_juntao 已提交
53
| 类名 | 接口名 | 描述 |
L
li_juntao 已提交
54
| -------- | -------- | -------- |
L
li_juntao 已提交
55 56
| DistributedDataObject| on(type: 'status', callback: Callback<{ sessionId: string, networkId: string, status: 'online' \| 'offline' }>): void | 订阅数据对象上下线。 |
| DistributedDataObject| off(type: 'status', callback?: Callback<{ sessionId: string, deviceId: string, status: 'online' \| 'offline' }>): void | 注销订阅。 |
L
li_juntao 已提交
57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72



## 开发步骤

以一次分布式数据对象同步为例,说明开发步骤。

1. 准备工作,导入@ohos.data.distributedDataObject模块到开发环境。
   ```js
   import distributedObject from '@ohos.data.distributedDataObject'
   ```

2. 获取分布式数据对象实例。

   以下为创建分布式数据对象的代码示例:
   ```js
L
li_juntao 已提交
73 74
   var local_object = distributedObject.createDistributedObject({name:undefined, age:undefined, isVis:true, 
                  parent:undefined, list:undefined});
L
li_juntao 已提交
75 76 77 78 79 80 81 82
   ```


3. 加入同步组网。同步组网中的数据对象分为发起方和被拉起方。
   
   以下为加入同步组网的代码示例:

   ```js
L
li_juntao 已提交
83 84 85
   //发起方
   var local_object = distributedObject.createDistributedObject({name:"jack", age:18, isVis:true, 
       parent:{mother:"jack mom",father:"jack Dad"},[{mother:"jack mom"}, {father:"jack Dad"}]};
86
   local_object.setSessionId(sessionId);
L
li_juntao 已提交
87
   
88
   //被拉起方
L
li_juntao 已提交
89 90
   var remote_object = distributedObject.createDistributedObject({name:undefined, age:undefined, isVis:true, 
                  parent:undefined, list:undefined});
91
   remote_object.setSessionId(sessionId);
L
li_juntao 已提交
92
   //收到status上线后remote_object同步数据,即name变成jack,age是18
L
li_juntao 已提交
93
   ```
L
li_juntao 已提交
94 95
   
4. 监听对象数据变更。可监听对端数据的变更,以callback作为变更回调实例。
L
li_juntao 已提交
96 97 98 99

   以下为监听对象数据变更的代码示例。
   
   ```js
100
   function changeCallback(sessionId, changeData) {
L
li_juntao 已提交
101
        console.info("change" + sessionId);
L
li_juntao 已提交
102
   
L
li_juntao 已提交
103 104 105 106 107 108 109 110
        if (changeData != null && changeData != undefined) {
            changeData.forEach(element => {
                console.info("changed !" + element + " " + local_object[element]);
        });
        }
    } 
    local_object.on("change", this.changeCallback);
   ```
L
li_juntao 已提交
111
   
L
li_juntao 已提交
112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149
5. 修改对象属性,对象属性支持基本类型(数字类型、布尔类型、字符串类型)以及复杂类型(数组、基本类型嵌套等)。
   
   以下为修改分布式数据对象属性的代码示例:
   ```js
   local_object.name = "jack";
   local_object.age = 19;
   local_object.isVis = false;
   local_object.parent = {mother:"jack mom",father:"jack Dad"};
   local_object.list = [{mother:"jack mom"}, {father:"jack Dad"}];
   ```

   > ![icon-note.gif](public_sys-resources/icon-note.gif) **说明:**
   > 针对复杂类型的数据修改,目前支持对根属性的修改,暂不支持对下级属性的修改。示例如下:
   ```js
   //支持的修改方式
   local_object.parent = {mother:"mom", father:"dad"};
   //不支持的修改方式
   local_object.parent.mother = "mom";
   ```

6. 访问对象。可以通过直接获取的方式访问到分布式数据对象的属性,且该数据为组网内的最新数据。
   
   以下为访问对象的代码示例:
   ```js
   console.info("name " + local_object["name"]); 
   ```
7. 删除监听数据变更。可以指定删除监听的数据变更回调;也可以不指定,这将会删除该分布式数据对象的所有数据变更回调。

   以下为取消监听数据变更的代码示例:
   ```js
   //删除变更回调changeCallback
   local_object.off("change", changeCallback);
   //删除所有的变更回调
   local_object.off("change"); 
   ```
8. 监听分布式对象的上下线。可以监听对端分布式数据对象的上下线。
   以下为访问对象的代码示例:
   ```js
150
    function statusCallback(sessionId, networkid, status) {
L
li_juntao 已提交
151 152
      this.response += "status changed " + sessionId + " " + status + " " + networkId;
    }
L
li_juntao 已提交
153
   
L
li_juntao 已提交
154 155 156
    local_object.on("status", this.changeCallback);
   ```
9. 删除监听分布式对象的上下线。可以指定删除监听的上下线回调;也可以不指定,这将会删除该分布式数据对象的所有上下线回调。
L
li_juntao 已提交
157
   
L
li_juntao 已提交
158 159 160 161 162 163 164 165
    以下为取消监听数据变更的代码示例:
   ```js
   //删除上下线回调changeCallback
   local_object.off("status", changeCallback);
   //删除所有的上下线回调
   local_object.off("status");
   ```
10. 退出同步组网。分布式对象退出组网后,本地的数据变更对端不会同步。
L
li_juntao 已提交
166 167 168 169 170 171

     以下为退出同步组网的代码示例:
       ```js
       local_object.setSessionId("");
       ```

L
li_juntao 已提交
172
   
L
li_juntao 已提交
173

L
li_juntao 已提交
174 175 176 177