NestJS基于Mongoose实现动态多数据库连接的问题咨询

核心矛盾在于Mongoose模块初始化时机早于Guard的认证流程，导致模块初始化阶段无法获取request.user中的动态URI。官方的连接名策略本身支持多数据库管理，但直接在模块初始化时绑定固定连接名，无法满足请求级动态切换的需求，需要结合请求作用域服务与动态连接管理来实现。

1. 请求作用域的动态连接管理（推荐） #

放弃在app.module.ts中提前初始化customer连接，改为在请求处理时根据request.user的URI动态创建/复用连接：

步骤1：实现动态连接服务 #

@Injectable({ scope: Scope.REQUEST })
export class DynamicMongoService {
  private connection: Connection;

  constructor(
    @Inject(REQUEST) private readonly request: IRequest,
    private readonly mongoose: Mongoose,
  ) {}

  async getConnection(): Promise<Connection> {
    if (this.connection) return this.connection;

    // 获取目标URI：优先用用户配置，否则用默认值
    const targetUri = this.request.user?.uri || process.env.DEFAULT_MONGO_URI;
    // 用用户ID作为连接标识，避免重复创建相同URI的连接
    const connectionKey = this.request.user?.id || 'default_customer';

    // 检查连接池是否已存在该连接
    const existingConn = this.mongoose.connections.find(conn => conn.name === connectionKey);
    if (existingConn) {
      this.connection = existingConn;
      return this.connection;
    }

    // 动态创建新连接
    this.connection = await this.mongoose.createConnection(targetUri, {
      useNewUrlParser: true,
      useUnifiedTopology: true,
      connectionName: connectionKey,
    });
    return this.connection;
  }
}

步骤2：业务Service中使用动态连接 #

@Injectable({ scope: Scope.REQUEST })
export class ProcessService {
  private processModel: Model<Process>;

  constructor(private readonly dynamicMongoService: DynamicMongoService) {}

  private async getProcessModel(): Promise<Model<Process>> {
    if (this.processModel) return this.processModel;
    const conn = await this.dynamicMongoService.getConnection();
    this.processModel = conn.model('Process', ProcessSchema);
    return this.processModel;
  }

  // 示例业务方法
  async createProcess(dto: ProcessCreateDto) {
    const model = await this.getProcessModel();
    return model.create(dto);
  }
}

步骤3：保障Guard优先级 #

保持现有Guard的全局注册或控制器级注册，确保在DynamicMongoService读取request.user前完成认证逻辑。

2. 连接名策略的适配改造 #

如果坚持使用官方连接名绑定机制，可以通过延迟初始化+请求作用域配置提供者实现，但性能较低（每个请求可能触发连接初始化）：

• 将MongooseModule.forRootAsync的useClass改为请求作用域的配置服务
• 在配置服务中通过request.user获取URI，返回对应配置
• 注意：这种方式无法复用连接，仅适合低并发场景

3. 替代方案：拦截器预处理连接 #

在Guard之后添加全局拦截器，提前根据request.user的URI初始化连接并挂载到request对象上，后续业务Service直接从request中获取连接实例。但需手动处理连接的复用、闲置清理与生命周期管理，复杂度较高。

• 连接复用：必须通过用户ID或URI标识缓存连接，避免频繁创建连接导致性能损耗
• 请求作用域：所有涉及动态连接的服务必须设置为Scope.REQUEST，确保每个请求拿到正确的用户上下文
• 连接清理：可通过定时任务清理闲置连接，或在应用 shutdown 时销毁所有动态创建的连接

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