MongoDB 线程长连接问题

我在使用MongoDB的过程当中,遇到如下问题:
netstat -an|grep 27017

我的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关闭 

请问各位是否有任何建议或者解决思路。

谢谢。

1个回答

用netstat -nlp等,查看一下对应的进程,然后就是对应的代码多看看是否有其他分支退出了,从而没有释放连接

ye8303019
ChrisYez 我正在查找原因,貌似是mongoDB本身配置的问题~
4 年多之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
立即提问