使用流处理大文件可避免内存溢出。1. 上传时用multer分块暂存,再通过fs.createReadStream读取并pipe到目标文件,最后删除临时文件;2. 下载时用fs.createReadStream创建读取流,设置响应头后pipe到res,实现分批传输;3. 增强稳定性需监听error事件,及时销毁流并释放资源。

处理大文件上传与下载时,直接读取整个文件到内存会导致内存溢出。Node.js 的流(Stream)机制能有效解决这个问题,通过分块传输数据,实现高效、低内存占用的文件操作。
使用流处理大文件上传
前端上传大文件时,后端应避免一次性加载整个文件。利用 multer 中间件配合流式写入,可将文件分块保存到磁盘。
安装 multer:
npm install multer
示例代码:
const express = require(‘express’);
const multer = require(‘multer’);
const fs = require(‘fs’);
const app = express();
const upload = multer({ dest: ‘uploads/’ }); // 临时存储目录
app.post(‘/upload’, upload.single(‘file’), (req, res) => {
const readStream = fs.createReadStream(req.file.path);
const writeStream = fs.createWriteStream(`./final/${req.file.originalname}`);
readStream.pipe(writeStream);
writeStream.on(‘finish’, () => {
fs.unlinkSync(req.file.path); // 删除临时文件
res.send(‘文件上传成功’);
});
});
说明:multer 将文件暂存本地,再通过可读流读取并用 pipe 导入可写流,逐块写入目标位置,避免内存压力。
使用流处理大文件下载
用户请求下载大文件时,不应使用 fs.readFile,而应创建可读流,通过 pipe 发送给响应对象。
示例代码:
app.get(‘/download/:filename’, (req, res) => {
const filename = req.params.filename;
const filePath = `./files/${filename}`;
fs.access(filePath, fs.constants.F_OK, (err) => {
if (err) return res.status(404).send(‘文件不存在’);
const readStream = fs.createReadStream(filePath);
res.setHeader(‘Content-Disposition’, `attachment; filename=”${filename}”`);
res.setHeader(‘Content-Type’, ‘application/octet-stream’);
readStream.pipe(res);
});
});
说明:设置合适的响应头后,将文件流通过 pipe 接入 HTTP 响应,数据分批发送,不占内存。
提升流处理稳定性
在实际应用中,需考虑错误处理和资源释放,确保服务健壮。
监听流的 error 事件,防止崩溃下载失败时及时销毁流上传完成后清理临时文件
增强版下载示例:
readStream.on(‘error’, (err) => {
console.error(‘读取失败:’, err);
res.status(500).send(‘下载失败’);
});
res.on(‘close’, () => {
readStream.destroy();
});
基本上就这些。用流处理大文件,核心是避免内存堆积,借助 pipe 实现高效管道传输,上传下载都能稳定运行。
以上就是如何用Node.js流处理大文件上传与下载?的详细内容,更多请关注创想鸟其它相关文章!
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1526145.html
微信扫一扫
支付宝扫一扫