如何通过Java驱动程序正确连接Atlas M0（免费层）集群？

Question

正在尝试使用MongoDB 3.6版通过Java驱动程序连接Atlas群集。

所以，我写的是：

 MongoClientURI uri = new MongoClientURI("mongodb+srv://admin:[e-mail]/test?retryWrites=true");
 MongoClient mongoClient = new MongoClient(uri);

在这种情况下，错误是：

java.lang.IllegalArgumentException: The connection string is invalid. Connection strings must start with 'mongodb://'
    at com.mongodb.ConnectionString.<init>(ConnectionString.java:203)
    at com.mongodb.MongoClientURI.<init>(MongoClientURI.java:176)
    at com.mongodb.MongoClientURI.<init>(MongoClientURI.java:158)
    at project.Bot.check(Bot.java:30)
    at project.Bot.onUpdateReceived(Bot.java:104)
    at java.util.ArrayList.forEach(ArrayList.java:1249)
    at org.telegram.telegrambots.generics.LongPollingBot.onUpdatesReceived(LongPollingBot.java:27)
    at org.telegram.telegrambots.updatesreceivers.DefaultBotSession$HandlerThread.run(DefaultBotSession.java:309)

当程序以使用MongoDB 3.6版或更高版本的snippet开始时，不使用srv：

MongoClientURI uri = new MongoClientURI("mongodb://admin1:[e-mail]/test?retryWrites=true");
MongoClient mongoClient = new MongoClient(uri);

com.mongodb.MongoTimeoutException: Timed out after 30000 ms while waiting for a server that matches ReadPreferenceServerSelector{readPreference=primary}. Client view of cluster state is {type=UNKNOWN, servers=[{address=cluster0.mongodb.net:27017, type=UNKNOWN, state=CONNECTING, exception={com.mongodb.MongoSocketException: cluster0.mongodb.net}, caused by {java.net.UnknownHostException: cluster0.mongodb.net}}]
    at com.mongodb.connection.BaseCluster.createTimeoutException(BaseCluster.java:369)
    at com.mongodb.connection.BaseCluster.selectServer(BaseCluster.java:101)
    at com.mongodb.binding.ClusterBinding$ClusterBindingConnectionSource.<init>(ClusterBinding.java:75)
    at com.mongodb.binding.ClusterBinding$ClusterBindingConnectionSource.<init>(ClusterBinding.java:71)
    at com.mongodb.binding.ClusterBinding.getReadConnectionSource(ClusterBinding.java:63)
    at com.mongodb.operation.OperationHelper.withConnection(OperationHelper.java:201)
    at com.mongodb.operation.CountOperation.execute(CountOperation.java:206)
    at com.mongodb.operation.CountOperation.execute(CountOperation.java:53)
    at com.mongodb.Mongo.execute(Mongo.java:772)
    at com.mongodb.Mongo$2.execute(Mongo.java:759)
    at com.mongodb.MongoCollectionImpl.count(MongoCollectionImpl.java:185)
    at com.mongodb.MongoCollectionImpl.count(MongoCollectionImpl.java:170)
    at project.Bot.check(Bot.java:36)
    at project.Bot.onUpdateReceived(Bot.java:103)
    at java.util.ArrayList.forEach(ArrayList.java:1249)
    at org.telegram.telegrambots.generics.LongPollingBot.onUpdatesReceived(LongPollingBot.java:27)
    at org.telegram.telegrambots.updatesreceivers.DefaultBotSession$HandlerThread.run(DefaultBotSession.java:309)

在POM文件我有依赖：

        <dependency>
            <groupId>org.mongodb</groupId>
            <artifactId>mongo-java-driver</artifactId>
            <version>3.6.0</version>
        </dependency>

此外，当我启动mongo时，我的数据库会添加到此地址mongodb://127.0.0.1:27017，但我为集群添加了路径，但不是为了这个。也许我需要写具体集群的路径，或者？

Ofc，我有管理员用户。此外，我还可以通过Compass连接到我的集群和shell<代码>mongod过程已启动。只有在IDE中运行时，才会出现此错误。这里可能也有同样的问题。

有人知道如何解决这个错误吗？谢谢你的帮助。

Answer 1

还有一个重要提示：在这个字符串中：

MongoClientURI uri = new MongoClientURI("mongodb+srv://admin:[e-mail]/test?retryWrites=true");

测试==

Answer 2

这里似乎有一些问题

第一

3.6.0不是实际加载到您的应用程序类路径中的Mongo驱动程序库；我怀疑您以前使用旧版本进行测试，最近更新了POM？您以前使用的是3.2.0版本。

我怎么知道的？

我开始挖掘代码，在3.6.0版本中，您提供的错误信息离第203行很远。而且，您可以看到上面链接的代码支持srv。

浏览之前的版本，我终于在第203行，即3.2.0版上找到了错误信息。

长话短说，试着做一个马文清洁，然后重建。

如果项目刷新没有帮助，请重新启动Eclipse以获取新的依赖项。

第二

MongoTimeoutException：等待服务器时在30000毫秒后超时

这很可能是防火墙/访问html" target="_blank">控制组配置问题，因为防火墙阻止数据包到达Atlas群集。

请参见将地址添加到白名单。

Answer 3

解决了！所以，我所做的：

>

蒙古srv://user:@cluster0-ox90k.mongodb.net/test?retryWrites=true

我总是遇到一个错误：连接字符串必须以“mongodb://”开头。。

好的，我删除了片段srv，并以同样的方式编写

mongodb://user:@cluster0-ox90k.mongodb.net/test?retryWrites=true

并再次得到错误：

com.mongodb.MongoTimeoutException: Timed out after 30000 ms while waiting for a server that matches ReadPreferenceServerSelector{readPreference=primary}. Client view of cluster state is {type=UNKNOWN, servers=[{address=cluster0-ox90k.mongodb.net:27017, type=UNKNOWN, state=CONNECTING, exception={com.mongodb.MongoSocketException: cluster0-ox90k.mongodb.net}, caused by {java.net.UnknownHostException: cluster0-ox90k.mongodb.net}}]

所以，我通过driver3写信。4岁或更早

mongodb://user:<PASSWORD>@cluster0-shard-00-00-ox90k.mongodb.net:27017,cluster0-shard-00-01-ox90k.mongodb.net:27017,cluster0-shard-00-02-ox90k.mongodb.net:27017/test?ssl=true&replicaSet=Cluster0-shard-0&authSource=admin&retryWrites=true

最终它解决了。

注意：通过将Java驱动程序设置为“3.4或更高版本”，可以从Atlas管理控制台获取此连接字符串。这将帮助您避免自己想出连接字符串。

更新：如果你想使用驱动程序3.7，你需要写而不是格式连接（并避免我上面的问题）

MongoClientURI uri = new MongoClientURI("mongodb+srv://admin:[e-mail]/test?retryWrites=true");
MongoClient mongoClient = new MongoClient(uri);

另一个使用MongoClients的变体。create（）（从3.7版本开始），如下所述：

   MongoClient mongoClient = MongoClients.create("mongodb+srv://admin:[e-mail]/test?retryWrites=true");

注意：密码需要写的不一样mongoDB：//user：

只是格式mongodb://user:mypassword@...

没有大括号