MongoDB打开连接问题

Question

MongoDB打开连接问题

6

我在mongo控制台中有以下日志：

Tue Jul 23 17:20:01.301 [initandlisten] waiting for connections on port 27017
Tue Jul 23 17:20:01.401 [websvr] admin web console waiting for connections on port 28017
Tue Jul 23 17:20:01.569 [initandlisten] connection accepted from 127.0.0.1:58090 #1 (1 connection now open)
Tue Jul 23 17:20:01.570 [initandlisten] connection accepted from 127.0.0.1:58089 #2 (2 connections now open)
Tue Jul 23 17:20:21.799 [initandlisten] connection accepted from 127.0.0.1:58113 #3 (3 connections now open)
....
....
....

同样，日志继续记录，现在已经到了112。每次我启动Mongo服务器时都会发生这种情况。我的代码中只有一个单例连接。可能出了什么问题：

public static DB getConnection(String databaseName) throws AppConnectionException {

    if (null != db) {
        Logger.debug("Returning existing db connection...!");
        return db;
    }

    Logger.debug("Creating new db connection...!");
    final String connStr = PropertyRetreiver.getPropertyFromConfigurationFile("rawdata.url");

    try {

        final MongoClientURI uri = new MongoClientURI(connStr);
        final MongoClient client = new MongoClient(uri);
        db = client.getDB(databaseName);

    } catch (UnknownHostException e) {
        throw new AppConnectionException(
                "Unable to connect to the given host / port.");
    }

    return db;
}

- popcoder

有多种方法吗？你能让它“同步”吗？ - bsd

我的DAO将调用这个连接器类的方法来获取连接。此外，这个连接是一个静态单例连接，因此我希望在任何给定时间只有一个连接...那么，为什么我需要在这里同步？？？ - popcoder

1个回答

阿里云服务器只需要99元/年，新老用户同享，点击查看详情

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，

- Alex P · Accepted Answer

MongoClient 内部有一个连接池，最大连接数可以配置（默认为 100）。您可以通过使用 MongoClientOptions 来设置它，如下所示：

MongoClientOptions options = MongoClientOptions.builder()
                .connectionsPerHost(100)
                .autoConnectRetry(true)
                .build();

然后在Mongo Java API v2.11.1中将这些选项提供给MongoClient。连接池中的连接保持打开状态（打开和关闭连接通常是昂贵的操作），以便以后可以重用。

我还建议使用enum重新设计您的MongoDB客户端单例，以避免在此方法上放置synchronized。

以下是我的想法草图：

public enum MongoDB {
    INSTANCE;

    private static final String MONGO_DB_HOST = "some.mongohost.com";
    private Mongo mongo;
    private DB someDB;

    MongoDB() {

        MongoClientOptions options = MongoClientOptions.builder()
                .connectionsPerHost(100)
                .autoConnectRetry(true)
                .readPreference(ReadPreference.secondaryPreferred())
                .build();

        try {
            mongo = new MongoClient(MONGO_DB_HOST, options);
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }

        someDB = mongo.getDB("someDB");
         //authenticate if needed
         //boolean auth = someDB.authenticate("username", "password".toCharArray());
         //if(!auth){
         //     System.out.println("Error Connecting To DB");
         //}        
    }

    public DB getSomeDB() {
        return someDB;
    }

    //call it on your shutdown hook for example 
    public void close(){
        mongo.close();
    }
}

随后，您可以通过以下方式访问您的数据库：

MongoDB.INSTANCE.getSomeDB().getCollection("someCollection").count();