Spring Boot中使用MongoDB的连接池配置的方法

 更新时间:2018年03月06日 09:17:15   作者:翟永超  
本文介绍了Spring Boot中使用MongoDB的连接池配置的方法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧

因为今天开发遇到了性能问题,可能与MongoDB的连接有关,所以稍稍深入看了一下,正好搜到原来有人写过这篇相关的内容,所以转载过来。回头有时间可以写个扩展到SpringForAll里,主体思路还是一样的。感谢这位美女程序媛的文章!

说明

Spring Boot中通过依赖 spring-boot-starter-data-mongodb ,来实现 spring-data-mongodb 的自动配置。

但是默认情况下,Spring Boot 中,并没有像使用MySQL或者Redis一样,提供了连接池配置的功能。因此,我们需要自行重写 MongoDbFactory ,实现MongoDB客户端连接的参数配置扩展。

需要说明的是,MongoDB的客户端本身就是一个连接池,因此,我们只需要配置客户端即可。

配置文件

为了统一Spring Boot的配置,我们要将重写的配置也配置到 application.yml 中,前缀为 spring.data.mongodb.custom 下(前缀可自己随意配置):

spring:
 data:
 mongodb:
  custom:
  hosts:
   - 10.0.5.1
   - 10.0.5.1
  ports:
   - 27017
   - 27018
  replica-set: mgset-3590061
  username: jancee
  password: abc123
  database: jancee
  authentication-database: admin
  connections-per-host: 20
  min-connections-per-host: 20

该配置例子中,配置了副本集,其中包含了主机 10.0.5.1:27017 和 10.0.5.1:27018 ,其它配置与Spring Boot的标准配置类似,另外, connections-per-host 为客户端的连接数, in-connections-per-host 为客户端最小连接数。

将配置包装成类

为方便调用和可读性,将上述配置包装成一个配置实体类, MongoConfig.java 代码如下:

package com.feidiao.jancee.fdiot.api.config.mongo;
import org.hibernate.validator.constraints.NotBlank;
import org.hibernate.validator.constraints.NotEmpty;
import org.springframework.stereotype.Component;
import org.springframework.validation.annotation.Validated;
import java.util.List;

@Component
@Validated
public class MongoSettingsProperties {

 @NotBlank
 private String database;

 @NotEmpty
 private List<String> hosts;

 @NotEmpty
 private List<Integer> ports;
 private String replicaSet;
 private String username;
 private String password;
 private String authenticationDatabase;
 private Integer minConnectionsPerHost = 10;
 private Integer connectionsPerHost = 2;
 public MongoSettingsProperties() {

 }

 public String getDatabase() {
  return database;
 }

 public void setDatabase(String database) {
  this.database = database;
 }

 public List<String> getHosts() {
  return hosts;
 }

 public void setHosts(List<String> hosts) {
  this.hosts = hosts;
 }

 public List<Integer> getPorts() {
  return ports;
 }

 public void setPorts(List<Integer> ports) {
  this.ports = ports;
 }

 public String getReplicaSet() {
  return replicaSet;
 }

 public void setReplicaSet(String replicaSet) {
  this.replicaSet = replicaSet;
 }

 public String getUsername() {
  return username;
 }

 public void setUsername(String username) {
  this.username = username;
 }

 public String getPassword() {
  return password;
 }

 public void setPassword(String password) {
  this.password = password;
 }

 public String getAuthenticationDatabase() {
  return authenticationDatabase;
 }

 public void setAuthenticationDatabase(String authenticationDatabase) {
  this.authenticationDatabase = authenticationDatabase;
 }

 public Integer getMinConnectionsPerHost() {
  return minConnectionsPerHost;
 }

 public void setMinConnectionsPerHost(Integer minConnectionsPerHost) {
  this.minConnectionsPerHost = minConnectionsPerHost;
 }

 public Integer getConnectionsPerHost() {
  return connectionsPerHost;
 }

 public void setConnectionsPerHost(Integer connectionsPerHost)  {
  this.connectionsPerHost = connectionsPerHost;
 }
}

覆盖MongoDbFactory

接下来,就是覆盖Spring Boot原有的 MongoDbFactory Bean,新建文件 MongoConfig.java ,代码如下:

import com.mongodb.MongoClient;
import com.mongodb.MongoClientOptions;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.mongodb.MongoDbFactory;
import org.springframework.data.mongodb.core.SimpleMongoDbFactory;
import java.util.ArrayList;
import java.util.List;

@Configuration
public class MongoConfig {
 // 注入配置实体
 @Autowired
 private MongoSettingsProperties mongoSettingsProperties;
 @Bean
 @ConfigurationProperties(
   prefix = "spring.data.mongodb.custom")
 MongoSettingsProperties mongoSettingsProperties() {
  return new MongoSettingsProperties();
 }

