解决：com.mongodb.MongoSocketOpenException: Exception opening socket ...

背景

springboot项目启动时，报错

1. com.mongodb.MongoSocketOpenException: Exception opening socket
2.         at com.mongodb.internal.connection.SocketStream.open(SocketStream.java:70) ~[mongodb-driver-core-3.11.2.jar:na]
3.         at com.mongodb.internal.connection.InternalStreamConnection.open(InternalStreamConnection.java:128) ~[mongodb-driver-core-3.11.2.jar:na]
4.         at com.mongodb.internal.connection.DefaultServerMonitor$ServerMonitorRunnable.run(DefaultServerMonitor.java:117) ~[mongodb-driver-core-3.11.2.jar:na]
5.         at java.lang.Thread.run(Thread.java:748) [na:1.8.0_181]
6. Caused by: java.net.ConnectException: Connection refused: connect
7.         at java.net.DualStackPlainSocketImpl.waitForConnect(Native Method) ~[na:1.8.0_181]
8.         at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:85) ~[na:1.8.0_181]
9.         at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) ~[na:1.8.0_181]
10.         at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) ~[na:1.8.0_181]
11.         at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) ~[na:1.8.0_181]
12.         at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172) ~[na:1.8.0_181]
13.         at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) ~[na:1.8.0_181]
14.         at java.net.Socket.connect(Socket.java:589) ~[na:1.8.0_181]
15.         at com.mongodb.internal.connection.SocketStreamHelper.initialize(SocketStreamHelper.java:64) ~[mongodb-driver-core-3.11.2.jar:na]
16.         at com.mongodb.internal.connection.SocketStream.initializeSocket(SocketStream.java:79) ~[mongodb-driver-core-3.11.2.jar:na]
17.         at com.mongodb.internal.connection.SocketStream.open(SocketStream.java:65) ~[mongodb-driver-core-3.11.2.jar:na]
18.         ... 3 common frames omitted

复制代码

而且用工具能够连接mongodb，已经排除是mongodb不能连接的问题
缘故原由

项目中设置了自界说的MongoClient：

1.         @Bean
2.     public MongoDatabase mongoDatabase() {
3.         String host = mongodbProperties.getHost();
4.         Integer port = mongodbProperties.getPort();
6.         MongoClientOptions.Builder options = new MongoClientOptions.Builder();
7.         options.connectionsPerHost(mongodbProperties.getPoolSize());
8.         options.threadsAllowedToBlockForConnectionMultiplier(mongodbProperties.getBlockSize());
9.         options.build();
11.         MongoClient mongoClient = null;
12.         ServerAddress serverAddress = new ServerAddress(mongodbProperties.getHost(), mongodbProperties.getPort());
13.         List<ServerAddress> seeds = new ArrayList<>();
14.         seeds.add(serverAddress);
15.         String userName = mongodbProperties.getUserName();
16.         String password = mongodbProperties.getPassword();
17.         if (StringUtils.isNotBlank(userName) && StringUtils.isNotBlank(password)){
19.             MongoCredential credentials = MongoCredential.createCredential(userName, mongodbProperties.getDatabase(), password.toCharArray());
20.             List<MongoCredential> credentialsList = new ArrayList<>();
21.             credentialsList.add(credentials);
22.             mongoClient = new MongoClient(seeds, credentialsList);
23.         }else {
24.             mongoClient = new MongoClient(host, port);
25.         }
27.        return mongoClient.getDatabase(mongodbProperties.getDatabase());
28.     }

复制代码

而springboot在启动时会自动实例化一个MongoClient：

源码如下：

