Mongodb-java获取链接工具类

import java.util.ArrayList; import java.util.List; import com.mongodb.DB; import com.mongodb.MongoClient; import com.mongodb.MongoException; import com.mongodb.MongoOptions; import com.mongodb.ServerAddress; public class MongoManager { // private static Mongo mongo = null; private static MongoClient mongoClient = null; private MongoManager() { } static { initDBPrompties(); } @SuppressWarnings("deprecation") public static DB getDB() { return mongoClient.getDB(Constants.DB_NAME); } @SuppressWarnings("deprecation") public static DB getDB(String dbName) { return mongoClient.getDB(dbName); } /** * 初始化连接池 */ private static void initDBPrompties() { // 其他参数根据实际情况进行添加 try { List<ServerAddress> addresses = new ArrayList<ServerAddress>(); ServerAddress address1 = new ServerAddress(Constants.HOST1 , Constants.PORT); ServerAddress address2 = new ServerAddress(Constants.HOST2 , Constants.PORT); ServerAddress address3 = new ServerAddress(Constants.HOST3 , Constants.PORT); addresses.add(address1); addresses.add(address2); addresses.add(address3); //mongo = new Mongo(addresses); mongoClient = new MongoClient(addresses); // mongoClient = new MongoClient(Constants.HOST, Constants.PORT); // mongo = new Mongo(Constants.HOST, Constants.PORT); @SuppressWarnings("deprecation") MongoOptions opt = mongoClient.getMongoOptions(); // MongoOptions options = mongo.getMongoOptions(); // MongoOptions opt = mongo.getMongoOptions(); opt.connectionsPerHost = Constants.POOLSIZE; opt.threadsAllowedToBlockForConnectionMultiplier = Constants.BLOCKSIZE; System.out.println(Constants.HOST+"++++++++++++"+Constants.PORT); } catch (MongoException e) { } /*catch (UnknownHostException e) { // TODO Auto-generated catch block e.printStackTrace(); }*/ } }