黑马程序员技术交流社区

标题: 动态代理出了问题，求帮忙 [打印本页]
作者: CrazyProgram    时间: 2013-4-30 18:52
标题: 动态代理出了问题，求帮忙

  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;

  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;

  3. import java.sql.Connection;
  4. import java.sql.SQLException;

  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. }
复制代码




欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2