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。

下面看代码:

  1. package com.mongo.common;
  2. import java.net.UnknownHostException;
  3. import com.mongodb.DB;
  4. import com.mongodb.Mongo;
  5. import com.mongodb.MongoException;
  6. import com.mongodb.MongoOptions;
  7. public class MongoManager {
  8. private final static String HOST = "localhost";// 端口
  9. private final static int PORT = 27017;// 端口
  10. private final static int POOLSIZE = 100;// 连接数量
  11. private final static int BLOCKSIZE = 100; // 等待队列长度
  12. private static Mongo mongo = null;
  13. private MongoManager() { }
  14. static {
  15. initDBPrompties();
  16. }
  17. public static DB getDB(String dbName) {
  18. return mongo.getDB(dbName);
  19. }
  20. /**
  21. * 初始化连接池
  22. */
  23. private static void initDBPrompties() {
  24. // 其他参数根据实际情况进行添加
  25. try {
  26. mongo = new MongoClient( HOST, PORT);
  27. MongoOptions opt = mongo.getMongoOptions();
  28. opt.connectionsPerHost = POOLSIZE;
  29. opt.threadsAllowedToBlockForConnectionMultiplier = BLOCKSIZE;
  30. } catch (UnknownHostException e) {
  31. } catch (MongoException e) {
  32. }
  33. }
  34. }

使用的时候,如下所示:

  1. /**
  2. * 保存
  3. *
  4. * @param user
  5. * @throws UnknownHostException
  6. */
  7. public void save(User user) throws UnknownHostException {
  8. DB myMongo = MongoManager.getDB("myMongo");
  9. DBCollection userCollection = myMongo.getCollection("user");
  10. DBObject dbo = (DBObject) JSON.parse(user.toJson());
  11. userCollection.insert(dbo);
  12. }
上一篇:java 操作mongodb查询条件的常用设置


下一篇:android和Vitamio使用比较