有人拉我做彩票网站,网站右下角广告展示代码,公司网站设计师,1元购类似网站架设药多少钱原文链接#xff1a; java操作mongodb#xff08;连接池#xff09; Mongo的实例其实就是一个数据库连接池#xff0c;这个连接池里默认有10个链接。我们没有必要重新实现这个链接池#xff0c;但是我们可以更改这个连接池的配置。因为Mongo的实例就是一个连接池#xff…原文链接 java操作mongodb连接池 Mongo的实例其实就是一个数据库连接池这个连接池里默认有10个链接。我们没有必要重新实现这个链接池但是我们可以更改这个连接池的配置。因为Mongo的实例就是一个连接池所以项目中最好只存在一个Mongo的实例。 常见的配置参数 connectionsPerHost每个主机的连接数 threadsAllowedToBlockForConnectionMultiplier线程队列数它以上面connectionsPerHost值相乘的结果就是线程队列最大值。如果连接线程排满了队列就会抛出“Out of semaphores to get db”错误。 maxWaitTime:最大等待连接的线程阻塞时间 connectTimeout连接超时的毫秒。0是默认和无限 socketTimeoutsocket超时。0是默认和无限 autoConnectRetry这个控制是否在一个连接时系统会自动重试 还有许多配置可以参见mongodb的API。 下面看代码 [java] view plain copy print? 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) { } } } 使用的时候如下所示 [java] view plain copy print? /** * 保存 * * 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); } 转载于:https://www.cnblogs.com/gaopeng527/p/5349445.html
