Firebase调用runTransaction后ValueEventListener短暂返回null快照如何解决？

问题表现 #

使用runTransaction执行数据更新时，绑定的ValueEventListener会在事务执行后短暂收到值为null的DataSnapshot，对应监听代码如下：

@Override
public void onDataChange(@NonNull DataSnapshot snapshot) {
    if (snapshot.getValue() == null) {
        Log.println(Log.ERROR, TAG, "onDataChange: WAS NULL!!!!");
    } else {
        // 执行业务逻辑
    }
}

并发事务场景下该空值会导致严重业务错误。 #

成因分析 #

1. 事务的doTransaction方法会优先以本地缓存的节点值作为初始假设值执行，若本地无对应缓存，第一次调用时读取到的MutableData为空。现有代码所有setValue逻辑都包裹在anObject != null判断内，空值场景下未对节点赋值就直接返回了Transaction.success(mutableData)，此时SDK会先在本地缓存将对应节点临时设为null，触发监听的空值回调。
2. 事务后续重试时会拉取服务端真实的非空值，进入非空分支执行setValue逻辑，服务端CAS校验通过后，SDK会将正确值同步回本地缓存，触发第二次正常回调，因此空值仅为短暂中间态。
3. Realtime Database事务默认开启本地事件优先触发机制，目的是提升前端响应速度，并发场景下事务重试次数增加，该中间态空值的出现概率会进一步升高。

解决方案 #

方案1：事务内补充空值兜底逻辑 #

若目标节点逻辑上必然存在，在读取到空值时直接终止事务，或初始化默认值，避免未赋值的MutableData被返回：

@NonNull
@Override
public Transaction.Result doTransaction(@NonNull MutableData mutableData) {
    MutableData childA = mutableData.child(Keys.A);
    ObjectA anObject = childA.getValue(ObjectA.class);
    // 新增空值处理逻辑
    if (anObject == null) {
        // 节点值不符合预期，终止事务
        return Transaction.abort();
        // 若允许初始化默认值，替换为下方逻辑
        // anObject = new ObjectA();
    }
    // 原有非空分支业务逻辑
    // ...
    return Transaction.success(mutableData);
}

方案2：监听侧兼容中间态空值 #

在onDataChange中增加空值过滤逻辑，逻辑上不可能为空的节点收到空值时直接跳过本次处理，等待最终状态回调：

@Override
public void onDataChange(@NonNull DataSnapshot snapshot) {
    if (snapshot.getValue() == null) {
        Log.println(Log.ERROR, TAG, "收到事务临时空值，跳过本次处理");
        return;
    }
    // 原有业务逻辑
}

方案3：关闭本地中间态事件触发 #

调用runTransaction时将第二个参数fireEventsAfterCommit设为true，此时仅当服务端确认事务执行成功后才会触发监听事件，不会返回本地中间态结果：

// 第二个参数设为true，关闭本地预事件触发
yourDatabaseRef.runTransaction(yourTransactionHandler, true);

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