MongoClient連接數據庫

public class DbManager {
    private static volatile DbManager instance;

    private static final Logger logger = LoggerFactory.getLogger(DbManager.class);

    private MongoClient mongoClient;

    private DbManager() {

    }

    public static DbManager getInstance() {

        if (null == instance) {
            synchronized (DbManager.class) {
                if (null == instance) {
                    instance = new DbManager();
                    instance.init();
                }

            }
        }

        return instance;
    }

    private void init() {

        // 連接池選項
     
        // 選項構建者
        com.mongodb.MongoClientOptions.Builder builder = new MongoClientOptions.Builder();
        
        // 每個地址最大請求數
        builder.connectionsPerHost(8);
        builder.threadsAllowedToBlockForConnectionMultiplier(4);
        
        // 設置連接超時時間
        builder.connectTimeout(10000);
        
        // 設置最大等待時間
        builder.maxWaitTime(120000);
        
        // 讀取數據的超時時間
        builder.socketTimeout(1500);

        MongoClientOptions options = builder.build();

        List<ServerAddress> hosts = new ArrayList<ServerAddress>();

        String host = "127.0.0.1";

        logger.info("dbhost:"+host);
        int port = 27017;
        ServerAddress serverAddress = new ServerAddress(host, port);
        hosts.add(serverAddress);

        List<MongoCredential> credentials = new ArrayList<MongoCredential>();

        MongoCredential credential = MongoCredential.createCredential("admin","admin","123456".toCharArray());  // 需要驗證
        credentials.add(credential);

　　　　　//不使用用戶名密碼
       // mongoClient = new MongoClient(hosts);
　　　　
　　　　　//使用用戶名密碼
         mongoClient=new MongoClient(serverAddress, Arrays.asList(credential));

    }

    public MongoClient getMongoClient() {
        return mongoClient;
    }
    
    public DB getDataDb() {
        DB db = mongoClient.getDB("data");

        return db;
    }
}