通过mongo java驱动程序java API设置Mongodb连接池选项

Question

使用Morphia和mongo java驱动程序，我正在连接mongo服务器：

MongoClientOptions.Builder builder = MongoClientOptions.builder();
        builder.sslEnabled(true);
        builder.sslInvalidHostNameAllowed(true);
        builder.maxConnectionIdleTime(0);
        MongoClientOptions sslOptions = builder.build();

        MongoClient mongoClient = new MongoClient(serverAddressList, Arrays.asList(mongoCredential), sslOptions);

其中serverAddressList是主机：端口列表和使用kerberos身份验证的mongoCredential创建为：

MongoCredential mongoCredential = MongoCredential.createGSSAPICredential("[e-mail]");

我想使用以下参数设置自定义连接池参数：

1. maxPoolSize
2. 最小池大小
3. Maxidletimes等

为了实现这一点，我找到了ConnectionPoolSettings。建设者和com.mongodb.联系ConnectionPoolSettings类。

我在这里搜索了一个示例代码：

ConnectionPoolSettings connectionPoolSettings = ConnectionPoolSettings
                .builder()
                .minSize(MIN_MONGO_POOL_SIZE)
                .maxSize(MONGO_POOL_SIZE)
                .build();
        MongoClientSettings settings = MongoClientSettings
                .builder()
                .readPreference(MONGO_READ_PREFERENCE)
                .credentialList(credentialsList).clusterSettings(clusterSettings)
                .connectionPoolSettings(connectionPoolSettings).build();

有人能推荐一种应用这些设置的方法来获取MongoClient的实例吗？

正在使用的库：

dependencies {
    compile 'org.mongodb:mongodb-driver-sync:3.4.3'
  }

Answer 1

终于找到了设置连接池参数的正确方法，所以在这里回答了我自己的问题。

我在这里浏览了MongoClientations的源代码，其中connectionPool参数的设置如下：

connectionPoolSettings = ConnectionPoolSettings
                    .builder()
                    .minSize(getMinConnectionsPerHost())
                    .maxSize(getConnectionsPerHost())
                    .maxWaitQueueSize(getThreadsAllowedToBlockForConnectionMultiplier()
                    * getConnectionsPerHost())
                    .maxWaitTime(getMaxWaitTime(), MILLISECONDS)
                    .maxConnectionIdleTime(getMaxConnectionIdleTime(), MILLISECONDS)
                    .maxConnectionLifeTime(getMaxConnectionLifeTime(), MILLISECONDS)
                    .build();

我们可以看到minSize和maxSize值是从getMinConnectionsPerHost（）获取的 和getConnectionsPerHost（） 方法。因此，要在客户端代码中更改和自定义连接池参数，我们只需将maxConnectionIdleTime和minConnectionsPerHost值添加到生成器中，如下所示：

MongoClientOptions.Builder builder = MongoClientOptions.builder();
    builder.maxConnectionIdleTime(0);
    builder.minConnectionsPerHost(50);
    builder.connectionsPerHost(200);
    MongoClientOptions sslOptions = builder.build();

此代码成功地打开了到mongodb服务器主机的最小指定连接。

LOG : 00:20:00,714 INFO  [org.mongodb.driver.connection] (pool-1-thread-1) Opened connection [connectionId{localValue:50}] to server.com:27180