使用Firebase事务阻止Cloud Firestore挂起写入无效问题排查

Firestore的离线持久化默认处于开启状态，不管你使用单文档写入、批量操作（batch）还是事务，只要离线持久化未关闭，客户端就会自动缓存挂起的写入操作，等网络恢复后同步。事务的设计目标是保证数据一致性，而非阻止离线缓存——官方提到的用事务规避离线问题，是指避免离线时因数据冲突导致的异常，并非禁止挂起写入。

方案1：检查网络后再执行写入（推荐） #

直接判断设备当前是否联网，仅在联网时调用Firestore写入接口，从根源上避免离线操作被缓存。

示例代码（Android）：

// 检查网络连接状态
private boolean isNetworkConnected() {
    ConnectivityManager cm = (ConnectivityManager) getSystemService(Context.CONNECTIVITY_SERVICE);
    NetworkInfo activeNetwork = cm.getActiveNetworkInfo();
    return activeNetwork != null && activeNetwork.isConnectedOrConnecting();
}

// 按钮点击逻辑
if (isNetworkConnected()) {
    HashMap<String, Object> hashMap = new HashMap<>();
    hashMap.put("Name", "Test");

    FirebaseFirestore.getInstance().batch()
            .set(FirebaseFirestore.getInstance().collection("LISTS").document(), hashMap)
            .commit()
            .addOnCompleteListener(task -> {
                Toast.makeText(MainActivity.this, task.toString(), Toast.LENGTH_SHORT).show();
                if (task.isSuccessful()) {
                    activityMainBinding.activityMainMaterialToolbarTopBar.setTitle("Done");
                } else {
                    activityMainBinding.activityMainMaterialToolbarTopBar.setTitle(task.getException().getMessage());
                }
            });
} else {
    Toast.makeText(MainActivity.this, "无网络连接，无法执行操作", Toast.LENGTH_SHORT).show();
    activityMainBinding.activityMainMaterialToolbarTopBar.setTitle("无网络");
}

方案2：临时关闭离线持久化（不推荐全局关闭） #

如果不想全局关闭离线持久化，可以为该特定操作创建临时Firestore实例，关闭其离线持久化功能。注意：关闭后会影响该实例的所有操作，操作完成后可按需恢复。

示例代码：

// 创建禁用离线持久化的临时实例
FirebaseFirestoreSettings settings = new FirebaseFirestoreSettings.Builder()
        .setPersistenceEnabled(false)
        .build();
FirebaseFirestore tempFirestore = FirebaseFirestore.getInstance();
tempFirestore.setFirestoreSettings(settings);

// 执行批量写入
HashMap<String, Object> hashMap = new HashMap<>();
hashMap.put("Name", "Test");

tempFirestore.batch()
        .set(tempFirestore.collection("LISTS").document(), hashMap)
        .commit()
        .addOnCompleteListener(task -> {
            Toast.makeText(MainActivity.this, task.toString(), Toast.LENGTH_SHORT).show();
            if (task.isSuccessful()) {
                activityMainBinding.activityMainMaterialToolbarTopBar.setTitle("Done");
            } else {
                activityMainBinding.activityMainMaterialToolbarTopBar.setTitle(task.getException().getMessage());
            }
            // 恢复原实例的离线持久化（可选）
            FirebaseFirestore.getInstance().setFirestoreSettings(new FirebaseFirestoreSettings.Builder().setPersistenceEnabled(true).build());
        });

方案3：用enableNetwork()强制依赖网络 #

调用enableNetwork()后，Firestore操作必须依赖网络，无网络时写入会直接失败，不会缓存操作。

示例代码：

FirebaseFirestore db = FirebaseFirestore.getInstance();
db.enableNetwork()
        .addOnCompleteListener(networkTask -> {
            if (networkTask.isSuccessful()) {
                // 网络可用，执行写入
                HashMap<String, Object> hashMap = new HashMap<>();
                hashMap.put("Name", "Test");

                db.batch()
                        .set(db.collection("LISTS").document(), hashMap)
                        .commit()
                        .addOnCompleteListener(task -> {
                            Toast.makeText(MainActivity.this, task.toString(), Toast.LENGTH_SHORT).show();
                            if (task.isSuccessful()) {
                                activityMainBinding.activityMainMaterialToolbarTopBar.setTitle("Done");
                            } else {
                                activityMainBinding.activityMainMaterialToolbarTopBar.setTitle(task.getException().getMessage());
                            }
                        });
            } else {
                // 无网络，直接提示
                Toast.makeText(MainActivity.this, "无网络连接，无法执行操作", Toast.LENGTH_SHORT).show();
                activityMainBinding.activityMainMaterialToolbarTopBar.setTitle("无网络");
            }
        });

事务和批量操作无法规避离线挂起写入，这是Firestore离线持久化的默认行为。交付时间紧张的情况下，方案1是最稳妥且实现最快的选择，无需修改Firestore核心配置，仅需增加网络检查逻辑即可。

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