Firestore in Datastore Emulator事务冲突问题及解决方法咨询

核心原因 #

模拟器在--use-firestore-in-datastore-mode模式下，事务冲突检测逻辑和生产环境Datastore存在差异：它会过度扩大事务的锁范围——即使事务查询的是完全不存在的随机字段值，模拟器也会将整个实体种类（kind）标记为事务的读写依赖，导致并发事务互相触发冲突。而生产环境的Datastore只会针对实际存在的实体或索引条目加锁，当随机值查询无匹配结果时，不会产生全局的kind级锁。

解决办法 #

方法1：显式设置事务读取隔离级别（推荐） #

启动事务时指定读取一致性级别，限制模拟器的锁范围，使其行为对齐生产环境：

// 替换原transaction.run()调用
await transaction.run({ readOptions: { readConsistency: 'STRONG' } });

如果业务允许弱一致性，也可以使用：

await transaction.run({ readOptions: { readConsistency: 'EVENTUAL' } });

方法2：将查询移出事务 #

由于你的查询是检查随机生成的字段值是否存在（重复概率极低），可以把查询操作放在事务外部执行，确认无匹配结果后再进入事务保存实体：

async function doTestTransaction(i : number)
{
    try
    {
        const field = Random.getGlobalIdentifier();
        // 事务外执行查询
        const [existing] = await datastore.runQuery(
            datastore.createQuery(kind).filter("field", "=", field).select("__key__").limit(1)
        );
        if (existing.length === 0) {
            const transaction = datastore.transaction();
            await transaction.run();
            transaction.save({
                key: datastore.key([kind, Random.getGlobalIdentifier()]), 
                data: {field}
            });
            await transaction.commit();
        }
    }
    catch(err)
    {
        console.log("ERROR : ", err)
    }
}

方法3：升级Cloud SDK及模拟器 #

Google会持续修复模拟器的兼容性问题，尝试更新到最新版本：

gcloud components update

部分旧版本模拟器存在该特定冲突检测bug，新版本可能已修复。

验证效果 #

调整后重新运行并发事务测试，模拟器应和生产环境一致，不再触发无意义的事务冲突。

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