因为工作需要要使用到连接池，所以拜读了互联网上众多前辈的文章，学了不少经验，这里想做一个小结，加上自己的想法和在一起，希望能给大家一些帮助。

　　目的：

• 消除数据库频繁连接带来的开销和瓶颈。

　　解决方案：

• 不过多的限制用户的使用，既不能太多的要求用户按规定的方法得到和使用数据库连

• 尽量保持用户的习惯

　　目前的很多方法都是要求用户只能按规定方法使用连接，不能使用直接关闭数据连接的方法。解决办法就是使用代理类，来中间解决。可以参考http://www-900.ibm.com/developerWorks/cn/java/l-connpoolproxy/index.shtml

• 能维护连接的正常状态

　　因为针对数据库连接创建的资源，如果不能及时的释放，就会影响下一次数据连接的使用。例如在sql 2k中，一个连接不同创建多条Statement否则操作时会有数据连接占线的异常，所以必须在归还连接以后释放这些资源。

//判断是使用了createStatement语句    if (CREATESTATE.equals(method.getName()))    {     obj = method.invoke(conn, args);     statRef = (Statement)obj;//记录语句     return obj;    }

//判断是否调用了close的方法，如果调用close方法则把连接置为无用状态    if(CLOSE.equals(method.getName()))    {     //设置不使用标志     setIsFree(false);     //检查是否有后续工作，清除该连接无用资源     if (statRef != null)      statRef.close();     if (prestatRef != null)      prestatRef.close();     return null;    }

• 正确保护类不被违例使用

一个考虑就是不能让用户随便使用代理类，而只能自己使用，一个就是用内部私有类，一个就是使用只有指定类才能调用的标志。我的实现就是采用后者。

/**   * 创建连接的工厂，只能让工厂调用   * @param factory 要调用工厂，并且一定被正确初始化   * @param param 连接参数   * @return 连接   */  static public _Connection getConnection(ConnectionFactory factory, ConnectionParam param)  {   if (factory.isCreate())//判断是否正确初始化的工厂   {    _Connection _conn = new _Connection(param);    return _conn;   }   else    return null;  }

• 提供良好的用户接口，简单实用

　　使用静态方法创建工厂，然后来得到连接，使用完全和普通的Connection方法一样，没有限制。同时为了方便，设置了连接参数类和工厂参数类。

ConnectionParam param = new ConnectionParam(driver,url,user,password);   ConnectionFactory cf = null;//new ConnectionFactory(param, new FactoryParam());   try{    cf = new ConnectionFactory(param,new FactoryParam());    Connection conn1 = cf.getFreeConnection();    Connection conn2 = cf.getFreeConnection();    Connection conn3 = cf.getFreeConnection();    Statement stmt = conn1.createStatement();    ResultSet rs = stmt.executeQuery("select * from requests");    if (rs.next())    {     System.out.println("conn1 y");      }    else    {     System.out.println("conn1 n");      }     stmt.close();    conn1.close();



• 为了实现连接池的正常运作，使用了单态模

/**   * 使用指定的参数创建一个连接池   */  public ConnectionFactory(ConnectionParam param, FactoryParam fparam)   throws SQLException  {   //不允许参数为空   if ((param == null)||(fparam == null))    throw new SQLException("ConnectionParam和FactoryParam不能为空");   if (m_instance == null)   {    synchronized(ConnectionFactory.class){     if (m_instance == null)     {      //new instance      //参数定制      m_instance = new ConnectionFactory();      m_instance.connparam = param;      m_instance.MaxConnectionCount = fparam.getMaxConn();      m_instance.MinConnectionCount = fparam.getMinConn();      m_instance.ManageType = fparam.getType();      m_instance.isflag = true;      //初始化，创建MinConnectionCount个连接      System.out.println("connection factory 创建！");      try{       for (int i=0; i < m_instance.MinConnectionCount; i++)       {        _Connection _conn = _Connection.getConnection(m_instance, m_instance.connparam);        if (_conn == null) continue;        System.out.println("connection创建");        m_instance.FreeConnectionPool.add(_conn);//加入空闲连接池        m_instance.current_conn_count ++;        //标志是否支持事务        m_instance.supportTransaction = _conn.isSupportTransaction();           }      }      catch(Exception e)      {       e.printStackTrace();      }      //根据策略判断是否需要查询      if (m_instance.ManageType != 0)      {       Thread t = new Thread(new FactoryMangeThread(m_instance));       t.start();      }      }    }   }  }

• 连接池的管理

　　对于连接池的管理，我是设想使用静态管理和动态管理两种策略，设置了最大限制，和恒定的连接数。使用了2个池，一个空闲池，一个使用池。静态就是使用的时候发现空闲连接不够再去检查。动态就是使用了一个线程定时检查。

//根据策略判断是否需要查询      if (m_instance.ManageType != 0)      {       Thread t = new Thread(new FactoryMangeThread(m_instance));       t.start();      }  //连接池调度线程 public class FactoryMangeThread implements Runnable {  ConnectionFactory cf = null;  long delay = 1000;  public FactoryMangeThread(ConnectionFactory obj)  {   cf = obj;  }  /* (non-Javadoc)   * @see java.lang.Runnable#run()   */  public void run() {   while(true){    try{     Thread.sleep(delay);    }    catch(InterruptedException e){}    System.out.println("eeeee");    //判断是否已经关闭了工厂，那就退出监听    if (cf.isCreate())     cf.schedule();    else     System.exit(1);   }  } }