【HarmonyOS NEXT】鸿蒙应用文件上传下载（ohos.request）

应用可以将应用文件上传到网络服务器，也可以从网络服务器下载网络资源文件到当地应用文件目次。
上传应用文件

开辟者可以使用上传下载模块（ohos.request）的上传接口将当地文件上传。文件上传过程使用系统服务代理完成, 在api12中request.agent.create接口增加了设置代理地址参数，支持用户设置自定义代理地址。
分析
当前上传应用文件功能，仅支持上传应用缓存文件路径（cacheDir）下的文件。
使用上传下载模块，需声明权限
：ohos.permission.INTERNET。
以下示例代码演示两种将应用缓存文件路径下的文件上传至网络服务器的方式:

1. // 方式一:request.uploadFile
2. // pages/xxx.ets
3. import common from '@ohos.app.ability.common';
4. import fs from '@ohos.file.fs';
5. import request from '@ohos.request';
6. import { BusinessError } from '@ohos.base';
8. // 获取应用文件路径
9. let context = getContext(this) as common.UIAbilityContext;
10. let cacheDir = context.cacheDir;
12. // 新建一个本地应用文件
13. let file = fs.openSync(cacheDir + '/test.txt', fs.OpenMode.READ_WRITE | fs.OpenMode.CREATE);
14. fs.writeSync(file.fd, 'upload file test');
15. fs.closeSync(file);
17. // 上传任务配置项
18. let header = new Map<Object, string>();
19. header.set('key1', 'value1');
20. header.set('key2', 'value2');
21. let files: Array<request.File> = [
22. //uri前缀internal://cache 对应cacheDir目录
23.   { filename: 'test.txt', name: 'test', uri: 'internal://cache/test.txt', type: 'txt' }
24. ]
25. let data: Array<request.RequestData> = [{ name: 'name', value: 'value' }];
26. let uploadConfig: request.UploadConfig = {
27.   url: 'https://xxx',
28.   header: header,
29.   method: 'POST',
30.   files: files,
31.   data: data
32. }
34. // 将本地应用文件上传至网络服务器
35. try {
36.   request.uploadFile(context, uploadConfig)
37.     .then((uploadTask: request.UploadTask) => {
38.       uploadTask.on('complete', (taskStates: Array<request.TaskState>) => {
39.         for (let i = 0; i < taskStates.length; i++) {
40.           console.info(`upload complete taskState: ${JSON.stringify(taskStates[i])}`);
41.         }
42.       });
43.     })
44.     .catch((err: BusinessError) => {
45.       console.error(`Invoke uploadFile failed, code is ${err.code}, message is ${err.message}`);
46.     })
47. } catch (error) {
48.   let err: BusinessError = error as BusinessError;
49.   console.error(`Invoke uploadFile failed, code is ${err.code}, message is ${err.message}`);
50. }

复制代码

1. // 方式二:request.agent
2. // 获取应用文件路径
3. let context = getContext(this) as common.UIAbilityContext;
4. let cacheDir = context.cacheDir;
6. // 新建一个本地应用文件
7. let file = fs.openSync(cacheDir + '/test.txt', fs.OpenMode.READ_WRITE | fs.OpenMode.CREATE);
8. fs.writeSync(file.fd, 'upload file test');
9. fs.closeSync(file);
10. let attachments: Array<request.agent.FormItem> = [{
11.   name: "test",
12.   value: [
13.     {
14.       filename: "test.txt",
15.       path: "./test.txt",
16.     },
17.   ]
18. }];
19. let config: request.agent.Config = {
20.   action: request.agent.Action.UPLOAD,
21.   url: 'http://xxx',
22.   mode: request.agent.Mode.FOREGROUND,
23.   overwrite: true,
24.   method: "POST",
25.   data: attachments,
26.   saveas: "./"
27. };
28. request.agent.create(getContext(), config).then((task: request.agent.Task) => {
29.   task.start((err: BusinessError) => {
30.     if (err) {
31.       this.progress = `Failed to start the upload task, Code: ${err.code}  message: ${err.message}`;
32.       return;
33.     }
34.   });
35.   task.on('progress', async(progress) => {
36.     console.warn(`/Request upload status ${progress.state}, uploaded ${progress.processed}`);
37.   })
38.   task.on('completed', async() => {
39.     console.warn(`/Request upload completed`);
40.   })
41. }).catch((err: BusinessError) => {
42.   this.progress = `Failed to create a upload task, Code: ${err.code}, message: ${err.message}`;
43. });

