1.Mongo物件

2.DB物件

DB物件可以通過Mongo.get方法獲得，代表了和資料庫的一個連線。預設情況下，當執行完資料庫的查詢或者更新操作後，連線將自動回到連線池中。不需要我們手動呼叫程式碼放回池中。至於如何實現，我猜測是update,query,save方法內部有finally塊，那裡面有還連線到池中的程式碼。

3.手動還連線入池

DB物件也允許在一個連線上執行多個操作，比如下面的程式碼：



DB db...;
db.requestStart();

code....

db.requestDone();

4.示例程式碼，下面的類實現了Lazy loading的Singleton模式，裡面的成員變數Mongo mongo因此只會例項化一次。注意連線池大小和重連設定。

package com.freebird.helper;

import com.mongodb.Mongo;
import com.mongodb.MongoOptions;
import com.mongodb.DB;

/**
 * Describe class DBManager here.
 * example:
 * 初始化：DBManager.getInstance().init("74.208.78.5",27017,200);
 * 之後，每次通過下面的程式碼獲取資料庫物件
 * DBManager.getInstance().getDB();
 * Created: Sat Dec 17 10:45:24 2011
 *
 * @author <a href="mailto:
 
[email protected]">chenshu</a>
 * @version 1.0
 */
public class DBManager {

    public static final String DB_NAME = "kaimei";
    
    public static final String MESSAGE_COLLECTION = "email";

    public static DBManager getInstance(){
	return InnerHolder.INSTANCE;
    }

    /**
     * Creates a new <code>DBManager</code> instance.
     *
     */
    private DBManager() {
	
    }

    private static class InnerHolder{
	static final DBManager INSTANCE = new DBManager();
    }

    public DB getDB(){
	return mongo.getDB(DB_NAME);
    }

    private Mongo mongo;
    

    public void init(final String ip, int port, int poolSize) throws java.net.UnknownHostException {
        System.setProperty("MONGO.POOLSIZE", String.valueOf(poolSize));
        if (mongo == null) {
            mongo = new Mongo(ip, port);
            MongoOptions options = mongo.getMongoOptions();
            options.autoConnectRetry = true;
            options.connectionsPerHost = poolSize;
        }
    }
}