如何用XML中的spring-data-mongoDB启用mongo连接池监控？

Question

我正在使用spring-data-mongoDB 1.10.12和mongo 3.6.4。我最近从一个较低版本的mongo进行了升级，现在我的mongo连接池监控中断了，因为没有注册ConnectionPoolStatisticsMBean。根据mongo版本的文档，“默认情况下禁用JMX连接池监视。要启用它，请通过MongoClientOptions添加com.mongodb.management.jmxConnectionPoolListener实例”

但是，在spring-data-mongo的xml模式中，clientOptionsType不允许设置该值，除非我缺少了什么。有没有办法，使用spring数据MongoDB，通过XML打开连接池监控？

这是我的mongo bean的xml

<mongo:mongo-client id="mongo"
                    host="${mongo.hostname:#{null}}"
                    replica-set="${mongo.replica.set:#{null}}"
                    port="${mongo.port}"
                    credentials="'${mongo.username}:${mongo.password}@${mongo.auth.db.name}?uri.authMechanism=${mongo.auth.mechanism:SCRAM-SHA-1}'"
>
    <mongo:client-options connections-per-host="${mongo.connections-per-host:40}"
                          threads-allowed-to-block-for-connection-multiplier="${mongo.threads-blocked-per-connection:3}"
                          connect-timeout="${mongo.connection-timeout:10000}"
                          max-wait-time="${mongo.maxWaitTime:120000}"
                          socket-keep-alive="${mongo.socketKeepAlive:true}"
                          socket-timeout="${mongo.socketTimeout:0}"
                          read-preference="${mongo.read.preference:PRIMARY_PREFERRED}"
                          write-concern="${mongo.write.concern:ACKNOWLEDGED}"
    />
</mongo:mongo-client>

和我的pom依赖项

<properties>
    <mongo-version>3.6.4</mongo-version>
    <spring-data-version>1.10.12.RELEASE</spring-data-version>
</properties>

<dependencies>
    <dependency>
        <groupId>org.mongodb</groupId>
        <artifactId>mongo-java-driver</artifactId>
        <version>${mongo-version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.data</groupId>
        <artifactId>spring-data-mongodb</artifactId>
        <version>${spring-data-version}</version>
    </dependency>
</dependencies>

Answer 1

我也遇到了同样的挑战。在我的例子中，最初的spring配置是使用XML完成的。我已经设法将XML配置与Java配置结合起来，因为Java配置为您配置MongoClientOptions:

@Configuration
public class MongoClientWrapper {

    @Bean
    public MongoClient mongo() 
    {
        //credentials:
        MongoCredential credential = MongoCredential.createCredential("user", "auth-db", "password".toCharArray());

        MongoClientOptions options = MongoClientOptions.builder()
                .addConnectionPoolListener(new MyConnectionPoolListener())
                .build();
        return new MongoClient(
                new ServerAddress("localhost", 27017),      //replica-set
                Arrays.asList(credential)
                ,options
                );
    }


    @Bean
    public MongoTemplate mongoTemplate()
    {
        return new MongoTemplate(mongo(), database);
    }
    ...
}

希望这对某人有帮助...

Answer 2

的确，没有办法通过spring数据MongoDB模式添加连接池侦听器，但是维护repo的人员建议了一个解决方案，即在将MongoClientOptions传递给mongo客户端之前使用BeanPostProcessor更改MongoClientOptions，如下所示

@Override
public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {

    if (bean instanceof MongoClientOptions) {
        return MongoClientOptions.builder((MongoClientOptions) bean)
            .addConnectionPoolListener(new JMXConnectionPoolListener()).build();
    }
    return bean;
}

这样做成功地为我注册了ConnectionPoolStatisticsSmBeans