java操作mongodb（连接池）（转）

Mongo的实例其实就是一个数据库连接池，这个连接池里默认有10个链接。我们没有必要重新实现这个链接池，但是我们可以更改这个连接池的配置。因为Mongo的实例就是一个连接池，所以，项目中最好只存在一个Mongo的实例。

常见的配置参数：

connectionsPerHost：每个主机的连接数

threadsAllowedToBlockForConnectionMultiplier：线程队列数，它以上面connectionsPerHost值相乘的结果就是线程队列最大值。如果连接线程排满了队列就会抛出“Out of semaphores to get db”错误。

maxWaitTime:最大等待连接的线程阻塞时间

connectTimeout：连接超时的毫秒。0是默认和无限

socketTimeout：socket超时。0是默认和无限

autoConnectRetry：这个控制是否在一个连接时，系统会自动重试

还有许多配置，可以参见mongodb的API。

下面看代码：

 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. }  

使用的时候，如下所示：

 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（连接池）（转）

标签：