NestJS + MikroORM upsertMany导致内存无法回收的解决方法

针对你使用upsertMany批量操作后内存无法回收的问题，核心原因是MikroORM的EntityManager会缓存实体实例，定时任务重复执行时这些缓存持续累积，最终导致内存泄漏。以下是具体解决方案：

• 使用独立的EntityManager实例
  每次定时任务执行时，不要复用全局的emBi，而是创建新的EntityManager实例，执行完操作后手动销毁，彻底避免缓存堆积。示例代码：

  // 注入EntityManagerFactory
  constructor(private readonly emFactory: EntityManagerFactory) {}
  
  async yourCronJob() {
    // 创建独立的EM实例
    const em = this.emFactory.create();
    try {
      await em.upsertMany(SingleOrderSales, saveArry);
    } finally {
      // 手动销毁实例，释放缓存
      await em.destroy();
    }
  }
  

• 禁用实体缓存（适配纯批量写入场景）
  如果你的批量upsert不需要复用实体，可以在操作时直接禁用缓存，阻止EntityManager存储本次操作的实体实例。修改代码如下：

  await this.emBi.upsertMany(SingleOrderSales, saveArry, { disableIdentityMap: true });
  

  注意：该配置仅影响本次操作，不会干扰其他业务的实体缓存逻辑。

• 手动清理EntityManager的identity map
  若必须复用全局EM实例，可以在每次任务执行后手动清理缓存，释放占用的内存：

  await this.emBi.upsertMany(SingleOrderSales, saveArry);
  // 清理当前EM的所有缓存实体
  this.emBi.clear();
  

  这种方式比创建新EM更轻量，但要确保清理时机正确，避免影响其他正在执行的业务操作。

• 拆分超大批量数据
  如果saveArry数据量过大，一次性处理会导致内存峰值过高，可以拆分成分批操作，每处理完一批就清理缓存或销毁EM实例：

  const batchSize = 1000;
  for (let i = 0; i < saveArry.length; i += batchSize) {
    const batch = saveArry.slice(i, i + batchSize);
    const em = this.emFactory.create();
    try {
      await em.upsertMany(SingleOrderSales, batch, { disableIdentityMap: true });
    } finally {
      await em.destroy();
    }
  }
  

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