先說明一下，我本身是做android開發的，java web是我的弱項，只是近來京東雲免費，於是去折騰了幾下，有了些許經驗，特作分享。如果文章中內容有誤，還請各高手指正。

我在web端，需要連線資料庫進行查詢插入等操作，但是每次進行操作都先獲取連線用完後就斷開的話，未免效率太低。以前知道tomcat中可以配置，但是京東雲引擎的tomcat並不能由自己配置。因為我折騰的東西較小，所以也不考慮使用框架，於是就想自己寫一個。

我寫的連線池很簡單，在初始化時建立5個連線，並放在一個列表當中。如果要獲取連線，從列表中獲取，同時列表移除，還回來時，列表新增上。也就是列表儲存的是閒置的連線。

如果列表已經為空了，那麼判斷是否超過最大連線了，沒有就建立，有的話就等待。當然，我這裡做的是很簡單的實現，所以沒有去做等待超時等處理。

程式碼如下：

package com.githang.tucao.web.dbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.LinkedList;

public class DatabaseConnection {
    private static final String CREATE_TABLE_TWITTER = "CREATE TABLE IF NOT EXISTS twitter (id INTEGER NOT NULL AUTO_INCREMENT PRIMARY KEY, msg varchar(300) not null) DEFAULT CHARSET=utf8";
    final static String HOST = "host";
    final static String PORT = "port";
    final static String DB_NAME = "dbname";
    final static String USERNAME = "username";
    final static String PASSWORD = "password";
    final static String url = "jdbc:mysql://" + HOST + ":" + PORT + "/" + DB_NAME
            + "?useUnicode=true&characterEncoding=utf-8";
    private static final DatabaseConnection instance = new DatabaseConnection();
    private final int INIT_COUNT = 5;
    private final int MAX_COUNT = 30;
    private int count = 0;
    
    private final Object wait = new Object();
    
    private  LinkedList<Connection> CONN_POOL;

    private DatabaseConnection() {
        CONN_POOL = new LinkedList<Connection>();
        try {
            Class.forName("com.mysql.jdbc.Driver");
            for (int i = 0; i < INIT_COUNT; i++) {
                Connection connection = createConnection();
                if(connection != null) {
                    CONN_POOL.add(createConnection());
                    count++;
                }
            }
     //       Connection connection = getConnection();
     //       Statement stmt = connection.createStatement();
     //       stmt.execute(CREATE_TABLE_TWITTER);
     //       stmt.execute("set names 'utf-8'");
     //       stmt.close();
     //       releaseConnection(connection);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    
    public static DatabaseConnection getInstance() {
        return instance;
    }
    
    private static Connection createConnection() {
        try {
            return DriverManager.getConnection(url, USERNAME, PASSWORD);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return null;
    }

    public Connection getConnection() {
        synchronized (CONN_POOL) {
            while(CONN_POOL.size() > 0) {
                Connection conn = CONN_POOL.removeLast();
                try {
                    if(conn.isValid(1000)) {
                        return conn;
                    } else {
                        count--;
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(count < MAX_COUNT) {
                count++;
                return createConnection();
            } 
            synchronized (wait) {
                try {
                    wait.wait(3000);
                    if(CONN_POOL.size() > 0) {
                        return CONN_POOL.removeLast();
                    }
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
        return null;
    }

    public void releaseConnection(Connection connection) {
        CONN_POOL.add(connection);
        synchronized (wait) {
            wait.notify();
        }
    }
    
}
 

wait物件用於執行緒同步鎖，主要是獲取不到連線並且需要等其他連線被還回來時使用，在getConnection()裡面呼叫 wait，而在releaseConnection()方法中，也就是釋放連線時，呼叫 notify通知其他等待的執行緒。

另外，在公用的資料庫當中，資料庫連線通常是不作長連線的。所以在這裡連線池中的連線，可能是已經斷開的或者是無效的，所以在獲取連線時需要判斷一下當前拿到的連線是否還有效。沒有的話就拿下一個。