ETL工具完畢的差點兒相同了。今天遇到一個問題。就是給C3P0配置了maxPoolSize為10。目的是想讓整個應用同一時候獲得的最大的Connection個數為10,可是在測試應用的這一部分之后,發現PostgreSQL端的鏈接遠遠超過10個。由于工具是多線程的。所以就想,是不是多線程的問題,查了一下Connection的個數,也確實是10*線程個數。于是做了一個測試:
將maxPoolSize配置為5。執行以下的程序:
ComboPooledDataSource cpds = new ComboPooledDataSource("postgres");for (int i = 0; i < 10; i++) {cpds.getConnection();}
ComboPooledDataSource cpds2 = new ComboPooledDataSource("postgres");for (int i = 0; i < 10; i++) {cpds2.getConnection();}
maxPoolSize配置為5。一共想要獲取20個鏈接,這時查看PostgreSQL Server端的連接數為5,正式預期的結果。
在執行以下的程序:
for (int i = 0; i < 2; i++) {new Thread(new Runnable() {@Overridepublic void run() {ComboPooledDataSource cpds = new ComboPooledDataSource("postgres");for (int i = 0; i < 10; i++) {try {cpds.getConnection();} catch (SQLException e) {e.printStackTrace();}}try {Thread.sleep(100000);} catch (InterruptedException e) {e.printStackTrace();}}}, "Thread" + i).start();}
兩個線程,每一個線程想要獲取10個鏈接數,這時查看PostgreSQL Server端的鏈接數,是10個。將i<2改為i<3,在執行一次,查看PostgreSQL Server端的連接數是15。
再進行以下的測試:
final ComboPooledDataSource cpds = new ComboPooledDataSource("postgres");for (int i = 0; i < 3; i++) {new Thread(new Runnable() {@Overridepublic void run() {for (int i = 0; i < 10; i++) {try {cpds.getConnection();} catch (SQLException e) {e.printStackTrace();}}try {Thread.sleep(100000);} catch (InterruptedException e) {e.printStackTrace();}}}, "Thread" + i).start();
創建3個線程,每一個線程須要10個Connection,這時查看PostgreSQL Server端的連接數是5。可見,PostgreSQL Server端的鏈接的個數與client創建的ComboPooledDataSource實例的個數成正比。C3P0配置文件里配置的內容都是針對一個ComboPooledDataSource實例的限制。
結論:
底層的原因大概是由于C3P0不是為多線程設計的,在底層JDBC也不是線程安全的。
詳細的原因,有機會在詳細分析。
一個應用中一般一個數據源僅僅用一個ComboPooledDataSource對象,也就是一個ComboPooledDataSource實例。