不能直接用multer.single()写入gridfs，因其默认将文件暂存为buffer或磁盘临时文件，而gridfs必须接收原生readablestream；正确做法是用multer().none()禁用解析，再通过busboy从原始请求流中提取文件流并直连gridfs。
为什么不能直接用 multer.single() 写入 GridFS？
因为 multer.single() 默认把文件暂存到内存或磁盘（memoryStorage 或 diskStorage），而 GridFS 需要的是可读流（ReadableStream）——不是完整文件 Buffer，也不是临时路径。一旦 Multer 解析完，原始流就结束了，再拿 req.file.buffer 或 fs.createReadStream(req.file.path) 都是二次封装，失去“流式”意义，还多占内存或磁盘 IO。
关键点：必须绕过 Multer 的默认文件处理逻辑，从原始 HTTP 请求流中截取文件部分，并手动解析 multipart boundary，再喂给 GridFS。
用 multer().none() + 手动解析 multipart 流
这是最可控的方式：禁用 Multer 的文件解析，自己用 busboy（Multer 底层依赖）或 formidable 提前消费请求流，拿到文件字段的 ReadableStream 后直连 GridFS。
-
multer().none()让 Multer 不做任何解析，保留req原始流可读性 - 用
busboy监听file事件，拿到stream（即原生 Node.jsReadable） - 用
GridFSBucket.openUploadStream()创建上传流，pipe()直连 - 注意设置
contentType和filename元数据，否则 GridFS 查不到
const busboy = require('busboy');
const { GridFSBucket } = require('mongodb');
<p>app.post('/upload', (req, res) => {
req.busboy = new busboy({ headers: req.headers });</p><p>req.busboy.on('file', (fieldname, stream, info) => {
const bucket = new GridFSBucket(db);
const uploadStream = bucket.openUploadStream(info.filename, {
contentType: info.mimeType,
});</p><pre class="brush:php;toolbar:false;">stream.pipe(uploadStream);
uploadStream.on('error', () => res.status(500).send('Upload failed'));
uploadStream.on('finish', () => res.send('OK'));});
req.pipe(req.busboy); });
避免踩坑：边界解析失败、超时、流未销毁
常见错误现象：Error: Request aborted、write after end、上传卡住无响应——基本都是流控制没对齐。
- 必须监听
req的aborted和error事件，手动销毁busboy和uploadStream - Node.js 默认
req超时是 2 分钟，大文件上传需调大：req.setTimeout(0)（禁用超时）或设为足够值 -
busboy的file事件只触发一次，但若前端发了多个文件字段，需循环处理；单文件场景下确保字段名匹配（如input name="file"→fieldname === 'file'） - GridFS
openUploadStream()返回的流不自动处理错误，务必监听error并结束响应，否则连接挂起
要不要用 multer.memoryStorage() + Buffer 传 GridFS？
可以，但不推荐用于生产大文件上传。它把整个文件读进内存，req.file.buffer 是完整 Buffer，再用 bucket.openUploadStream() 写入，本质是“先加载后写入”，丢失流式优势，且易 OOM。
仅适合小文件（maxSize 严格限制：
const upload = multer({
storage: multer.memoryStorage(),
limits: { fileSize: 8 * 1024 * 1024 } // 8MB
});
<p>app.post('/upload-buffer', upload.single('file'), async (req, res) => {
try {
const bucket = new GridFSBucket(db);
const uploadStream = bucket.openUploadStream(req.file.originalname, {
contentType: req.file.mimetype,
});</p><pre class="brush:php;toolbar:false;">await req.file.buffer.pipe(uploadStream).promise(); // 注意：pipe 不返回 Promise，需用 .promise() 或监听 finish
res.send('OK');} catch (err) { res.status(500).send(err.message); } });
真正流式上传的核心，是让数据从客户端 TCP 连接 → HTTP parser → GridFS → MongoDB 磁盘，全程不落地、不全缓存。中间任意一环转成 Buffer 或临时文件，就不再是“流式”了。
