我的主服务器上运行着一个H2服务器进程,允许TCP连接。
假设我要执行100个SQL查询:
SELECT * FROM TEST
并且,出于我自己的目的,我想对每个线程进行一次查询。让我们使用Connection
线程之间共享的一个和一个对象来完成此操作:
Connection
对象。Connection
调用SQL查询。上面的方法可以工作,但是会有点慢。当然,毕竟,如果有人正在使用Connection
,则其他人必须等待它。
那么,让我们Connection
为每个线程做一个:
Connection
对象并调用SQL查询。快得多了。但是我觉得100个连接有点浪费。也许50个连接就可以了。我听说我可以用JdbcConnectionPool
这种东西。
JdbcConnectionPool
最多50个连线的。pool.getConnection()
然后调用SQL查询。嗯 太慢了 如果有的话,它和第一种方法一样慢。也许出于好奇,我应该将最大连接数设置为100
...
...而且仍然很慢。奇怪的。据我了解,具有100个连接的池相当于为我的100个线程中的每个线程建立一个连接。
可能是什么问题?这是最后一个测试的代码:
import java.sql.Connection;
import java.sql.ResultSet;
import org.h2.jdbcx.JdbcConnectionPool;
public class App {
public static void main(String[] args) throws Exception {
Class.forName("org.h2.Driver");
JdbcConnectionPool pool = JdbcConnectionPool.create("url", "user", "password");
pool.setMaxConnections(100);
for (int i = 0; i < 100; ++i) {
Thread t = new Thread(new Client(i, pool));
t.start();
}
}
}
class Client implements Runnable {
int id;
JdbcConnectionPool pool;
public Client(int id, JdbcConnectionPool pool) {
this.id = id;
this.pool = pool;
}
public void run() {
try {
Connection conn = pool.getConnection();
ResultSet set = conn.createStatement().executeQuery("SELECT * FROM TEST");
if (set.next()) {
System.out.println("Finished " + id);
}
set.close();
conn.close();
}catch (Exception e) {
}
}
}
我正在使用H2 1.4.182
。
JdbcConnectionPool#getConnection()的源代码:
public Connection getConnection() throws SQLException {
long max = System.currentTimeMillis() + timeout * 1000;
do {
synchronized (this){
if (activeConnections < maxConnections) {
return getConnectionNow();
}
try {
wait(1000);
} catch (InterruptedException e) {
// ignore
}
}
} while (System.currentTimeMillis() <= max);
throw new SQLException("Login timeout", "08001", 8001);
}
您的示例中最昂贵的操作之一是创建连接。如您所见,该方法getConnection()
具有同步的锁(此),因此只有一个线程可以同时创建连接,而所有其他线程都处于等待状态。
我相信内置的H2连接池非常简单。如果您想拥有高性能的连接池,可以查看C3P0或BoneCP。
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句