小编典典

不同的交易必须保证选择不同的项目;避免争执

sql

作为注册新用户的一部分;我们从预编译列表(表)中为他们分配资源(在这种情况下,为Solr核心)。

如果有5个用户注册,则必须为他们分配5个 不同的内核 ;如果用户成功注册,则分配完成(请参见下面的说明)。

但是在现实世界中,并发注册新用户 竞争同一行,而不是选择不同的行
。如果X需要5秒钟来注册,则X的“持续时间”中的Y和Z的注册将失败,因为它们争用X的同一行。

问题: 即使在高并发率(例如每秒100次注册)下,如何使交易选择而没有争用?

table: User
user_id   name  core   
      1    Amy h1-c1
      2    Anu h1-c1
      3    Raj h1-c1
      4    Ron h1-c2
      5    Jon h1-c2

table: FreeCoreSlots
core_id  core status   
      1 h1-c1   used
      2 h1-c1   used
      3 h1-c1   used
      4 h1-c2   used
      5 h1-c2   used #these went to above users already
      6 h1-c2   free
      7 h1-c2   free
      8 h1-c2   free
      9 h1-c2   free

伪代码(如果隔离了东西):

sql = SQLTransaction()
core_details = sql.get("select * from FreeCoreSlots limit 1")
sql.execute("update FreeCoreSlots set status = 'used' where id = {id}".format(
   id = core_details["id"]))
sql.execute("insert into users (name,core) values ({name},{core})".format(
   name = name,
   id   = core_details["id"]))
sql.commit()

如果第二次进行100次注册,则它们将 争夺第一行FreeCoreSlots并导致严重的失败。

有一个select … for更新,如InnoDB SELECT … FOR
UPDATE语句锁定表中的所有行作为解决方案,但它们似乎建议降低隔离度。这种方法正确吗?


阅读 218

收藏
2021-03-08

共1个答案

小编典典

我要问的问题是,为什么用户可能需要5秒钟才能完成。在START TRANSACTION和之间COMMIT应该只有几分之一秒。

为了防止FreeCoreSlots再次将同一行分配给同一用途,您必须再次使用SELECT for UPDATE。我认为锁定级别并不是真正的问题。设计数据库的下一个空闲行的FreeCoreSlots方式实际上已锁定,直到完成事务为止。请在下面查看我的测试结果。而且我确实认为,即使对于每秒100个新用户来说,这仍然足够。但是,如果您甚至想克服这一点,则必须找到一种方法来锁定其中的另一个下一个空闲行FreeCoreSlots给每个用户。不幸的是,没有“选择第一行,除非它有锁”的功能。也许改为使用一些随机或模数逻辑。但是,正如我已经说过的那样,即使对于不可思议的每秒100个新用户,我认为这也不应该是您的问题。如果我对此有错,请随时发表评论,我愿意再看一遍。

这是我的测试结果。默认的InnoDB锁定级别:不带的 可重复读取FOR UPDATE。这样就行不通了。

User 1:
    START TRANSACTION
    SELECT * FROM FreeCoreSlots WHERE status = 'FREE' LIMIT 1 -- returns id 1
User 2:
    START TRANSACTION
    SELECT * FROM FreeCoreSlots WHERE status = 'FREE' LIMIT 1 -- also returns id 1 !!!
User 1:
    UPDATE FreeCoreSlots SET status = 'USED' where ID = 1;
User 2:
    UPDATE FreeCoreSlots SET status = 'USED' where ID = 1; -- WAITS !!!
User 1:
    INSERT INTO user VALUES (...
    COMMIT;
USER 2:
    wait ends and updates also ID = 1 which is WRONG

锁定级别 可重复读取, 但带有FOR UPDATE。这样就可以了。

User 1:
    START TRANSACTION
    SELECT * FROM FreeCoreSlots WHERE status = 'FREE' LIMIT 1 FOR UPDATE -- returns id 1
User 2:
    START TRANSACTION
    SELECT * FROM FreeCoreSlots WHERE status = 'FREE' LIMIT 1 FOR UPDATE -- WAITS
User 1:
    UPDATE FreeCoreSlots SET status = 'USED' where ID = 1;
User 2:
    still waits
User 1:
    INSERT INTO user VALUES (...
    COMMIT;
USER 2:
    Gets back Id 2 from the select as the next free Id
2021-03-08