0Pricing
MongoDB Academy · 课时

错误处理和重试逻辑

您将捕获 TransientTransactionError 和 UnknownTransactionCommitResult,并实现生产环境可靠性所需的推荐重试循环。

错误处理和重试逻辑 是 CoddyKit 上的免费 MongoDB Academy 课时。 这是第 3 节课,共 4 节。 你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。 这是 MongoDB Academy 学习路径的一部分,你的进度在网页和 CoddyKit 应用中同步。 MongoDB Academy 课程共包含 4 节课。

本课时的部分内容尚未翻译,以英文显示。

Why Transactions Need Retry Logic

MongoDB transactions can fail with transient errors—temporary conditions like network blips, primary failovers, or write conflicts—that do not indicate a logical problem with your code. These errors are safe to retry: the transaction was rolled back cleanly, and retrying it will produce correct results. Without retry logic, your application will surface unnecessary errors to users for conditions that a simple retry would resolve.

Two Error Labels to Understand

MongoDB classifies transaction errors with two important error labels: TransientTransactionError and UnknownTransactionCommitResult. TransientTransactionError means the entire transaction failed and it is safe to retry from the beginning. UnknownTransactionCommitResult means the commit was sent but the client does not know if it succeeded—the commit must be retried (not the whole transaction). Each requires a different retry strategy.

// Checking error labels
if (error.hasErrorLabel('TransientTransactionError')) {
  // Retry the whole transaction from scratch
  console.log('Transient error — retrying transaction');
} else if (error.hasErrorLabel('UnknownTransactionCommitResult')) {
  // Retry only the commit, not the whole transaction
  console.log('Unknown commit result — retrying commit only');
} else {
  // Application error (e.g., InsufficientFunds) — do not retry
  throw error;
}

Causes of TransientTransactionError

TransientTransactionError occurs when a transaction cannot proceed due to temporary conditions: write conflicts (another transaction modified the same document first), lock acquisition timeouts, replica set election failovers, or network connectivity issues. MongoDB rolls back the transaction completely before returning this error. The safe response is to start over with a fresh session and re-execute all operations.

Causes of UnknownTransactionCommitResult

UnknownTransactionCommitResult happens when a network timeout or failover occurs after MongoDB has committed the transaction but before the acknowledgment reaches the client. The transaction may or may not have been committed. The correct response is to retry only commitTransaction()—not the whole transaction—because MongoDB detects duplicate commit calls on the same session and returns successfully if the transaction is already committed.

The Recommended Retry Pattern

MongoDB's documentation specifies a two-loop retry pattern: an outer loop that retries the entire transaction on TransientTransactionError, and an inner loop that retries only the commit on UnknownTransactionCommitResult. This pattern handles all transient failure modes correctly and is what the withTransaction() helper implements internally.

async function runTransactionWithRetry(txnFunc, client, session) {
  while (true) {
    try {
      await txnFunc(client, session); // execute transaction
      break; // success — exit loop
    } catch (error) {
      if (error.hasErrorLabel('TransientTransactionError')) {
        console.log('Retrying transaction due to TransientTransactionError');
        continue; // retry the whole transaction
      } else {
        throw error; // non-transient error — surface to caller
      }
    }
  }
}

Retrying the Commit Separately

The commit retry loop handles UnknownTransactionCommitResult. It continuously calls commitTransaction() until either the commit is confirmed or a non-retryable error occurs. MongoDB idempotently handles duplicate commit calls on the same transaction—if the transaction was already committed, the retry returns success without re-applying the writes.

async function commitWithRetry(session) {
  while (true) {
    try {
      await session.commitTransaction();
      console.log('Transaction committed');
      break;
    } catch (error) {
      if (error.hasErrorLabel('UnknownTransactionCommitResult')) {
        console.log('Retrying commit...');
        continue; // retry commit
      } else {
        throw error;
      }
    }
  }
}

Full Two-Loop Implementation

Combining both retry loops gives the complete production-grade transaction function. The business logic is extracted into a separate function passed as a parameter, keeping the retry scaffolding reusable. Notice that the session is reused across retries—you do not create a new session for each retry, but you must call startTransaction() again at the beginning of each attempt.

async function runTransaction(client, txnBody) {
  const session = client.startSession();
  try {
    let committed = false;
    while (!committed) {
      session.startTransaction({ readConcern: { level: 'snapshot' }, writeConcern: { w: 'majority' } });
      try {
        await txnBody(session);
        // Commit with retry
        while (true) {
          try { await session.commitTransaction(); committed = true; break; }
          catch (e) {
            if (e.hasErrorLabel('UnknownTransactionCommitResult')) continue;
            else throw e;
          }
        }
      } catch (e) {
        await session.abortTransaction();
        if (!e.hasErrorLabel('TransientTransactionError')) throw e;
        // else retry
      }
    }
  } finally {
    await session.endSession();
  }
}

Why withTransaction() Is Simpler

The session.withTransaction(callback, options) helper implements the two-loop retry pattern automatically. You provide only the business logic callback and transaction options. Using withTransaction dramatically reduces boilerplate, minimizes the risk of getting the retry logic wrong, and is the recommended approach for all production MongoDB transaction code in the Node.js driver.

