1. 
   
2. import java.lang.reflect.InvocationHandler;
   
3. import java.lang.reflect.Method;
   
4. import java.lang.reflect.Proxy;
   
5. import java.sql.Connection;
   
6. import java.sql.DriverManager;
   
7. import java.util.LinkedList;
   
8. 
   
9. //自定义连接池
   
10. public class Pool {
    
11.         private static LinkedList<Connection> linkedList = new LinkedList<Connection>();
    
12.         static{
    
13.                 //在加载Pool类时，创建10个连接，并加入到连接池中
    
14.                 for(int i=0;i<10;i++){
    
15.                         try {
    
16.                                 Class.forName("com.mysql.jdbc.Driver");
    
17.                                 Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/bbs","root","zhiwei");
    
18.                                 linkedList.addLast(conn);
    
19.                         } catch (Exception e) {
    
20.                         }
    
21.                 }
    
22.         }
    
23.         //取得连接池中连接的个数
    
24.         public int getSize() {
    
25.                 return linkedList.size();
    
26.         }
    
27.         //取得一个空闲的连接，只能返回Connection的动态代理对象
    
28.         public Connection getConnection() {
    
29.                 final Connection conn = linkedList.removeFirst();
    
30.                 return (Connection) Proxy.newProxyInstance(
    
31.                                 Pool.class.getClassLoader(),
    
32.                                 conn.getClass().getInterfaces(),
    
33.                                 new InvocationHandler(){
    
34.                                         public Object invoke(
    
35.                                                         Object proxy,
    
36.                                                         Method method,
    
37.                                                         Object[] args) throws Throwable {
    
38.                                                 //如果调用的是close()方法
    
39.                                                 if("close".equals(method.getName())){
    
40.                                                         //将连接放回连接池
    
41.                                                         linkedList.addLast(conn);
    
42.                                                         //返回null
    
43.                                                         return null;
    
44.                                                 }else{
    
45.                                                         return method.invoke(conn,args);
    
46.                                                 }
    
47.                                         }
    
48.                                 });
    
49.         }
    
50.        
    
51. }
    

复制代码

测试的类

1. package zhiwei.deng.web.reflect.pool;
   
2. 
   
3. import java.sql.Connection;
   
4. import java.sql.SQLException;
   
5. 
   
6. public class Test {
   
7.         public static void main(String[] args) throws Exception {
   
8.                 //创建连接池
   
9.                 Pool pool = new Pool();
   
10.                 //连接池的个数
    
11.                 System.out.println("开始的时候连接池的个数为"+pool.getSize());
    
12.                 //取得一个空闲的连接从连接池中
    
13.                 Connection conn = pool.getConnection();
    
14.                 System.out.println("取出一个后的个数为"+pool.getSize());
    
15.                 //关闭连接
    
16.                 conn.close();
    
17.                 System.out.println("关闭连接后的个数为"+pool.getSize());
    
18.         }
    
19. }
    

复制代码

1. 
   
2. import java.lang.reflect.InvocationHandler;
   
3. import java.lang.reflect.Method;
   
4. import java.lang.reflect.Proxy;
   
5. import java.sql.Connection;
   
6. import java.sql.DriverManager;
   
7. import java.util.LinkedList;
   
8. 
   
9. //自定义连接池
   
10. public class Pool {
    
11.         private static LinkedList<Connection> linkedList = new LinkedList<Connection>();
    
12.         static{
    
13.                 //在加载Pool类时，创建10个连接，并加入到连接池中
    
14.                 for(int i=0;i<10;i++){
    
15.                         try {
    
16.                                 Class.forName("com.mysql.jdbc.Driver");
    
17.                                 Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/bbs","root","zhiwei");
    
18.                                 linkedList.addLast(conn);
    
19.                         } catch (Exception e) {
    
20.                         }
    
21.                 }
    
22.         }
    
23.         //取得连接池中连接的个数
    
24.         public int getSize() {
    
25.                 return linkedList.size();
    
26.         }
    
27.         //取得一个空闲的连接，只能返回Connection的动态代理对象
    
28.         public Connection getConnection() {
    
29.                 final Connection conn = linkedList.removeFirst();
    
30.                 return (Connection) Proxy.newProxyInstance(
    
31.                                 Pool.class.getClassLoader(),
    
32.                                 conn.getClass().getInterfaces(),
    
33.                                 new InvocationHandler(){
    
34.                                         public Object invoke(
    
35.                                                         Object proxy,
    
36.                                                         Method method,
    
37.                                                         Object[] args) throws Throwable {
    
38.                                                 //如果调用的是close()方法
    
39.                                                 if("close".equals(method.getName())){
    
40.                                                         //将连接放回连接池
    
41.                                                         linkedList.addLast(conn);
    
42.                                                         //返回null
    
43.                                                         return null;
    
44.                                                 }else{
    
45.                                                         return method.invoke(conn,args);
    
46.                                                 }
    
47.                                         }
    
48.                                 });
    
49.         }
    
50.        
    
51. }
    

复制代码

测试的类

1. package zhiwei.deng.web.reflect.pool;
   
2. 
   
3. import java.sql.Connection;
   
4. import java.sql.SQLException;
   
5. 
   
6. public class Test {
   
7.         public static void main(String[] args) throws Exception {
   
8.                 //创建连接池
   
9.                 Pool pool = new Pool();
   
10.                 //连接池的个数
    
11.                 System.out.println("开始的时候连接池的个数为"+pool.getSize());
    
12.                 //取得一个空闲的连接从连接池中
    
13.                 Connection conn = pool.getConnection();
    
14.                 System.out.println("取出一个后的个数为"+pool.getSize());
    
15.                 //关闭连接
    
16.                 conn.close();
    
17.                 System.out.println("关闭连接后的个数为"+pool.getSize());
    
18.         }
    
19. }
    

复制代码