0
我在MongoDB副本集中有2个服务器,一个是主要的,另一个是次要的。我的应用程序运行完全在主服务器上,但是当对次级游,我得到以下警告:如何使用REPLICA_SET_SECONDARY类型对MongoDB服务器执行写操作?
INFO: No server chosen by WritableServerSelector from cluster description ClusterDescription{type=REPLICA_SET, connectionMode=SINGLE, serverDescriptions=[ServerDescription{address=localhost:27017, type=REPLICA_SET_SECONDARY, state=CONNECTED, ok=true, version=ServerVersion{versionList=[3, 2, 11]}, minWireVersion=0, maxWireVersion=4, maxDocumentSize=16777216, roundTripTimeNanos=691940, setName='rs2', canonicalAddress=192.168.71.22:27017, hosts=[192.168.70.197:27017, 192.168.71.22:27017, PC:27017], passives=[], arbiters=[], primary='PC:27017', tagSet=TagSet{[]}, electionId=null, setVersion=3}]}. Waiting for 30000 ms before timing out
读操作(选择“2”的代码)后30秒超时正确执行。写入操作(代码中的选择“1”&“3”)触发此警告再次出现并且不起作用。我应该在MongoDB设置中更改什么或添加到代码才能执行写入操作?
代码:
package ru.energodata;
import com.mongodb.*;
import java.io.File;
import java.io.IOException;
import java.util.Scanner;
import com.mongodb.gridfs.GridFS;
import com.mongodb.gridfs.GridFSInputFile;
public class Main {
public static void main(String[] args) {
Scanner scanner;
int selection;
boolean exit = false;
MongoClient mongoClient = new MongoClient("localhost", 27017);
DB db = mongoClient.getDB("imagedb");
GridFS gfsPhoto = new GridFS(db, "photo");
while (!exit)
{
System.out.println("Choose action with the DB");
System.out.println("1 - add files to DB");
System.out.println("2 - list files");
System.out.println("3 - remove files");
scanner = new Scanner(System.in);
if(scanner.hasNextInt()) {
selection = scanner.nextInt();
if (selection == 1) {
String path = "C:\\2015";
String fileName;
File dir = new File(path);
File[] imageFile = dir.listFiles();
try {
for (File anImageFile : imageFile) {
GridFSInputFile gfsFile = gfsPhoto.createFile(anImageFile);
fileName = anImageFile.getName();
System.out.println("Current file: " + fileName);
// set a new filename for identify purpose
gfsFile.setFilename(fileName);
// save the image file into mongoDB
gfsFile.save();
}
} catch (MongoException | IOException e) {
e.printStackTrace();
}
}
if (selection == 2) {
// print the result
System.out.println("Database content:");
DBCursor cursor = gfsPhoto.getFileList();
if (cursor.hasNext()) {
while (cursor.hasNext()) {
System.out.println(cursor.next());
}
}
else {System.out.println("none.");
}
}
if (selection == 3) {
// remove the image file from mongoDB
DBCursor cursor = gfsPhoto.getFileList();
if (cursor.hasNext()) {
while (cursor.hasNext()) {
gfsPhoto.remove(cursor.next());
}
System.out.println("DB content deleted");
}
else {System.out.println("DB is empty");
}
}
}
else {
System.out.println("Select either 1, 2 or 3");
scanner = new Scanner(System.in);
}
}
}
}
这应该可以帮到你.. http://stackoverflow.com/questions/14587398/how-to-prefer-reads-on-secondaries-in-mongodb – user641887