使用MongoDB GridFSBucket流式传输文件时出现“dest.on is not a function”错误

核心原因 #

这个错误本质是downStream.pipe(res)中，res不是符合Node.js规范的可写流（Writable Stream），或者downStream不是有效可读流，导致pipe方法无法调用目标流的on事件监听。

具体诱因及解决办法 #

1. Express响应对象被修改或环境不兼容 #

虽然Express的res默认是可写流，但部分中间件（如异常拦截、压缩中间件）或特殊运行环境（如Serverless容器）会修改res的结构，使其失去标准流的方法。

• 解决：
  先在代码中验证res的流属性：

  app.get('/api/:id', (req, res) => {
    // 打印流方法，确认是否存在
    console.log('res.on:', typeof res.on, 'res.write:', typeof res.write);
    // 后续代码...
  })
  

  如果输出不是function，检查中间件顺序，移除可能修改res的非必要中间件，或切换到标准Node.js运行环境测试。

2. 文件ID格式错误导致无效可读流 #

如果req.params.id不是MongoDB存储的ObjectId类型，openDownloadStream会返回异常对象而非正常可读流，调用pipe时就会报错。

• 解决：
  先校验并转换ID格式：

  const { ObjectId } = require('mongodb');
  
  app.get('/api/:id', (req, res) => {
    let fileId;
    try {
      fileId = new ObjectId(req.params.id);
    } catch (err) {
      return res.status(400).send('无效的文件ID');
    }
  
    const bucket = new mongodb.GridFSBucket(mydb, { bucketName: 'ls-config' });
    const downStream = bucket.openDownloadStream(fileId);
    downStream.pipe(res);
  })
  

3. MongoDB驱动与Express版本不兼容 #

部分MongoDB驱动v4.x+返回的可读流，在pipe到旧版Express的res时存在适配问题，导致流方法不匹配。

• 解决：
  要么将MongoDB驱动降级到v3.x稳定版，要么升级Express到最新v4.x版本；或者绕过pipe，手动处理流事件：

  app.get('/api/:id', (req, res) => {
    const bucket = new mongodb.GridFSBucket(mydb, { bucketName: 'ls-config' });
    const downStream = bucket.openDownloadStream(req.params.id);
  
    // 可选：设置对应文件的Content-Type
    res.setHeader('Content-Type', 'application/octet-stream');
  
    downStream.on('data', chunk => res.write(chunk));
    downStream.on('end', () => res.end());
    downStream.on('error', err => res.status(500).send(`文件读取失败：${err.message}`));
  })
  

内容的提问来源于stack exchange，提问作者Dinh-Bac Nguyen