复制代码

下载网络资源文件至应用文件目次

开辟者可以使用上传下载模块（ohos.request）的下载接口将网络资源文件下载到应用文件目次。对已下载的网络资源文件，开辟者可以使用基础文件IO接口（ohos.file.fs）对其举行访问，使用方式与应用文件访问一致。文件下载过程使用系统服务代理完成, 在api12中request.agent.create接口增加了设置代理地址参数，支持用户设置自定义代理地址。
分析
当前网络资源文件仅支持下载至应用文件目次。
使用上传下载模块，需声明权限：ohos.permission.INTERNET。
以下示例代码演示两种将网络资源文件下载到应用文件目次的方式：

1. // 方式一:request.downloadFile
2. // pages/xxx.ets
3. // 将网络资源文件下载到应用文件目录并读取一段内容
4. import common from '@ohos.app.ability.common';
5. import fs from '@ohos.file.fs';
6. import request from '@ohos.request';
7. import { BusinessError } from '@ohos.base';
8. import buffer from '@ohos.buffer';
10. // 获取应用文件路径
11. let context = getContext(this) as common.UIAbilityContext;
12. let filesDir = context.filesDir;
14. try {
15.   request.downloadFile(context, {
16.     url: 'https://xxxx/xxxx.txt',
17.     filePath: filesDir + '/xxxx.txt'
18.   }).then((downloadTask: request.DownloadTask) => {
19.     downloadTask.on('complete', () => {
20.       console.info('download complete');
21.       let file = fs.openSync(filesDir + '/xxxx.txt', fs.OpenMode.READ_WRITE);
22.       let arrayBuffer = new ArrayBuffer(1024);
23.       let readLen = fs.readSync(file.fd, arrayBuffer);
24.       let buf = buffer.from(arrayBuffer, 0, readLen);
25.       console.info(`The content of file: ${buf.toString()}`);
26.       fs.closeSync(file);
27.     })
28.   }).catch((err: BusinessError) => {
29.     console.error(`Invoke downloadTask failed, code is ${err.code}, message is ${err.message}`);
30.   });
31. } catch (error) {
32.   let err: BusinessError = error as BusinessError;
33.   console.error(`Invoke downloadFile failed, code is ${err.code}, message is ${err.message}`);
34. }

复制代码

1. // 方式二:request.agent
2. // pages/xxx.ets
3. // 将网络资源文件下载到应用文件目录并读取一段内容
4. import common from '@ohos.app.ability.common';
5. import fs from '@ohos.file.fs';
6. import request from '@ohos.request';
7. import { BusinessError } from '@ohos.base';
8. import buffer from '@ohos.buffer';
10. let config: request.agent.Config = {
11.   action: request.agent.Action.DOWNLOAD,
12.   url: 'https://xxxx/test.txt',
13.   gauge: true,
14.   overwrite: true,
15.   network: request.agent.Network.WIFI,
16. };
17. request.agent.create(getContext(), config).then((task: request.agent.Task) => {
18.   task.start((err: BusinessError) => {
19.     if (err) {
20.       this.progress = `Failed to start the upload task, Code: ${err.code}  message: ${err.message}`;
21.       return;
22.     }
23.   });
24.   task.on('progress', async(progress) => {
25.     console.warn(`/Request download status ${progress.state}, downloaded ${progress.processed}`);
26.   })
27.   task.on('completed', async() => {
28.     console.warn(`/Request download completed`);
29.   })
30. }).catch((err: BusinessError) => {
31.   this.progress = `Failed to create a download task, Code: ${err.code}, message: ${err.message}`;
32. });

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。