更改mongo连接配置参数为可集群

buyer-api/src/main/resources/application.yml

@@ -46,8 +46,7 @@ spring:
   # mongodb
   data:
     mongodb:
-      host: 127.0.0.1
+      uri: 127.0.0.1:27017
-      port: 27017
       database: lilishop
       username: root
       password: lilishop

common-api/src/main/resources/application.yml

@@ -32,8 +32,7 @@ spring:
   # mongodb
   data:
     mongodb:
-      host: 127.0.0.1
+      uri: 127.0.0.1:27017
-      port: 27017
       database: lilishop
       username: root
       password: lilishop

config/application.yml

@@ -28,8 +28,7 @@ spring:
   # mongodb
   data:
     mongodb:
-      host: 192.168.0.116
+      uri: 192.168.0.116:27017
-      port: 27017
       database: lilishop
       username: root
       password: lilishop

consumer/src/main/resources/application.yml

@@ -35,8 +35,7 @@ spring:
   # mongodb
   data:
     mongodb:
-      host: 127.0.0.1
+      uri: 127.0.0.1:27017
-      port: 27017
       database: lilishop
       username: root
       password: lilishop

framework/src/main/java/cn/lili/cache/config/mongo/MongoConfig.java

@@ -8,7 +8,8 @@ import org.springframework.context.annotation.Configuration;
 import org.springframework.data.mongodb.config.AbstractMongoClientConfiguration;
 import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;
 
-import java.util.Collections;
+import java.util.ArrayList;
+import java.util.List;
 
 /**
  * @author paulG
@@ -21,11 +22,8 @@ public class MongoConfig extends AbstractMongoClientConfiguration {
     @Value("${spring.data.mongodb.database}")
     private String databaseName;
 
-    @Value("${spring.data.mongodb.host}")
+    @Value("${spring.data.mongodb.uri}")
-    private String host;
+    private List<String> uri = new ArrayList<>();
-
-    @Value("${spring.data.mongodb.port}")
-    private Integer port;
 
     @Value("${spring.data.mongodb.username}")
     private String username;
@@ -44,7 +42,14 @@ public class MongoConfig extends AbstractMongoClientConfiguration {
     @Override
     protected void configureClientSettings(MongoClientSettings.Builder builder) {
         builder.credential(MongoCredential.createCredential(username, authenticationDatabase, password.toCharArray()))
-                .applyToClusterSettings(settings -> settings.hosts(Collections.singletonList(new ServerAddress(host, port))));
+                .applyToClusterSettings(settings -> {
+                    List<ServerAddress> serverAddresses = new ArrayList<>();
+                    for (String s : uri) {
+                        String[] node = s.split(":");
+                        serverAddresses.add(new ServerAddress(node[0], Integer.parseInt(node[1])));
+                    }
+                    settings.hosts(serverAddresses);
+                });
     }
 
 }

manager-api/src/main/resources/application.yml

@@ -32,8 +32,7 @@ spring:
   # mongodb
   data:
     mongodb:
-      host: 127.0.0.1
+      uri: 127.0.0.1:27017
-      port: 27017
       database: lilishop
       username: root
       password: lilishop

seller-api/src/main/resources/application.yml

@@ -32,8 +32,7 @@ spring:
   # mongodb
   data:
     mongodb:
-      host: 127.0.0.1
+      uri: 127.0.0.1:27017
-      port: 27017
       database: lilishop
       username: root
       password: lilishop