我在使用MongoDB的过程当中，遇到如下问题：
我的MongoDB一直存在4个ESTABLISHED 连接，一直未释放，即使任务已经执行完了。
代码如下，其中Client只会在系统启动的时候初始化一次，当然在系统停止contextDestroyed的时候Client也调用了close：
public class ExportServer extends BasicMongoServer {
public final static Logger LOG = Logger.getLogger(ExportServer.class);
public static MongoClient mongoClient;
private static DB exportDB;
private static DBCollection exportCollection;
/**
初始化MongoDB Client
*/
public static void init(String add,String username,String password) throws UnknownHostException {
ArrayList<ServerAddress> addr = new ArrayList<ServerAddress>();
for (String s : add.split(",")) {
addr.add(new ServerAddress(s.trim()));
}
if (addr.size() > 1) {
mongoClient = new MongoClient(addr, getOptions());
} else {
mongoClient = new MongoClient(add, getOptions());
}
mongoClient.setReadPreference(ReadPreference.secondaryPreferred());
exportDB = mongoClient.getDB("export");
exportDB.authenticate(username, password.toCharArray());
exportCollection = exportDB.getCollection("export");
if (exportCollection.getIndexInfo().size() == 0) {
LOG.info("adding necessary indexes on export history collection");
BasicDBObject compoundIndex = new BasicDBObject();
compoundIndex.put("status", 1);
exportCollection.ensureIndex(compoundIndex);
compoundIndex.clear();
compoundIndex.put("key", 1);
exportCollection.ensureIndex(compoundIndex);
compoundIndex.clear();
compoundIndex.put("uid", 1);
exportCollection.ensureIndex(compoundIndex);
}
}
/**
更新document
*/
public static void update(DBObject query, DBObject update) {
exportCollection.update(query, update);
}
/**
保存docuemnt
*/
public static void save(DBObject obj) {
exportCollection.save(obj);
}
}
}
这些代码当中也没有什么特别操作，包括在应用停止的时候我也会将Client关闭
请问各位是否有任何建议或者解决思路。
谢谢。
