【发布时间】：2015-02-17 23:05:37
【问题描述】：
先验信息：数据库是远程托管的，平均连接延迟为 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 语句。
再一次，有没有办法在异步线程中运行加载过程？如果是的话，怎么做？
谢谢。
【问题讨论】：
标签： java mysql multithreading asynchronous