java操作mongodb（連接池）（轉）

原文鏈接： java操作mongodb（連接池）

 

Mongo的實例其實就是一個數據庫連接池，這個連接池里默認有10個鏈接。我們沒有必要重新實現這個鏈接池，但是我們可以更改這個連接池的配置。因為Mongo的實例就是一個連接池，所以，項目中最好只存在一個Mongo的實例。

常見的配置參數：

connectionsPerHost：每個主機的連接數

threadsAllowedToBlockForConnectionMultiplier：線程隊列數，它以上面connectionsPerHost值相乘的結果就是線程隊列最大值。如果連接線程排滿了隊列就會拋出“Out of semaphores to get db”錯誤。

maxWaitTime:最大等待連接的線程阻塞時間

connectTimeout：連接超時的毫秒。0是默認和無限

socketTimeout：socket超時。0是默認和無限

autoConnectRetry：這個控制是否在一個連接時，系統會自動重試

 

還有許多配置，可以參見mongodb的API。

 

下面看代碼：

package com.mongo.common;

import java.net.UnknownHostException;

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

public class MongoManager {
    private final static String HOST = "localhost";// 端口
    private final static int PORT = 27017;// 端口
    private final static int POOLSIZE = 100;// 連接數量
    private final static int BLOCKSIZE = 100; // 等待隊列長度
    private static Mongo mongo = null;

    private MongoManager() { }

    static {
        initDBPrompties();
    }

    public static DB getDB(String dbName) {
        return mongo.getDB(dbName);
    }

    /**
     * 初始化連接池
     */
    private static void initDBPrompties() {
        // 其他參數根據實際情況進行添加
        try {
            mongo = new MongoClient( HOST, PORT);
            MongoOptions opt = mongo.getMongoOptions();
            opt.connectionsPerHost = POOLSIZE;
            opt.threadsAllowedToBlockForConnectionMultiplier = BLOCKSIZE;
        } catch (UnknownHostException e) {
        } catch (MongoException e) {

        }

    }
}

使用的時候，如下所示：

/**
     * 保存
     *
     * @param user
     * @throws UnknownHostException
     */
    public void save(User user) throws UnknownHostException {
        DB myMongo = MongoManager.getDB("myMongo");
        DBCollection userCollection = myMongo.getCollection("user");

        DBObject dbo = (DBObject) JSON.parse(user.toJson());
        userCollection.insert(dbo);
    }