mongodb加用户名和密码权限

src/main/java/com/neotel/smfcore/common/config/mongodb/MongoDbConfig.java

 package com.neotel.smfcore.common.config.mongodb;
 
 import com.mongodb.MongoClientSettings;
+import com.mongodb.MongoCredential;
 import com.mongodb.ServerAddress;
 import com.mongodb.client.MongoClient;
 import com.mongodb.client.MongoClients;
@@ -66,7 +67,8 @@ public class MongoDbConfig {
 
         ServerAddress serverAddress = new ServerAddress(mongoProperties.getHost(), mongoProperties.getPort());
         serverAddressList.add(serverAddress);
-        MongoClientSettings setting = MongoClientSettings.builder()
+
+        MongoClientSettings.Builder settingBuilder = MongoClientSettings.builder()
                 .applyToClusterSettings(builder ->
                         builder.hosts(serverAddressList)
                                 .mode(clusterConnectionMode)
@@ -75,7 +77,16 @@ public class MongoDbConfig {
                 ).applyToConnectionPoolSettings(builder ->
                         builder.maxSize(mongoProperties.getMaxConSize())
                                 .minSize(mongoProperties.getMinConsize())
-                ).build();
+                );
+
+
+        if (StringUtils.isNotEmpty(mongoProperties.getUsername()) && StringUtils.isNotEmpty(mongoProperties.getPassword())){
+            MongoCredential credential = MongoCredential.createCredential(mongoProperties.getUsername(), mongoProperties.getDatabase(), mongoProperties.getPassword().toCharArray());
+            settingBuilder.credential(credential);
+        }
+
+
+        MongoClientSettings setting = settingBuilder.build();
         MongoClient mongoClient = MongoClients.create(setting);
         return new SimpleMongoClientDatabaseFactory(mongoClient, mongoProperties.getDatabase());
     }

src/main/java/com/neotel/smfcore/common/config/mongodb/bean/CustomMongoProperties.java

@@ -9,6 +9,8 @@ public class CustomMongoProperties {
     private String host;
     private Integer port;
     private String database;
+    private String username;
+    private String password;
     private Integer maxConSize = 100;
     private Integer minConsize = 50;
 }

src/main/resources/config/application-prod.yml

@@ -12,6 +12,18 @@ spring:
       host: localhost  # 主机地址
       port: 27017           # 端口
       database: smf        # 数据库
+      username:
+      password:
+
+    #备份数据库,如果有,则开启,注意:如果主数据库设置了用户名和密码,备份服务器必须设置用户名和密码!!
+    #backup-mongodb:
+    #  auto-index-creation: true # 默认为false，即不会自动创建索引
+    #  host: localhost  # 主机地址
+    #  port: 27017           # 端口
+    #  database: backup_smf        # 数据库
+    #  username:
+    #  password:
+
   servlet:
     multipart:
       max-file-size: 10MB