• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1# 跨设备文件访问
2
3分布式文件系统为应用提供了跨设备文件访问的能力，开发者在两个设备安装同一应用时，通过[基础文件接口](app-file-access.md)，可跨设备读写另一个设备该应用[分布式文件路径](app-sandbox-directory.md#应用沙箱路径和真实物理路径的对应关系)（/data/storage/el2/distributedfiles/）下的文件。例如：多设备数据流转的场景，设备组网互联之后，设备A上的应用可访问设备B同应用分布式路径下的文件，当期望应用文件被其他设备访问时，只需将文件移动到分布式文件路径即可。
4
5## 开发步骤
6
71. 完成分布式组网。
8   将需要跨设备访问的两个设备登录同一账号，保证设备蓝牙和Wi-Fi功能开启，蓝牙无需互连，Wi-Fi无需接入同一个局域网。
9
102. 授权分布式数据同步权限。
11   分布式数据同步权限的授权方式为user_grant，因此需要调用requestPermissionsFromUser接口，以动态弹窗的方式向用户申请授权。示例中的context的获取方式请参见[获取UIAbility的上下文信息](../application-models/uiability-usage.md#获取uiability的上下文信息)。
12
13   ```ts
14   import { common, abilityAccessCtrl } from '@kit.AbilityKit';
15   // 请在组件内获取context，确保this.getUIContext().getHostContext()返回结果为UIAbilityContext
16   let context = this.getUIContext().getHostContext() as common.UIAbilityContext;
17   let atManager = abilityAccessCtrl.createAtManager();
18   try {
19     atManager.requestPermissionsFromUser(context, ['ohos.permission.DISTRIBUTED_DATASYNC']).then((data) => {
20       console.log('data: ' + JSON.stringify(data));
21     }).catch((err: object) => {
22       console.log('err: ' + JSON.stringify(err));
23     })
24   } catch (err) {
25     console.log('catch err->' + JSON.stringify(err));
26   }
27   ```
28
293. 访问跨设备文件。
30   同一应用不同设备之间实现跨设备文件访问，只需要将对应的文件放在应用沙箱的分布式文件路径即可。
31
32   设备A上在分布式路径下创建测试文件，并写入内容。示例中的context的获取方式请参见[获取UIAbility的上下文信息](../application-models/uiability-usage.md#获取uiability的上下文信息)。
33
34   ```ts
35   import { fileIo as fs } from '@kit.CoreFileKit';
36   import { common } from '@kit.AbilityKit';
37   import { BusinessError } from '@kit.BasicServicesKit';
38
39   // 请在组件内获取context，确保this.getUIContext().getHostContext()返回结果为UIAbilityContext
40   let context = this.getUIContext().getHostContext() as common.UIAbilityContext;
41   let pathDir: string = context.distributedFilesDir;
42   // 获取分布式目录的文件路径
43   let filePath: string = pathDir + '/test.txt';
44
45   try {
46     // 在分布式目录下创建文件
47     let file = fs.openSync(filePath, fs.OpenMode.READ_WRITE | fs.OpenMode.CREATE);
48     console.info('Succeeded in creating.');
49     // 向文件中写入内容
50     fs.writeSync(file.fd, 'content');
51     // 关闭文件
52     fs.closeSync(file.fd);
53   } catch (error) {
54     let err: BusinessError = error as BusinessError;
55     console.error(`Failed to openSync / writeSync / closeSync. Code: ${err.code}, message: ${err.message}`);
56   }
57   ```
58
59   设备B主动向设备A发起建链，建链成功后设备B可在分布式路径下读取测试文件。
60   > **说明：**
61   >
62   > 这里通过分布式设备管理的接口获取设备networkId，详见[设备管理接口](../reference/apis-distributedservice-kit/js-apis-distributedDeviceManager.md)。
63
64   ```ts
65   import { fileIo as fs } from '@kit.CoreFileKit';
66   import { common } from '@kit.AbilityKit';
67   import { BusinessError } from '@kit.BasicServicesKit';
68   import { buffer } from '@kit.ArkTS';
69   import { distributedDeviceManager } from '@kit.DistributedServiceKit'
70
71   // 通过分布式设备管理的接口获取设备A的networkId信息
72   let dmInstance = distributedDeviceManager.createDeviceManager("com.example.hap");
73   let deviceInfoList: Array<distributedDeviceManager.DeviceBasicInfo> = dmInstance.getAvailableDeviceListSync();
74   let networkId = deviceInfoList[0].networkId;
75
76   // 定义访问公共文件目录的回调
77   let listeners : fs.DfsListeners = {
78     onStatus: (networkId: string, status: number): void => {
79       console.info('Failed to access public directory');
80     }
81   }
82
83   // 访问并挂载公共文件目录
84   fs.connectDfs(networkId, listeners).then(() => {
85     console.info("Success to connectDfs");
86     // 请在组件内获取context，确保this.getUIContext().getHostContext()返回结果为UIAbilityContext
87     let context = this.getUIContext().getHostContext() as common.UIAbilityContext;
88     let pathDir: string = context.distributedFilesDir;
89     // 获取分布式目录的文件路径
90     let filePath: string = pathDir + '/test.txt';
91
92     try {
93       // 打开分布式目录下的文件
94       let file = fs.openSync(filePath, fs.OpenMode.READ_WRITE);
95       // 定义接收读取数据的缓存
96       let arrayBuffer = new ArrayBuffer(4096);
97       // 读取文件的内容，返回值是读取到的字节个数
98       class Option {
99           public offset: number = 0;
100           public length: number = 0;
101       }
102       let option = new Option();
103       option.length = arrayBuffer.byteLength;
104       let num = fs.readSync(file.fd, arrayBuffer, option);
105       // 打印读取到的文件数据
106       let buf = buffer.from(arrayBuffer, 0, num);
107       console.info('read result: ' + buf.toString());
108       fs.closeSync(file);
109     } catch (error) {
110       let err: BusinessError = error as BusinessError;
111       console.error(`Failed to openSync / readSync. Code: ${err.code}, message: ${err.message}`);
112     }
113   }).catch((error: BusinessError) => {
114     let err: BusinessError = error as BusinessError;
115     console.error(`Failed to connectDfs Code: ${err.code}, message: ${err.message}`);
116   });
117   ```
118
1193. B设备访问跨设备文件完成，断开链路。
120
121   ```ts
122   import { BusinessError } from '@kit.BasicServicesKit';
123   import { distributedDeviceManager } from '@kit.DistributedServiceKit'
124   import { fileIo as fs } from '@kit.CoreFileKit';
125
126   // 获取设备A的networkId
127   let dmInstance = distributedDeviceManager.createDeviceManager("com.example.hap");
128   let deviceInfoList: Array<distributedDeviceManager.DeviceBasicInfo> = dmInstance.getAvailableDeviceListSync();
129   let networkId = deviceInfoList[0].networkId;
130
131   // 取消公共文件目录挂载
132   fs.disconnectDfs(networkId).then(() => {
133     console.info("Success to disconnectDfs");
134   }).catch((error: BusinessError) => {
135     let err: BusinessError = error as BusinessError;
136     console.error(`Failed to disconnectDfs Code: ${err.code}, message: ${err.message}`)
137   })
138   ```