我在语句 DBCursor.hasNext() 中遇到“未与主机通信且重试已用完”的异常。
当我搜索时,得到了设置首选项的解决方案。我仍然遇到这个问题。
我的代码如下:
public void sampleTest() throws Exception
{
MongoClient client = new MongoClient("192.168.20.117", 27017);
DB database = client.getDB("CLME2ECORE");
boolean auth = database.authenticate("tecnotree", ("tecnotree").toCharArray());
DBCollection collection = database.getCollection("RegistrationRequest");
collection.setReadPreference(ReadPreference.primary());
BasicDBObject andQuery = new BasicDBObject("serviceRequest.serviceRequestSubtype.masterCode","RETPOSTREG");
andQuery.append("serviceRequest.serviceRequestStatus.masterCode", "PYMTPEND");
BasicDBObject andFields = new BasicDBObject("serviceRequest.customer.profileDetails.basicDetails.customerCode",1);
andFields.append("_id", 0);
DBCursor dbCursor = collection.find(andQuery);
DBObject dbObject;
dbCursor.setReadPreference(ReadPreference.primary());
if(dbCursor.hasNext())
{
dbObject = dbCursor.next();
String value = dbObject.get("serviceRequest.customer.profileDetails.basicDetails.customerCode").toString();
}
client.close();
}
我使用 Maven 依赖项作为
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongo-java-driver</artifactId>
<version>2.13.0</version>
</dependency>
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>bson</artifactId>
<version>2.13.0</version>
</dependency>
请帮助解决此问题。
最佳答案
进行这些更改,然后它就会起作用。
连接 mongodb 时传递完整的副本集字符串,不要传递单个服务器 IP。
将 readPreferance 更改为 PrimaryPreferred,而不是仅 Primary。
关于java - 在 DBCursor.hasNext() 处获取 "not talking to master and retries used up"异常,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/39267096/