Java mysql - SELECT 语句延迟主线程

Question

先验信息：数据库是远程托管的，连接平均延迟 92 毫秒。

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

每个玩家 return 在遍历结果集时有 250 行，在他们登录游戏时分配玩家变量。

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

我发现这只发生在 SELECT 语句中，所有其他查询如 UPDATE、DELETE 或任何不 return 结果集的查询都很好。

我正在使用 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 中，减少延迟，效果很好。

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

问题是：我将如何运行该查询，将结果分配给播放器变量，而不会弄乱主线程 200 毫秒？

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

我如何加载播放器：

登录时要求：

PlayerLoader.load(username);

因此调用 return 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;
}

获取结果集后，调用另一个方法，将变量分配给播放器实例。

该方法包括：

        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 行。

该方法还 return 播放器实例，因此第一个加载方法将 return 它。（参见：public Player load(ResultSet result)）

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

同样，有没有什么方法可以运行在异步线程中加载进程？如果是，怎么办？

谢谢。

Answer 1

您可以将耗时的操作卸载到不同的线程，并在加载完成时获得事件通知。这类似于 Swing UI 事件分派模型，因此您可以继续阅读：http://www.oracle.com/technetwork/articles/javase/swingworker-137249.html

Answer 2

你的问题是 JDBC 阻塞了。

如果您将应用程序部署到 Web 服务器，则可以通过使用线程池来减少阻塞方式的影响。在这种情况下，可以并发处理的请求数取决于线程池的大小。

Answer 3

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

线程的工作原理：

玩家请求登录
请求在专用线程中排队等待执行，耗时不到 10 毫秒。
Thread 执行 Runnable，不延迟 Main Thread。

Java mysql - SELECT 语句延迟主线程

Java mysql - SELECT statements delaying main thread

java

mysql

multithreading

asynchronous