java - 在 DBCursor.hasNext() 处获取 "not talking to master and retries used up"异常

Question

我在语句 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> 

请帮助解决此问题。

Answer 1

进行这些更改，然后它就会起作用。

1. 连接 mongodb 时传递完整的副本集字符串，不要传递单个服务器 IP。

2. 将 readPreferance 更改为 PrimaryPreferred，而不是仅 Primary。