1. /*
2. * Copyright 2012-2019 the original author or authors.
3. *
4. * Licensed under the Apache License, Version 2.0 (the "License");
5. * you may not use this file except in compliance with the License.
6. * You may obtain a copy of the License at
7. *
8. *      https://www.apache.org/licenses/LICENSE-2.0
9. *
10. * Unless required by applicable law or agreed to in writing, software
11. * distributed under the License is distributed on an "AS IS" BASIS,
12. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13. * See the License for the specific language governing permissions and
14. * limitations under the License.
15. */
17. package org.springframework.boot.autoconfigure.mongo;
19. import com.mongodb.MongoClientURI;
21. import org.springframework.boot.context.properties.ConfigurationProperties;
23. /**
24. * Configuration properties for Mongo.
25. *
26. * @author Dave Syer
27. * @author Phillip Webb
28. * @author Josh Long
29. * @author Andy Wilkinson
30. * @author Eddú Meléndez
31. * @author Stephane Nicoll
32. * @author Nasko Vasilev
33. * @author Mark Paluch
34. * @author Artsiom Yudovin
35. * @since 1.0.0
36. */
37. @ConfigurationProperties(prefix = "spring.data.mongodb")
38. public class MongoProperties {
40.         /**
41.          * Default port used when the configured port is {@code null}.
42.          */
43.         public static final int DEFAULT_PORT = 27017;
45.         /**
46.          * Default URI used when the configured URI is {@code null}.
47.          */
48.         public static final String DEFAULT_URI = "mongodb://localhost/test";
50.         /**
51.          * Mongo server host. Cannot be set with URI.
52.          */
53.         private String host;
55.         /**
56.          * Mongo server port. Cannot be set with URI.
57.          */
58.         private Integer port = null;
60.         /**
61.          * Mongo database URI. Cannot be set with host, port and credentials.
62.          */
63.         private String uri;
65.         /**
66.          * Database name.
67.          */
68.         private String database;
70.         /**
71.          * Authentication database name.
72.          */
73.         private String authenticationDatabase;
75.         /**
76.          * GridFS database name.
77.          */
78.         private String gridFsDatabase;
80.         /**
81.          * Login user of the mongo server. Cannot be set with URI.
82.          */
84.         private String username;
86.         /**
87.          * Login password of the mongo server. Cannot be set with URI.
88.          */
89.         private char[] password;
91.         /**
92.          * Fully qualified name of the FieldNamingStrategy to use.
93.          */
94.         private Class<?> fieldNamingStrategy;
96.         /**
97.          * Whether to enable auto-index creation.
98.          */
99.         private Boolean autoIndexCreation;
101.         public String getHost() {
102.                 return this.host;
103.         }
105.         public void setHost(String host) {
106.                 this.host = host;
107.         }
109.         public String getDatabase() {
110.                 return this.database;
111.         }
113.         public void setDatabase(String database) {
114.                 this.database = database;
115.         }
117.         public String getAuthenticationDatabase() {
118.                 return this.authenticationDatabase;
119.         }
121.         public void setAuthenticationDatabase(String authenticationDatabase) {
122.                 this.authenticationDatabase = authenticationDatabase;
123.         }
125.         public String getUsername() {
126.                 return this.username;
127.         }
129.         public void setUsername(String username) {
130.                 this.username = username;
131.         }
133.         public char[] getPassword() {
134.                 return this.password;
135.         }
137.         public void setPassword(char[] password) {
138.                 this.password = password;
139.         }
141.         public Class<?> getFieldNamingStrategy() {
142.                 return this.fieldNamingStrategy;
143.         }
145.         public void setFieldNamingStrategy(Class<?> fieldNamingStrategy) {
146.                 this.fieldNamingStrategy = fieldNamingStrategy;
147.         }
149.         public String getUri() {
150.                 return this.uri;
151.         }
153.         public String determineUri() {
154.                 return (this.uri != null) ? this.uri : DEFAULT_URI;
155.         }
157.         public void setUri(String uri) {
158.                 this.uri = uri;
159.         }
161.         public Integer getPort() {
162.                 return this.port;
163.         }
165.         public void setPort(Integer port) {
166.                 this.port = port;
167.         }
169.         public String getGridFsDatabase() {
170.                 return this.gridFsDatabase;
171.         }
173.         public void setGridFsDatabase(String gridFsDatabase) {
174.                 this.gridFsDatabase = gridFsDatabase;
175.         }
177.         public String getMongoClientDatabase() {
178.                 if (this.database != null) {
179.                         return this.database;
180.                 }
181.                 return new MongoClientURI(determineUri()).getDatabase();
182.         }
184.         public Boolean isAutoIndexCreation() {
185.                 return this.autoIndexCreation;
186.         }
188.         public void setAutoIndexCreation(Boolean autoIndexCreation) {
189.                 this.autoIndexCreation = autoIndexCreation;
190.         }
192. }

复制代码

解决方法

禁用SpringBoot对Mongo的自动设置，以免和自界说的设置冲突，在SpringBoot启动类上加上：

1. @SpringBootApplication(exclude = MongoAutoConfiguration.class)

复制代码

由此可见，在任何springboot项目中，如果自界说了MongoClient且交与了springboot管理，都需要排除掉springboot对mongodb的自动设置

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。