鸿蒙next开发：文件上传下载（快速实现上传下载）_transferms inactivityms
往期鸿蒙全套实战文章必看：（附带鸿蒙全栈学习资料）
-
鸿蒙开发核心知识点，看这篇文章就够了
-
最新版！鸿蒙HarmonyOS Next应用开发实战学习路线
-
鸿蒙HarmonyOS NEXT开发技术最全学习路线指南
-
鸿蒙应用开发实战项目，看这一篇文章就够了（部分项目附源码）
快速实现上传下载
Remote Communication Kit 结合 Core File Kit 可以实现基于文件、目录、对象的快速上传和下载功能。 Remote Communication Kit 提供了远程通信的功能，包括远程连接、数据传输等 API 接口。而 Core File Kit 则提供了文件管理的功能，包括文件读取、写入等 API 接口。结合起来使用，可以通过 Remote Communication Kit 实现文件、目录、对象的远程传输，并且由于 Core File Kit 的高效文件处理能力，可以实现快速的上传和下载功能。
约束与限制
文件上传下载能力支持Phone，2in1，Tablet，Wearable设备。并且从5.1.1(19)开始，新增支持TV设备。
下载功能实现
- 导入需要的模块，示例中除去发起请求以及响应错误处理，还需用到CoreFileKit中的fileIo，所以需导入以下模块。
import { rcp } from \'@kit.RemoteCommunicationKit\';import { BusinessError } from \'@kit.BasicServicesKit\';import { fileIo } from \'@kit.CoreFileKit\'; - 定义下载路径，并创建相关配置。如还需访问应用文件，可以参考应用文件。
//下载文件保存的文件夹路径，仅为示例，请按需求进行替换。const DOWNLOAD_TO_PATH = `/data/storage/el2/base/haps/entry/files`;// 创建了一个安全配置对象，其中remoteValidation设置为\'skip\'，表示将跳过远程验证。const securityConfig: rcp.SecurityConfiguration = { remoteValidation: \'skip\'}// 创建了一个下载配置对象，其中kind设置为\'folder\'，表示下载的目标是文件夹，path设置为之前定义的DOWNLOAD_TO_PATH。let downloadToFile: rcp.DownloadToFile = { kind: \'folder\', path: DOWNLOAD_TO_PATH}// 创建一个HTTP会话，其中请求配置包括传输超时设置和安全配置（配置可自定义）const session = rcp.createSession({ requestConfiguration: { transfer: { timeout: { connectMs: 6000, transferMs: 6000, inactivityMs: 6000 } }, security: securityConfig }}) - 检查目标路径是否存在，如果存在，则先删除该路径，以确保下载的文件不会覆盖已存在的文件；最后发起请求，使用创建的会话执行下载操作，将https://example.com.png这个URL的内容下载到指定的本地路径。如果下载成功，会输出成功信息；如果失败，会输出错误信息。
// 检查目标路径是否存在if (fileIo.accessSync(DOWNLOAD_TO_PATH)) { fileIo.rmdirSync(DOWNLOAD_TO_PATH);}// 发起请求，执行下载操作，这里的https://example.com.png网址为示例图片网址，模拟下载图片场景session.downloadToFile(\'https://example.com.png\', downloadToFile) .then((response: rcp.Response) => { console.info(`Succeeded in getting the response, statusCode: ${JSON.stringify(response.statusCode)}`) }).catch((err: BusinessError) => { console.error(`Failed, the error message is ${JSON.stringify(err)}`)})
上传功能实现
- 导入需要的模块，示例中除去发起请求以及响应错误处理，还需用到CoreFileKit中的fileIo，需导入以下模块。
import { rcp } from \'@kit.RemoteCommunicationKit\';import { BusinessError } from \'@kit.BasicServicesKit\';import { fileIo } from \'@kit.CoreFileKit\'; - 定义Session配置，定义一个名为SESSION_CONFIG的对象，用于配置请求会话。配置包括传输超时和安全设置，如远程验证和TLS版本。
let SESSION_CONFIG: rcp.SessionConfiguration = { requestConfiguration: { transfer: { timeout: { connectMs: 6000 } }, security: { remoteValidation: \'skip\', tlsOptions: { tlsVersion: \'TlsV1.3\' } } }} - 定义FdReadFile类，用于读取文件描述符（File Descriptor）指向的文件。read方法异步读取指定的ArrayBuffer缓冲区，并返回实际读取的字节数。
class FdReadFile { readonly fd: number; constructor(fd: number) { this.fd = fd; } async read(buffer: ArrayBuffer): Promise { return fileIo.read(this.fd, buffer); }} - 创建会话并打开文件，以只读模式打开一个文件。fileIo.openSync方法返回一个文件描述符，如果打开失败，程序会打印错误信息并返回。
const session = rcp.createSession(SESSION_CONFIG);const file = fileIo.openSync(\'/data/storage/el1/bundle/entry_test/resources/resfile/upload_file.txt\', fileIo.OpenMode.READ_ONLY);if (!file) { console.error(\'fileIo.openSync failed\'); return;} - 读取文件，创建一个FdReadFile实例，并分配一个缓冲区来读取文件。read方法异步执行，等待文件读取完成。
const fdReadFile = new FdReadFile(file.fd);const buffer = new ArrayBuffer(1024 * 1024); // 假设文件大小为1MBawait fdReadFile.read(buffer); - 上传文件，使用会话的uploadFromFile方法将文件上传到指定的URL。UploadFromFile构造函数接受一个文件描述符读取文件。上传成功或失败时，会分别打印相应的信息。
await session.uploadFromFile(\'https://httpbin.org/anything\', new rcp.UploadFromFile(fdReadFile)) .then((response: rcp.Response) => { console.info(`Upload succeeded: ${response}`) }) .catch((err: BusinessError) => { console.error(`Upload failed: ${JSON.stringify(err)}`) }); - 关闭文件和会话，释放资源。
fileIo.closeSync(file.fd);session.close();