 // 覆盖默认的MongoDbFactory
 @Bean
 MongoDbFactory mongoDbFactory() {
  //客户端配置(连接数、副本集群验证)
  MongoClientOptions.Builder builder = new MongoClientOptions.Builder();
  builder.connectionsPerHost(mongoSettingsProperties.getConnectionsPerHost());
  builder.minConnectionsPerHost(mongoSettingsProperties.getMinConnectionsPerHost());
  if (mongoSettingsProperties.getReplicaSet() != null) {
   builder.requiredReplicaSetName(mongoSettingsProperties.getReplicaSet());
  }
  MongoClientOptions mongoClientOptions = builder.build();

  // MongoDB地址列表
  List<ServerAddress> serverAddresses = new ArrayList<>();
  for (String host : mongoSettingsProperties.getHosts()) {
   Integer index = mongoSettingsProperties.getHosts().indexOf(host);
   Integer port = mongoSettingsProperties.getPorts().get(index);

   ServerAddress serverAddress = new ServerAddress(host, port);
   serverAddresses.add(serverAddress);
  }
  System.out.println("serverAddresses:" + serverAddresses.toString());

  // 连接认证
  List<MongoCredential> mongoCredentialList = new ArrayList<>();
  if (mongoSettingsProperties.getUsername() != null) {
   mongoCredentialList.add(MongoCredential.createScramSha1Credential(
     mongoSettingsProperties.getUsername(),
     mongoSettingsProperties.getAuthenticationDatabase() != null ? mongoSettingsProperties.getAuthenticationDatabase() : mongoSettingsProperties.getDatabase(),
     mongoSettingsProperties.getPassword().toCharArray()));
  }
  System.out.println("mongoCredentialList:" + mongoCredentialList.toString());
  //创建客户端和Factory
  MongoClient mongoClient = new MongoClient(serverAddresses, mongoCredentialList, mongoClientOptions);
  MongoDbFactory mongoDbFactory = new SimpleMongoDbFactory(mongoClient, mongoSettingsProperties.getDatabase());
  return mongoDbFactory;
 }
}

在这里,实现了MongoDB连接时,前面配置的参数的设置,按照自己的实际情况,可以在 new SimpleMongoDbFactory 时,增加修改自己需要的配置参数。

至此,就完成了全部配置,运行测试即可。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • Java连接MySQL数据库并实现数据交互功能

    Java连接MySQL数据库并实现数据交互功能

    在现代应用中,数据库是不可或缺的一部分,Java 作为一种广泛使用的编程语言,提供了丰富的 API 来与各种数据库进行交互,本文将详细介绍如何在 Java 中连接 MySQL 数据库,并实现基本的数据交互功能,需要的朋友可以参考下
    2024-10-10
  • Java中StringBuilder常用构造方法解析

    Java中StringBuilder常用构造方法解析

    这篇文章主要介绍了Java中StringBuilder常用构造方法解析,StringBuilder是一个可标的字符串类,我们可以吧它看成是一个容器这里的可变指的是StringBuilder对象中的内容是可变的,需要的朋友可以参考下
    2024-01-01
  • IntelliJ Idea2017如何修改缓存文件的路径

    IntelliJ Idea2017如何修改缓存文件的路径

    这篇文章主要介绍了IntelliJ Idea2017如何修改缓存文件的路径,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-10-10
  • Java中EnumMap代替序数索引代码详解

    Java中EnumMap代替序数索引代码详解

    这篇文章主要介绍了Java中EnumMap代替序数索引代码详解,小编觉得还是挺不错的,具有一定借鉴价值,需要的朋友可以参考下
    2018-02-02
  • Java中ArrayList和LinkedList的遍历与性能分析

    Java中ArrayList和LinkedList的遍历与性能分析

    这篇文章主要给大家介绍了ArrayList和LinkedList这两种list的五种循环遍历方式,各种方式的性能测试对比,根据ArrayList和LinkedList的源码实现分析性能结果,总结结论。相信对大家的理解和学习具有一定的参考价值,有需要的朋友们下面跟着小编一起来学习学习吧。
    2016-12-12
  • Springboot项目的Mapper中增加一个新的sql语句

    Springboot项目的Mapper中增加一个新的sql语句

    本文主要介绍了Springboot项目的Mapper中增加一个新的sql语句,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2024-05-05
  • SpringBoot2 参数管理实践之入参出参与校验的方式

    SpringBoot2 参数管理实践之入参出参与校验的方式

    这篇文章主要介绍了SpringBoot2 参数管理实践,入参出参与校验,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2021-06-06
  • springboot接收日期类型参数的操作方法

    springboot接收日期类型参数的操作方法

    如果使用Get请求,直接使用对象接收,则可以使用@DateTimeFormat注解进行格式化,本文重点给大家介绍springboot接收日期类型参数的方法,感兴趣的朋友一起看看吧
    2024-02-02
  • 关于Spring Cache 缓存拦截器( CacheInterceptor)

    关于Spring Cache 缓存拦截器( CacheInterceptor)

    这篇文章主要介绍了关于Spring Cache缓存拦截器( CacheInterceptor),具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-12-12
  • idea日志乱码和tomcat日志乱码问题的解决方法

    idea日志乱码和tomcat日志乱码问题的解决方法

    这篇文章主要介绍了idea日志乱码和tomcat日志乱码问题的解决方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-08-08

最新评论