Java：使来自多个客户端的并发 MySQL 查询同步

Question

我在一家游戏网吧工作，我们这里有一个系统（智能启动）来跟踪游戏许可证。我编写了一个与该系统接口的程序（实际上，它是后端 MySQL 数据库）。该程序旨在在客户端 PC 上运行，并且 (1) 查询数据库以从可用池中选择未使用的许可证，然后 (2) 将此许可证标记为客户端 PC 正在使用。

问题是，我有一个并发错误。该程序旨在同时在多台机器上启动，当这种情况发生时，一些机器通常会尝试获取相同的许可证。我认为这是因为步骤 (1) 和 (2) 不同步，即一个程序确定许可证 #5 可用并选择它，但在它可以将 #5 标记为正在使用之前，另一台 PC 上的程序的另一个副本尝试获取相同的许可证。

我尝试通过使用事务和表锁定来解决这个问题，但它似乎没有任何区别 - 我这样做对吗？下面是有问题的代码：

    public LicenseKey Acquire() throws SmartLaunchException, SQLException {
    Connection conn = SmartLaunchDB.getConnection();
    int PCID = SmartLaunchDB.getCurrentPCID();

    conn.createStatement().execute("LOCK TABLE `licensekeys` WRITE");

    String sql = "SELECT * FROM `licensekeys` WHERE `InUseByPC` = 0 AND LicenseSetupID = ? ORDER BY `ID` DESC LIMIT 1";
    PreparedStatement statement = conn.prepareStatement(sql);
    statement.setInt(1, this.id);
    ResultSet results = statement.executeQuery();

    if (results.next()) {
        int licenseID = results.getInt("ID");
        sql = "UPDATE `licensekeys` SET `InUseByPC` = ? WHERE `ID` = ?";
        statement = conn.prepareStatement(sql);
        statement.setInt(1, PCID);
        statement.setInt(2, licenseID);
        statement.executeUpdate();
        statement.close();
        conn.commit();
        conn.createStatement().execute("UNLOCK TABLES");
        return new LicenseKey(results.getInt("ID"), this, results.getString("LicenseKey"), results.getInt("LicenseKeyType"));
    } else {
        throw new SmartLaunchException("All licenses of type " + this.name + "are in use");
    }
}

Answer 1

你必须做两件事：

• 将您的代码包装在事务中（以避免自动提交立即释放锁）
• 使用 SELECT ... FOR UPDATE 和 mysql 会给你你需要的锁（在提交时释放）

SELECT ... FOR UPDATE 比 LOCK TABLE 更好，因为它可以通过行级锁定来解决，而不是自动锁定整个表

Answer 2

根据online manual，正确的加锁语法是：

LOCK TABLES ...

你有

LOCK TABLE ...

但是您没有任何错误检查。因此，您可能无法获得锁，而它会默默地忽略它。

FWIW，我会将您的清理代码（UNLOCK TABLES、conn.commit() 等）放在 finally 块中，以确保您在发生异常时始终正确清理。

事实上，您似乎可能会泄漏数据库连接句柄，并且如果没有免费许可证，则永远不会释放锁。

Answer 3

我想建议只做一个更新语句并检查更新了多少行。我会用psudo代码写出来。

int uniqueId = SmartLaunchDB.getCurrentPCID();;
int updatedRows = execute('UPDATE `licensekeys` SET `InUseByPC` = uniqueId WHERE `InUseByPC` NOT null LIMIT1')
if (updatedRows == 1)
   SUCCESS
else
   FAIL

如果成功，您可以通过选择获取许可证密钥/ID。

Answer 4

通常情况下，OP 是个白痴。我发布的代码实际上是有效的，但我刚刚在数据库中发现了一个重复的行——我猜有人错误地输入了同一个许可证两次。这让我相信我已经修复的并发错误（通过引入表锁）仍未修复。

感谢您的一般建议，我已经为这个方法引入了更好的异常处理。