使用GridFsStorage配合multer读流时报TypeError: grid.mongo.GridStore is not a constructor

核心报错原因 #

• 异步时序问题：gfs 仅在MongoDB连接成功的异步回调中完成初始化，你在回调外直接调用gfs.files.findOne时，gfs 仍为undefined，调用其属性方法直接触发TypeError
• 构造函数调用错误：GridFSBucket是构造函数，必须加new关键字创建实例，直接调用也会抛出类型错误
• API不匹配：只有旧版第三方gridfs-stream包才有gfs.files属性，mongoose内置的GridFSBucket无该属性，直接调用同样会报错
• 缺少容错判断：未校验gfs是否初始化完成、未判断查询结果是否存在匹配文件，异常场景下也会触发类型错误

修复后代码 #

const mongoURI = DB;
const conn = mongoose.createConnection(mongoURI);

let gfs;
conn.once('open', function() {
  // 初始化GridFSBucket，指定存储桶名对应上传的uploads集合
  gfs = new mongoose.mongo.GridFSBucket(conn.db, {
    bucketName: 'uploads'
  });
});

// 示例文件读取接口逻辑
app.get('/uploads/:filename', (req, res) => {
  // 前置校验gfs是否就绪
  if (!gfs) {
    return res.status(503).send('文件存储服务未就绪');
  }
  // 查询匹配文件
  gfs.find({ filename: req.params.filename }).toArray((err, files) => {
    if (err) return res.status(500).send('文件查询失败');
    if (!files || files.length === 0) return res.status(404).send('文件不存在');
    // 创建读取流返回
    const readStream = gfs.openDownloadStreamByName(req.params.filename);
    readStream.pipe(res);
    readStream.on('error', () => res.status(500).send('文件读取失败'));
  });
});

注意事项 #

• 所有依赖gfs的业务逻辑都要确保在gfs初始化完成后执行，Express/Koa项目可以封装成全局中间件统一校验，避免重复判断
• multer的GridFsStorage配置中指定的bucketName要和GridFSBucket初始化的bucketName完全一致，否则会出现查询不到文件的问题
• 6.x以上版本mongoose已内置GridFS相关能力，不需要额外安装gridfs-stream等第三方依赖

内容的提问来源于stack exchange，提问作者theweirdev