【Java EE 学习 16 上】【dbcp数据库连接池】【c3p0数据库连接池】

 1 package day16.utils;
 2 
 3 import java.io.IOException;
 4 import java.lang.reflect.InvocationHandler;
 5 import java.lang.reflect.Method;
 6 import java.lang.reflect.Proxy;
 7 import java.sql.Connection;
 8 import java.sql.DriverManager;
 9 import java.sql.SQLException;
10 import java.util.LinkedList;
11 import java.util.Properties;
12 
13 public class JDBCUtils {
14     private static LinkedList<Connection>pool=new LinkedList<Connection>();//定义连接池，使用LinkedList能提高效率
15     static{
16         Properties properties=new Properties();
17         try {
18             properties.load(JDBCUtils.class.getClassLoader().getResourceAsStream("config.properties"));
19             String driver=properties.getProperty("driver");
20             String username=properties.getProperty("username");
21             String password=properties.getProperty("password");
22             String url=properties.getProperty("url");
23             int connectionMaxNum=Integer.parseInt(properties.getProperty("connectionMaxNum"));
24             Class.forName(driver);
25             for(int i=0;i<connectionMaxNum;i++)
26             {
27                 final Connection conn=DriverManager.getConnection(url, username, password);
28                 //关键的一步：进行代理设置。
29                 Object proxy=Proxy.newProxyInstance(
30                         JDBCUtils.class.getClassLoader()
31                         , new Class[]{Connection.class}, 
32                         new InvocationHandler() {
33                             @Override
34                             public Object invoke(Object proxy, Method method, Object[] args)
35                                     throws Throwable {
36                                 //如果调用了close方法，则不要关闭连接，而应当将连接回收。
37                                 if(method.getName().equals("close"))
38                                 {
39                                     synchronized(pool)
40                                     {
41                                         pool.addLast((Connection) proxy);//这里进行强制转换
42                                         System.out.println("调用了close方法！回收 "+proxy+" ,剩余连接数为"+pool.size());
43                                         pool.notify();//从等待池中唤醒任意一条线程
44                                     }
45                                     return null;//返回值是null表名拦截该方法的执行。这里的return位置非常重要，一不小心就会是的创建反射对象失败
46                                 }
47                                 //如果调用了其他的方法，则要放行
48                                 else
49                                 {
50                                     System.out.println("调用了 "+method.getName()+" 方法，放行！");
51                                     return method.invoke(conn, args);//注意这里的对象是conn，而不是其它对象
52                                 }
53                             }
54                         });
55 //                System.out.println(proxy);
56                 pool.addLast((Connection) proxy);//这里添加的一定是被代理的对象
57             }
58             System.out.println(pool);
59         } catch (IOException e) {
60             e.printStackTrace();
61         } catch (ClassNotFoundException e) {
62             e.printStackTrace();
63         } catch (SQLException e) {
64             e.printStackTrace();
65         }
66     }
67     //获得连接对象的方法
68     public static Connection getConnection()
69     {
70         synchronized (pool) {
71             if(pool.size()==0)
72             {
73                 System.out.println("连接池中没有可用连接，等待中------------");
74                 try {
75                     pool.wait();//等待的方式，使用的是pool*************************
76                 } catch (InterruptedException e) {
77                     e.printStackTrace();
78                 }
79                 return getConnection();//递归调用该方法目的是解锁之后重新获得连接
80             }
81             else
82             {
83                 Connection conn=pool.removeFirst();
84                 System.out.println("分配一条连接,剩余连接数目为"+pool.size());
85                 return conn;
86             }
87         }
88     }
89 }