Java mysql - SELECT 语句延迟主线程

Question

先前信息:数据库远程托管，平均连接延迟为 92 毫秒。

我有一个小型 MySQL 数据库，用于保存我的游戏的玩家数据。

每个玩家在迭代结果集时返回 250 行，并在登录游戏时分配玩家变量。

我的问题是，每次玩家登录时，我的游戏主线程都会延迟一小段时间，大约 200 毫秒。 (每个游戏周期有600ms)。

我发现这只发生在 SELECT 语句中，所有其他查询(例如 UPDATE、DELETE 或任何不返回 ResultSet 的查询)都可以。

我正在使用 c3p0 MySQL 池，这是我的配置:

    cpds.setInitialPoolSize(100);
    cpds.setMinPoolSize(100);
    cpds.setNumHelperThreads(200);
    cpds.setMaxIdleTime(0);
    cpds.setAcquireIncrement(10);
    cpds.setMaxPoolSize(200);
    cpds.setMaxStatements(0);

每次玩家登录时，都会执行大约 10 个查询，请求周围其他玩家的信息、他们当前的聊天服务器等。这些查询不能在单个语句中发出，这就是 c3p0 中多线程和连接的原因，以减少延迟，效果非常好。

正如我所说，只有需要 ResultSet 的 SELECT 查询才会发生这种情况。

问题是:我如何运行该查询，将结果分配给玩家变量，所有这一切都不会扰乱主线程 200 毫秒？

200ms可能会看到“ok”，但是如果50个玩家同时登录怎么办？这只会增加创建大量线程锁的时间。

我如何加载播放器:

登录时，需要这样做:

PlayerLoader.load(username);    

因此，将调用以下返回 Player 实例的方法:

public static Player load(String name) {
    ResultSet result = null;
    PreparedStatement ps = null;
    Player player = new Player();
    Connection con = null;
    try {
        con =  World.database().getConnection();
        ps =con.prepareStatement("SELECT * FROM " + PLAYER_TABLE + " WHERE username='" + name + "' LIMIT 1");
        result = ps.executeQuery();
        if (result.next()) {
            return player.playerSaving().load(result);
        }
    } catch (Exception e) {
        System.err.println("Error Loading the account: "+name);
        e.printStackTrace();
    } finally {
        try {
            if (result != null) {
                result.close();
            }
            result = null;
            ps.close();
            ps = null;
            con.close();
        } catch (SQLException e) {
        }
    }
    return null;
}    

获取 ResultSet 后，将调用另一个方法，该方法会将变量分配给播放器实例。

该方法包括:

        player.getPlayerDefinition().getIndex(result.getShort("id")).setDisplayName(result.getString("displayName"));
        player.getPlayerDefinition().setRights(result.getShort("rights"));
        player.getPlayerDefinition().setPlayTime(result.getLong("playTime"));
        player.getPlayerDefinition().setMuted(result.getInt("mute")).setMuteDuration(Long.parseLong(result.getString("muteTill")));
        player.getPlayerDefinition().setBanned(result.getLong("banned"));
        player.getPlayerDefinition().setPermBanned(result.getString("permBanned").equals("true"));
        player.getPlayerDefinition().setMemberDays2(result.getLong("member_days"));    

这只是它的一个简短版本。目前它加载了全部 250 行。

该方法还返回 Player 实例，因此第一个 Load 方法将返回它。 (参见:public Player load(ResultSet result))

在该过程之后，随着实例创建并准备好继续，玩家现在请求有关他们的世界、聊天服务器等的信息，这大约是 6-7 个小查询，执行速度也相当快。大约 2-3 个查询是带有简短结果的 SELECT 语句。

同样，有什么方法可以在异步线程中运行该加载过程吗？如果是的话，怎么办？

谢谢。

Answer 1

我通过简单地创建另一个专用线程来处理登录就解决了这个问题。

线程如何工作:

• 玩家请求登录
• 请求排队等待执行，在专用线程中花费的时间不到 10 毫秒。
• 线程执行 Runnable，而不延迟主线程。