Node.js基于GridFS的图片上传系统问题：upload中间件未定义求助

1. 核心问题：未正确执行初始化方法 #

你实例化MyGridFS类后，必须先调用initializeStorage方法，才能生成可用的upload中间件。如果直接实例化后就去读取upload属性，自然会得到undefined。

修正后的路由文件示例 #

const MyGridFS = require('./path/to/your/MyGridFS-file'); // 引入你的类
const uploadController = require('./path/to/uploadController'); // 确保引入控制器
const express = require('express');
const upload = express.Router();

// 实例化并执行初始化
const gridFSInstance = new MyGridFS();
gridFSInstance.initializeStorage('你的MongoDB连接URI'); // 关键步骤：调用初始化方法

// 现在可以正常使用中间件
upload.post("/upload", gridFSInstance.upload.single("file"), (req, res) =>
  uploadController.upload(req, res),
);

module.exports = upload;

2. 清理类中冗余代码 #

你的构造函数里的代码完全无效，直接删除即可，避免干扰属性指向：

class MyGridFS {
  // 空构造函数或直接省略
  constructor() {}

  initializeGridFS(conn) {
    this.conn = conn;
    conn.once("open", () => {
      this.gridfsBucket = new mongoose.mongo.GridFSBucket(conn.db, {
        bucketName: "uploads",
      });
      this.gfs = Grid(conn.db, mongoose.mongo);
      this.gfs.collection("uploads");
    });
  }

  initializeStorage(mongo_uri) {
    this.mongo_uri = mongo_uri;
    const storage = new GridFsStorage({
      url: this.mongo_uri,
      file: (req, file) => {
        const filename = "file_" + Date.now() + path.extname(file.originalname);
        return {
          filename,
          bucketName: "uploads",
        };
      },
    });
    this.upload = multer({ storage });
  }
}

module.exports = MyGridFS; // 确保类被正确导出

3. 处理异步初始化场景（可选） #

如果GridFsStorage的数据库连接是异步完成的，可能出现中间件未就绪就被调用的情况。可以给initializeStorage封装Promise，确保连接完成后再使用中间件：

修改后的initializeStorage方法 #

initializeStorage(mongo_uri) {
  return new Promise((resolve, reject) => {
    this.mongo_uri = mongo_uri;
    const storage = new GridFsStorage({
      url: this.mongo_uri,
      file: (req, file) => {
        const filename = "file_" + Date.now() + path.extname(file.originalname);
        return {
          filename,
          bucketName: "uploads",
        };
      },
      onConnection: (db) => {
        // 连接成功后初始化GridFS实例
        this.gridfsBucket = new mongoose.mongo.GridFSBucket(db, { bucketName: "uploads" });
        this.gfs = Grid(db, mongoose.mongo);
        this.gfs.collection("uploads");
        resolve();
      },
      onError: (err) => reject(err)
    });
    this.upload = multer({ storage });
  });
}

路由文件中异步初始化 #

const gridFSInstance = new MyGridFS();

// 等待初始化完成后再注册路由
gridFSInstance.initializeStorage('你的MongoDB连接URI')
  .then(() => {
    upload.post("/upload", gridFSInstance.upload.single("file"), (req, res) =>
      uploadController.upload(req, res),
    );
  })
  .catch(err => console.error('GridFS初始化失败:', err));

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