// withTransaction handles all retry logic internally
const session = client.startSession();
try {
  await session.withTransaction(
    async (session) => {
      // Pure business logic — no retry code needed here
      await debitAccount(session, fromId, amount);
      await creditAccount(session, toId, amount);
      await insertAuditLog(session, fromId, toId, amount);
    },
    { readConcern: { level: 'snapshot' }, writeConcern: { w: 'majority' } }
  );
} finally {
  await session.endSession();
}

Application-Level vs Transient Errors

Not every error inside a transaction is transient and retryable. Application-level errors—like insufficient funds, duplicate username, or invalid input—should abort the transaction and return an error to the user, not retry. Only errors with the TransientTransactionError or UnknownTransactionCommitResult labels should trigger retries. Mix both types of error handling in your transaction callback: throw domain errors that the outer layer can check before retrying.

async function transfer(session, fromId, toId, amount) {
  const account = await db.collection('accounts').findOne({ _id: fromId }, { session });
  
  // Domain error — should NOT be retried
  if (account.balance < amount) {
    const err = new Error('Insufficient funds');
    err.isDomainError = true;
    throw err;
  }
  
  await db.collection('accounts').updateOne({ _id: fromId }, { $inc: { balance: -amount } }, { session });
  await db.collection('accounts').updateOne({ _id: toId }, { $inc: { balance: amount } }, { session });
}

Write Conflicts: The Most Common Cause

Write conflicts occur when two transactions try to modify the same document simultaneously. MongoDB uses optimistic locking—it allows both transactions to proceed until commit time, then aborts the one that conflicts. The aborted transaction receives a TransientTransactionError with code WriteConflict. This is expected behavior—not a bug—and the retry loop handles it correctly. Frequent write conflicts indicate a hot document that may need schema redesign.

// Detection: WriteConflict is a TransientTransactionError subtype
try {
  await session.commitTransaction();
} catch (error) {
  if (error.hasErrorLabel('TransientTransactionError')) {
    // This includes WriteConflict (code 112)
    console.log('Code:', error.code); // 112 = WriteConflict
    // Retry the whole transaction
  }
}

Max Retry Attempts: Preventing Infinite Loops

In a production retry loop, always enforce a maximum number of retries to prevent infinite loops in pathological scenarios (e.g., perpetual write conflicts on a very hot document). After the maximum attempts, throw the last error so the application can handle it gracefully. Include exponential backoff with jitter between retries to reduce contention from multiple clients simultaneously retrying the same transaction.

async function runWithMaxRetries(session, txnFn, maxRetries = 5) {
  let attempts = 0;
  while (attempts < maxRetries) {
    try {
      await session.withTransaction(txnFn);
      return;
    } catch (error) {
      attempts++;
      if (error.hasErrorLabel('TransientTransactionError') && attempts < maxRetries) {
        const delay = Math.min(100 * Math.pow(2, attempts) + Math.random() * 100, 5000);
        await new Promise(res => setTimeout(res, delay));
        continue;
      }
      throw error; // exceeded retries or non-transient
    }
  }
}

Quick Check

Test your understanding of MongoDB & NoSQL Databases concepts from this lesson.

Lesson Recap

In this lesson you learned: TransientTransactionError means retry the entire transaction from the start, UnknownTransactionCommitResult means retry only the commit call, and withTransaction() implements this two-loop retry pattern automatically and is the recommended production approach. Next up we explore transaction performance considerations and how to minimize their overhead.

常见问题解答

「错误处理和重试逻辑」课时是免费的吗?

是的 — 「错误处理和重试逻辑」的完整文本可在网页上免费阅读。要进行交互式练习(内置代码编辑器和全天候 AI 导师)并解锁 MongoDB Academy 课程的其余内容,请升级到 CoddyKit PRO。 MongoDB Academy 课程共包含 4 节课。

「错误处理和重试逻辑」这节课中我会学到什么?

您将捕获 TransientTransactionError 和 UnknownTransactionCommitResult,并实现生产环境可靠性所需的推荐重试循环。 你通过在浏览器中直接运行的动手代码来练习 MongoDB Academy,全天候 AI 导师会在你学习这节课的过程中回答你的问题。

学习 MongoDB Academy 需要有经验吗?

无需任何先前经验。CoddyKit 上的 MongoDB Academy 课程适合初学者到高级学习者,你可以从这里开始或从头开始,按照自己的节奏学习。 这是第 3 节课,共 4 节。

「错误处理和重试逻辑」课时需要多长时间?

大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动,所以你能稳步进步,并在网页和应用中从离开的地方继续。

我能在这节 MongoDB Academy 课中编写并运行代码吗?

能。每节 MongoDB Academy 课都包含内置代码编辑器,你可以在浏览器中直接编写并运行真实代码,并获得即时 AI 反馈 — 无需本地设置。

此课程中的所有课时

  1. 分布式文档存储中的 ACID 保证
  2. 启动会话和多文档事务
  3. 错误处理和重试逻辑
  4. 事务性能考量
← 返回 MongoDB Academy