如何在Cloud Firestore中仅在首个事务成功后执行后续事务？

嘿，你的当前实现方式功能上是完全可行的——嵌套addOnSuccessListener确实能保证第二个写入操作只有在第一个成功完成后才会触发，完全满足你“第一个事务成功后再执行第二个”的需求。

不过咱们可以聊聊这种写法的优缺点，以及更优雅的替代方案：

一、当前嵌套回调的优缺点 #

优点 #

• 逻辑直观：明确体现了“先执行A，成功后再执行B”的顺序依赖
• 实现简单：不需要额外的工具类或语法支持

缺点 #

• 容易陷入「回调地狱」：如果后续需要添加更多的顺序操作，代码会层层缩进，可读性和维护性会急剧下降
• 错误处理分散：每个操作的失败回调需要单独处理，不利于统一的异常捕获

二、优化方案选择 #

根据你的业务场景，分两种情况给出优化建议：

情况1：两个操作无数据依赖（如你的示例） #

如果第二个写入不需要用到第一个操作生成的数据（比如只是写入子集合文档），推荐使用Firestore的批量写入（Batch Write）。它的核心优势是：

• 原子性：所有操作要么全部成功，要么全部失败，避免出现“第一个成功、第二个失败”的不一致情况
• 代码更扁平，没有嵌套回调

Java代码示例：

// 获取Firestore实例和批量写入对象
FirebaseFirestore db = FirebaseFirestore.getInstance();
WriteBatch batch = db.batch();

// 第一个写入操作：写入客户文档
DocumentReference customerDoc = customerReference.document(customerName);
batch.set(customerDoc, customerDetails);

// 第二个写入操作：写入子集合的账单文档
DocumentReference invoiceDoc = customerDoc.collection(firebaseUser.getUid())
        .document(invoiceDate + " && " + timestampString);
batch.set(invoiceDoc, makeBillDetails);

// 提交批量操作
batch.commit()
    .addOnSuccessListener(aVoid -> {
        // 两个操作都成功时触发
        openPdf();
    })
    .addOnFailureListener(e -> {
        // 任一操作失败时统一处理
        Log.e("Firestore", "批量写入失败", e);
    });

情况2：第二个操作依赖第一个操作的结果 #

如果第二个操作需要用到第一个操作生成的数据（比如需要客户文档的ID、或者写入后返回的字段），那么顺序执行是必须的，此时可以用Java的CompletableFuture来简化回调嵌套，让代码更线性：

首先写一个工具方法，把Firestore的Task转换成CompletableFuture：

private <T> CompletableFuture<T> taskToFuture(Task<T> task) {
    CompletableFuture<T> future = new CompletableFuture<>();
    task.addOnSuccessListener(future::complete)
        .addOnFailureListener(future::completeExceptionally);
    return future;
}

然后用链式调用实现顺序执行：

// 第一个操作：写入客户文档
taskToFuture(customerReference.document(customerName).set(customerDetails))
    // 第一个成功后，执行第二个操作
    .thenCompose(aVoid -> {
        // 这里可以拿到第一个操作的结果（如果需要的话）
        DocumentReference invoiceDoc = customerReference.document(customerName)
                .collection(firebaseUser.getUid())
                .document(invoiceDate + " && " + timestampString);
        return taskToFuture(invoiceDoc.set(makeBillDetails));
    })
    // 两个操作都成功时打开PDF
    .thenRun(this::openPdf)
    // 统一处理任何一步的失败
    .exceptionally(e -> {
        Log.e("Firestore", "写入失败", e);
        return null;
    });

总结 #

你的原始嵌套回调实现是功能正确的，但如果想提升代码的可读性和维护性，可以根据是否有数据依赖选择对应的优化方案：

• 无依赖：用批量写入，兼顾原子性和代码简洁性
• 有依赖：用CompletableFuture消除嵌套回调，让代码逻辑更线性

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