NestJS+Mongoose中使用GridFS的最佳实践：是否仍用原生GridFSBucket？

1. 在基于Mongoose的NestJS项目中，使用原生GridFSBucket是否仍属最佳实践？ #

是的。Mongoose本身并未提供对GridFS的完整封装，而原生GridFSBucket是MongoDB官方提供的标准组件，功能完整、性能稳定，尤其适合处理大文件的流式读写场景。在NestJS+Mongoose的架构下使用它，既不会和现有Mongoose代码冲突，还能避免第三方封装可能带来的功能限制或额外依赖。

2. 是否需将GridFS操作也迁移至Mongoose模型/库？ #

不需要强制迁移。虽然有第三方Mongoose插件（如mongoose-gridfs）可以封装GridFS操作，但如果当前原生GridFSBucket的实现已经满足业务需求，完全可以继续使用。如果追求代码风格和现有Mongoose模型统一，或者需要更贴合Mongoose的查询语法，再考虑迁移即可——原生实现的优势是直接、无额外学习成本，且能完全掌控GridFS的底层行为。

3. 在方法内重复创建新MongoClient是否为不良实践？ #

这是严重的不良实践。每次创建MongoClient都会建立新的数据库连接，频繁创建和销毁连接会：

• 耗尽MongoDB的连接数限制
• 产生大量连接建立/销毁的性能开销
• 导致应用性能波动甚至服务不可用

MongoDB的连接设计本身就是要复用连接池，而非每次请求新建连接。

4. 使用@InjectConnection()和connection.db是否为推荐方案？ #

这是推荐的标准方案。在NestJS+Mongoose项目中，@InjectConnection()可以直接获取到框架已经初始化好的Mongoose连接实例，通过connection.db就能拿到底层的MongoDB数据库对象，用它创建GridFSBucket即可复用项目中已配置好的连接池，完全避免重复创建连接的问题，同时也符合NestJS的依赖注入设计规范。

优化后的示例代码 #

import { Injectable, Inject } from '@nestjs/common';
import { Connection, ObjectId } from 'mongoose';
import { GridFSBucket } from 'mongodb';

@Injectable()
export class ImageService {
  private readonly db: any; // 底层MongoDB数据库对象

  constructor(@InjectConnection() private readonly connection: Connection) {
    this.db = this.connection.db;
  }

  async getImage(fileId: string) {
    try {
      const objectId = new ObjectId(fileId);

      const filesCollection = this.db.collection('fs.files');
      const fileDoc = await filesCollection.findOne({ _id: objectId });

      if (!fileDoc) {
        return {
          status: { statusCode: 404, message: 'File not found' },
        };
      }

      const gridFSBucket = new GridFSBucket(this.db, {
        bucketName: 'fs',
      });

      const downloadStream = gridFSBucket.openDownloadStream(objectId);

      return {
        stream: downloadStream,
        contentType: fileDoc.contentType || 'application/octet-stream',
        filename: fileDoc.filename || 'image',
      };
    } catch (err) {
      return {
        status: {
          statusCode: 500,
          message: err.message,
        },
      };
    }
  }
}

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