java操作mongodb(连接池)(转)

Posted ~风轻云淡~

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了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。

 

下面看代码:

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


使用的时候,如下所示:

[java] view plain copy
 
 print?技术分享技术分享
  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.   
  11.         DBObject dbo = (DBObject) JSON.parse(user.toJson());  
  12.         userCollection.insert(dbo);  
  13.     }  


 

以上是关于java操作mongodb(连接池)(转)的主要内容,如果未能解决你的问题,请参考以下文章

mongodb如何管理连接的?有必要实现连接池吗

8月23 配置mongodb连接池 | docker 操作

mongodb or操作与连接池

[转]阿里巴巴数据库连接池 druid配置详解

为 JBoss 中的连接池配置 MongoDB 数据源

node.js如何配置mongodb连接池?