在大表数据存储中,对于并发性,如何“锁定”一个实体?

您有几个选项:

• 根据计数器和实体的范围,将事务实体作为计数器的子实体。然后,您可以插入一个事务并更新计数器 transactionally . 请记住,这将您的更新率限制在1-5 qps左右。
• 如果您的计数不必100%准确,请插入实体并单独更新计数器(使用单个实体事务)。您可以运行一个常规的cronjob来重新计算实体的数量,并在错误导致计数器不同步时修复计数器。
• 你可以建立自己的 limited distributed transaction support .

除了尼克给出的选择外,你还可以考虑把柜台切碎。

保留多个计数器,并选择一个计数器进行更新,以使(理想情况下)不可能或(失败时)任何两个请求都不可能同时选择同一个碎片。

然后你有更多的选择。您可以使用shard作为父级进行事务处理(与单个计数器相比,这减少了争用),尽管最终您的新事务实体会任意选择父级。或者不必为交易费心,在这种情况下,你可能需要不时地修正计数,就像尼克的非交易选项一样。

要读取总计数,需要将所有碎片相加。你不会“同时”阅读它们,但这通常是好的。读取任何计数器时,它可能会在您读取它和使用该值之间增加,因此该值实际上只是一个下限。加上碎片没有什么不同,只是可能需要更长的时间。