前提条件:
npm i express unzipper multiparty bluebird
- 在项目根目录中创建
app/web
目录(如果需要,您可以自动创建)。
- 将所有这些文件放入一个目录中。
- 支持
async/await
的 Node 版本(据我所知,至少是 7.6+)
server.js:
const express = require('express');
const Promise = require('bluebird');
const fs = require('fs');
const writeFile = Promise.promisify(fs.writeFile);
const { parseRequest, getFile } = require('./multipart');
const { extractFiles } = require('./zip')
const EXTRACT_DIR = 'web/app';
const app = express();
const uploadFile = async (req, res, next) => {
try {
const body = await parseRequest(req);
const bodyFile = getFile(body, 'file');
if (!/\.zip$/.test(bodyFile.originalFilename)) {
res.status(200).json({ notice: 'not a zip archive, skipping' })
return;
}
const archiveFiles = await extractFiles(bodyFile);
await Promise.each(archiveFiles, async (file) => {
await writeFile(EXTRACT_DIR + '/' + file.path, file.buffer);
})
res.status(200).end();
} catch (e) {
res.status(500).end();
}
};
app.post('/files', uploadFile);
app.listen(3000, () => {
console.log('App is listening on port 3000');
});
multipart.js
const Promise = require('bluebird');
const { Form } = require('multiparty');
function parseRequest (req, options) {
return new Promise((resolve, reject) => {
const form = new Form(options)
form.parse(req, (err, fields, files) => {
if (err) {
return reject(err);
}
return resolve({ fields, files });
});
});
}
function getFile (body, field) {
const bodyFile = body.files[field];
const value = bodyFile ? bodyFile[0] : null;
return value || null;
}
module.exports = {
parseRequest,
getFile,
};
zip.js
const unzip = require('unzipper');
const fs = require('fs');
async function extractFiles (file) {
const files = [];
await fs.createReadStream(file.path).pipe(unzip.Parse()).on('entry', async entry => {
if (
entry.type !== 'File'
|| /^__MACOSX/.test(entry.path)
|| /.DS_Store/.test(entry.path)
) {
entry.autodrain()
return
}
const pathArr = entry.path.split('/');
const path = entry.path;
const buffer = await entry.buffer();
files.push({ buffer, path, originalFilename: pathArr[pathArr.length - 1] });
}).promise();
return files;
}
module.exports = {
extractFiles,
};
使用方法:
- 使用
node server
启动服务器。
- 在请求的
file
字段中发送您的文件 (在postman中键为file
)。示例curl命令:curl -XPOST -F 'file=@../ttrra-dsp-agency-api/banner.zip' 'localhost:3000/files'
缺点:
- 解压后的文件存储在缓冲区中,因此此方法不适用于大型档案,不建议使用。