소설같은JSP2부  8장 JDBC와 JSP  14 Pooling의 활용  

 

8.14 Pooling의 활용

 

이제 Connection Pool에 관한 예제를 살펴 보겠습니다. 예제를 보기 전에 이 ConnectionPool 클래스도 J2SDK에서 지원하는 클래스가 아니라, 단지 방법론을 이용해서 생성해본 클래스입니다. 스스로 좀 더 발전된 Connection Pool을 만들어보는 것도 좋은 방법이라 생각합니다.

 

PoolingTest.jsp

Pooling 클래스를 테스트하는 예제

<%@ page import = "java.sql.*, org.jabook.sql.*" contentType= "text/html;charset = euc-kr"%> 
<html><body>
<h3>ConnectionPool Class Test</h3>
<hr> 
<% 
  ConnectionPool pool = ConnectionPool.getInstance(); 
  Connection conn = pool.getConnection(); 
  if (conn != null) { 
  Statement stmt = conn.createStatement(); 
  ResultSet rs = stmt.executeQuery("SELECT * FROM MyTest"); 
%>
MyTest 테이블에서 ResultSet 가져오기<br> 
  <table border = "1" cellspacing="0" cellpadding="1"> 
  <tr bgcolor = "pink"> 
  <td><b>name</b></td> 
  <td><b>age</b></td> 
  </tr> 
<%
    while(rs.next()){ 
%>
  <tr> 
    <td><%=rs.getString(1)%></td> 
    <td><%=rs.getInt(2)%></td> 
  </tr> 
<% 
  }
    rs.close(); 
    stmt.close(); 
    pool.releaseConnection(conn); 
  }
%>
</table>
</body></html>

ConnectionPool.java

Pooling 클래스

package org.jabook.sql;
import java.sql.*;
import java.util.*;


public class ConnectionPool {
  private static ConnectionPool cp = null;
  private ConnectionFactory cf = null;
  private Vector pool = null;
  private int initCon = 0;  
  private int maxCon = 0;
  private int users = 0;
  private ConnectionPool(){}
  private ConnectionPool(int initCon, int maxCon) throws SQLException {
    this.initCon = initCon;
    this.maxCon = maxCon;
    cf = new ConnectionFactory();
    pool = new Vector();
    for (int i=0; i < initCon; i++) {
      pool.add(createConnection());
    }
  }


  public static synchronized ConnectionPool getInstance() throws SQLException {
    if (cp == null) {
      cp = new ConnectionPool(4,20);
    }
    return cp;
  }


  public synchronized Connection getConnection() throws SQLException {
    Connection conn = null;
    while ((conn = getPooledConnection()) == null)
    {
      try {
        wait();
      } catch (InterruptedException ie) {}
    }
    users++;
    return conn;
  }


  public synchronized void releaseConnection(Connection conn) {
    pool.add(conn);
    users--;
    notifyAll();
  }


  private Connection getPooledConnection() throws SQLException {
    Connection conn = null;
    int size = pool.size();
    if (size > 0) {
      conn = (Connection)(pool.elementAt(0));
      pool.removeElementAt(0);
    }  else if (users < maxCon || maxCon == 0) {
      pool.add(createConnection());
    }
    return conn;
  }


  private Connection createConnection()  throws SQLException {
    Connection conn = cf.getConnection(ConnectionFactory.MSSQL);
    System.out.println("== a connection was created");
    return conn;
  }
}

C:\jakarta\webapps\MySample\WEB-INF\classes>javac –d . ConnectionPool.java

 

먼저 JSP 파일에서 ConnectionPooling의 객체 pool을 얻기 위해 ConnectionPool 클래스의 getInstance 메서드를 호출하였습니다. 이 때 생성된 객체가 없으면 객체를 생성하고 있으면 객체를 반환합니다. 객체를 생성할 때 매개변수를 주어 초기에 생성할 Connection의 개수와 Max Connection 개수를 지정하고 있습니다.

 

n       public static synchronized ConnectionPool getInstance() throws SQLException {

n          if (cp == null) {

n             cp = new ConnectionPool(4,20);

n          }

n             return cp;

n       }

 

 이렇게 ConnectionPool의 객체 pool을 얻어 오면 Connection을 얻어 오기 위해 pool.getConnection 메서드를 호출합니다.

 

n       Connection conn = pool.getConnection();

 

 ConnectionPooling 클래스의 getConnection 메서드를 호출하면 내부적인 작용을 거쳐 Connection을 넘겨줍니다. getConnection 메서드는 pool에 만들어져 있는 Connection이 있는지 없는지를 확인하고 있다면 Connection 객체를 반환하고, 없다면 앞에서 설명한 ConnectionFactory 클래스를 사용하여 Connection 객체를 생성합니다.

 

n       public synchronized Connection getConnection() throws SQLException {

n          Connection conn = null;

n          while ((conn = getPooledConnection()) == null) {

n             try {

n                wait();

n             } catch (InterruptedException ie) {}

n          }

n          users++;

n          return conn;

n       }

 

JSP 파일은 Connection 객체를 얻어낸 후 자기의 작업을 완료합니다. 작업을 완료한 후 Connection 객체를 제외한 다른 연결을 종료합니다. Connection 객체는 종료시키는 것이 아니고, Connection Pool에 반환합니다. Connection 객체를 돌려받은 Connection Pool은 Connection 객체를 다시 사용할 수 있도록 저장을 합니다.

 

n       rs.close();

n       stmt.close();

n       pool.releaseConnection(conn);

 

한꺼번에 많은 작업이 일어날 가능성에 대비해서 메서드에 synchronized 키워드를 사용했습니다. 그리고, wait, notify 메서드도 사용하여 동기화 문제를 해결하였습니다. 더 자세한 내용을 보시려면 자북홈페이지(www.jabook.org)에서 소설 같은 자바 19장 JDBC편을 참고 하시기 바랍니다.



jabook저자명함
제목:소설같은JSP2부
저자:최영관