JAVA數(shù)據(jù)庫連接池實(shí)現(xiàn)
博客分類：
? 數(shù)據(jù)庫連接池
JAVA數(shù)據(jù)庫連接池連接池原理連接池實(shí)現(xiàn)JAVA連接池
連接池的管理用了了享元模式，這里對連接池進(jìn)行簡單設(shè)計(jì)。
一、設(shè)計(jì)思路
1.連接池配置屬性DBbean：里面存放可以配置的一些屬性
2.連接池接口IConnectionPool：里面定義一些基本的獲取連接的一些方法
3.接口實(shí)現(xiàn)ConnectionPool：對上面操作進(jìn)行實(shí)現(xiàn)，并加入一些其他方法
4.連接池管理ConnectionPoolManager：管理所有的不同的連接池，所有的連接都能通過這里進(jìn)行獲得連接
5.另外還有幾個測試類，和連接信息模擬的類，這里就不進(jìn)行xml 和配置文件信息的讀取了
Java代碼

1. package pool; 2. /** 3. * 這是外部可以配置的連接池屬性 4. * 可以允許外部配置，擁有默認(rèn)值 5. * @author Ran 6. * 7. */ 8. public class DBbean { 9. // 連接池屬性 10. private String driverName; 11. private String url; 12. private String userName; 13. private String password; 14. // 連接池名字 15. private String poolName; 16. private int minConnections = 1; // 空閑池，最小連接數(shù) 17. private int maxConnections = 10; // 空閑池，最大連接數(shù) 18. 19. private int initConnections = 5;// 初始化連接數(shù) 20. 21. private long connTimeOut = 1000;// 重復(fù)獲得連接的頻率 22. 23. private int maxActiveConnections = 100;// 最大允許的連接數(shù)，和數(shù)據(jù)庫對應(yīng) 24. 25. private long connectionTimeOut = 1000*60*20;// 連接超時(shí)時(shí)間，默認(rèn)20分鐘 26. 27. private boolean isCurrentConnection = true; // 是否獲得當(dāng)前連接，默認(rèn)true 28. 29. private boolean isCheakPool = true; // 是否定時(shí)檢查連接池 30. private long lazyCheck = 1000*60*60;// 延遲多少時(shí)間后開始 檢查 31. private long periodCheck = 1000*60*60;// 檢查頻率 32. 33. 34. 35. public DBbean(String driverName, String url, String userName, 36. String password, String poolName) { 37. super(); 38. this.driverName = driverName; 39. this.url = url; 40. this.userName = userName; 41. this.password = password; 42. this.poolName = poolName; 43. } 44. public DBbean() { 45. } 46. public String getDriverName() { 47. if(driverName == null){ 48. driverName = this.getDriverName()+"_"+this.getUrl(); 49. } 50. return driverName; 51. } 52. public void setDriverName(String driverName) { 53. this.driverName = driverName; 54. } 55. public String getUrl() { 56. return url; 57. } 58. public void setUrl(String url) { 59. this.url = url; 60. } 61. public String getUserName() { 62. return userName; 63. } 64. public void setUserName(String userName) { 65. this.userName = userName; 66. } 67. public String getPassword() { 68. return password; 69. } 70. public void setPassword(String password) { 71. this.password = password; 72. } 73. public String getPoolName() { 74. return poolName; 75. } 76. public void setPoolName(String poolName) { 77. this.poolName = poolName; 78. } 79. public int getMinConnections() { 80. return minConnections; 81. } 82. public void setMinConnections(int minConnections) { 83. this.minConnections = minConnections; 84. } 85. public int getMaxConnections() { 86. return maxConnections; 87. } 88. public void setMaxConnections(int maxConnections) { 89. this.maxConnections = maxConnections; 90. } 91. public int getInitConnections() { 92. return initConnections; 93. } 94. public void setInitConnections(int initConnections) { 95. this.initConnections = initConnections; 96. } 97. 98. public int getMaxActiveConnections() { 99. return maxActiveConnections; 100. } 101. public void setMaxActiveConnections(int maxActiveConnections) { 102. this.maxActiveConnections = maxActiveConnections; 103. } 104. public long getConnTimeOut() { 105. return connTimeOut; 106. } 107. public void setConnTimeOut(long connTimeOut) { 108. this.connTimeOut = connTimeOut; 109. } 110. public long getConnectionTimeOut() { 111. return connectionTimeOut; 112. } 113. public void setConnectionTimeOut(long connectionTimeOut) { 114. this.connectionTimeOut = connectionTimeOut; 115. } 116. public boolean isCurrentConnection() { 117. return isCurrentConnection; 118. } 119. public void setCurrentConnection(boolean isCurrentConnection) { 120. this.isCurrentConnection = isCurrentConnection; 121. } 122. public long getLazyCheck() { 123. return lazyCheck; 124. } 125. public void setLazyCheck(long lazyCheck) { 126. this.lazyCheck = lazyCheck; 127. } 128. public long getPeriodCheck() { 129. return periodCheck; 130. } 131. public void setPeriodCheck(long periodCheck) { 132. this.periodCheck = periodCheck; 133. } 134. public boolean isCheakPool() { 135. return isCheakPool; 136. } 137. public void setCheakPool(boolean isCheakPool) { 138. this.isCheakPool = isCheakPool; 139. } 140. 141. 142. 143. }

Java代碼

1. package pool; 2. 3. import java.sql.Connection; 4. import java.sql.SQLException; 5. 6. public interface IConnectionPool { 7. // 獲得連接 8. public Connection getConnection(); 9. // 獲得當(dāng)前連接 10. public Connection getCurrentConnecton(); 11. // 回收連接 12. public void releaseConn(Connection conn) throws SQLException; 13. // 銷毀清空 14. public void destroy(); 15. // 連接池是活動狀態(tài) 16. public boolean isActive(); 17. // 定時(shí)器，檢查連接池 18. public void cheackPool(); 19. }

Java代碼

1. package pool; 2. 3. import java.sql.Connection; 4. import java.sql.DriverManager; 5. import java.sql.SQLException; 6. import java.util.List; 7. import java.util.Timer; 8. import java.util.TimerTask; 9. import java.util.Vector; 10. 11. public class ConnectionPool implements IConnectionPool { 12. // 連接池配置屬性 13. private DBbean dbBean; 14. private boolean isActive = false; // 連接池活動狀態(tài) 15. private int contActive = 0;// 記錄創(chuàng)建的總的連接數(shù) 16. 17. // 空閑連接 18. private List<Connection> freeConnection = new Vector<Connection>(); 19. // 活動連接 20. private List<Connection> activeConnection = new Vector<Connection>(); 21. // 將線程和連接綁定，保證事務(wù)能統(tǒng)一執(zhí)行 22. private static ThreadLocal<Connection> threadLocal = new ThreadLocal<Connection>(); 23. 24. public ConnectionPool(DBbean dbBean) { 25. super(); 26. this.dbBean = dbBean; 27. init(); 28. cheackPool(); 29. } 30. 31. // 初始化 32. public void init() { 33. try { 34. Class.forName(dbBean.getDriverName()); 35. for (int i = 0; i < dbBean.getInitConnections(); i++) { 36. Connection conn; 37. conn = newConnection(); 38. // 初始化最小連接數(shù) 39. if (conn != null) { 40. freeConnection.add(conn); 41. contActive++; 42. } 43. } 44. isActive = true; 45. } catch (ClassNotFoundException e) { 46. e.printStackTrace(); 47. } catch (SQLException e) { 48. e.printStackTrace(); 49. } 50. } 51. 52. // 獲得當(dāng)前連接 53. public Connection getCurrentConnecton(){ 54. // 默認(rèn)線程里面取 55. Connection conn = threadLocal.get(); 56. if(!isValid(conn)){ 57. conn = getConnection(); 58. } 59. return conn; 60. } 61. 62. // 獲得連接 63. public synchronized Connection getConnection() { 64. Connection conn = null; 65. try { 66. // 判斷是否超過最大連接數(shù)限制 67. if(contActive < this.dbBean.getMaxActiveConnections()){ 68. if (freeConnection.size() > 0) { 69. conn = freeConnection.get(0); 70. if (conn != null) { 71. threadLocal.set(conn); 72. } 73. freeConnection.remove(0); 74. } else { 75. conn = newConnection(); 76. } 77. 78. }else{ 79. // 繼續(xù)獲得連接,直到從新獲得連接 80. wait(this.dbBean.getConnTimeOut()); 81. conn = getConnection(); 82. } 83. if (isValid(conn)) { 84. activeConnection.add(conn); 85. contActive ++; 86. } 87. } catch (SQLException e) { 88. e.printStackTrace(); 89. } catch (ClassNotFoundException e) { 90. e.printStackTrace(); 91. } catch (InterruptedException e) { 92. e.printStackTrace(); 93. } 94. return conn; 95. } 96. 97. // 獲得新連接 98. private synchronized Connection newConnection() 99. throws ClassNotFoundException, SQLException { 100. Connection conn = null; 101. if (dbBean != null) { 102. Class.forName(dbBean.getDriverName()); 103. conn = DriverManager.getConnection(dbBean.getUrl(), 104. dbBean.getUserName(), dbBean.getPassword()); 105. } 106. return conn; 107. } 108. 109. // 釋放連接 110. public synchronized void releaseConn(Connection conn) throws SQLException { 111. if (isValid(conn)&& !(freeConnection.size() > dbBean.getMaxConnections())) { 112. freeConnection.add(conn); 113. activeConnection.remove(conn); 114. contActive --; 115. threadLocal.remove(); 116. // 喚醒所有正待等待的線程，去搶連接 117. notifyAll(); 118. } 119. } 120. 121. // 判斷連接是否可用 122. private boolean isValid(Connection conn) { 123. try { 124. if (conn == null || conn.isClosed()) { 125. return false; 126. } 127. } catch (SQLException e) { 128. e.printStackTrace(); 129. } 130. return true; 131. } 132. 133. // 銷毀連接池 134. public synchronized void destroy() { 135. for (Connection conn : freeConnection) { 136. try { 137. if (isValid(conn)) { 138. conn.close(); 139. } 140. } catch (SQLException e) { 141. e.printStackTrace(); 142. } 143. } 144. for (Connection conn : activeConnection) { 145. try { 146. if (isValid(conn)) { 147. conn.close(); 148. } 149. } catch (SQLException e) { 150. e.printStackTrace(); 151. } 152. } 153. isActive = false; 154. contActive = 0; 155. } 156. 157. // 連接池狀態(tài) 158. @Override 159. public boolean isActive() { 160. return isActive; 161. } 162. 163. // 定時(shí)檢查連接池情況 164. @Override 165. public void cheackPool() { 166. if(dbBean.isCheakPool()){ 167. new Timer().schedule(new TimerTask() { 168. @Override 169. public void run() { 170. // 1.對線程里面的連接狀態(tài) 171. // 2.連接池最小 最大連接數(shù) 172. // 3.其他狀態(tài)進(jìn)行檢查，因?yàn)檫@里還需要寫幾個線程管理的類，暫時(shí)就不添加了 173. System.out.println("空線池連接數(shù)："+freeConnection.size()); 174. System.out.println("活動連接數(shù)：："+activeConnection.size()); 175. System.out.println("總的連接數(shù)："+contActive); 176. } 177. },dbBean.getLazyCheck(),dbBean.getPeriodCheck()); 178. } 179. } 180. }

Java代碼
1. package pool;
2.
3. import java.sql.Connection;
4. import java.sql.SQLException;
5. import java.util.Hashtable;
6. /**
7. * 連接管理類
8. * @author Ran
9. *
10. */
11. public class ConnectionPoolManager {
12.
13.
14. // 連接池存放
15. public Hashtable

1. package pool; 2. 3. import java.sql.Connection; 4. /** 5. * 模擬線程啟動，去獲得連接 6. * @author Ran 7. * 8. */ 9. public class ThreadConnection implements Runnable{ 10. private IConnectionPool pool; 11. @Override 12. public void run() { 13. pool = ConnectionPoolManager.getInstance().getPool("testPool"); 14. } 15. 16. public Connection getConnection(){ 17. Connection conn = null; 18. if(pool != null && pool.isActive()){ 19. conn = pool.getConnection(); 20. } 21. return conn; 22. } 23. 24. public Connection getCurrentConnection(){ 25. Connection conn = null; 26. if(pool != null && pool.isActive()){ 27. conn = pool.getCurrentConnecton(); 28. } 29. return conn; 30. } 31. }

Java代碼

1. package pool; 5. public class Client { 6. public static void main(String[] args) throws InterruptedException { 7. // 初始化連接池 8. Thread t = init(); 9. t.start(); 10. t.join(); 11. 12. ThreadConnection a = new ThreadConnection(); 13. ThreadConnection b = new ThreadConnection(); 14. ThreadConnection c = new ThreadConnection(); 15. Thread t1 = new Thread(a); 16. Thread t2 = new Thread(b); 17. Thread t3 = new Thread(c); 18. 19. 20. // 設(shè)置優(yōu)先級，先讓初始化執(zhí)行，模擬 線程池 先啟動 21. // 這里僅僅表面控制了，因?yàn)榧词箃 線程先啟動，也不能保證pool 初始化完成，為了簡單模擬，這里先這樣寫了 22. t1.setPriority(10); 23. t2.setPriority(10); 24. t3.setPriority(10); 25. t1.start(); 26. t2.start(); 27. t3.start(); 28. 29. System.out.println("線程A-> "+a.getConnection()); 30. System.out.println("線程B-> "+b.getConnection()); 31. System.out.println("線程C-> "+c.getConnection()); 32. } 33. 34. // 初始化 35. public static Thread init() { 36. Thread t = new Thread(new Runnable() { 37. @Override 38. public void run() { 39. IConnectionPool pool = initPool(); 40. while(pool == null || !pool.isActive()){ 41. pool = initPool(); 42. } 43. } 44. }); 45. return t; 46. } 47. 48. public static IConnectionPool initPool(){ 49. return ConnectionPoolManager.getInstance().getPool("testPool"); 50. } 51. 52. }

小結(jié) ：
1.連接池誕生原因是，如果每次都從數(shù)據(jù)庫獲得連接，時(shí)間比較長，因此我們提前做建立一些連接，放在連接池里面，每次都從里面取
2.上面僅僅寫了連接池基本原理，關(guān)于多線程下連接池的管理沒寫，后面對多線程操作熟練了添加吧

總結(jié)

以上是生活随笔為你收集整理的多线程情况下创建连接池的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。