MongoDB replica set连接问题

问答首页 → 综合技术

0 0

MongoDB replica set连接问题5

最近在尝试MongoDB，单节点时都还ok，结果用replica set时死活有问题

环境信息如下：

vmware + +

然后解压了3份

启动了3个进程（3个不同的端口）

config如下

rs.status

客户端用的Java，

host list

List<ServerAddress> list = new ArrayList<ServerAddress>();
		ServerAddress tmp1 = new ServerAddress("192.168.223.129", 27017);
		ServerAddress tmp2 = new ServerAddress("192.168.223.129", 27018);
		ServerAddress tmp3 = new ServerAddress("192.168.223.129", 27019);

		list.add(tmp1);
		list.add(tmp2);
		list.add(tmp3);
		return list;

然后悲剧来了，各种插入查询操作都是MongoTimeoutException

com.mongodb.MongoTimeoutException: Timed out while waiting for a server that matches {serverSelectors=[ReadPreferenceServerSelector{readPreference=primary}, LatencyMinimizingServerSelector{acceptableLatencyDifference=15ms}]} after 806 ms
	at com.mongodb.BaseCluster.getServer(BaseCluster.java:87)
	at com.mongodb.DBTCPConnector.getServer(DBTCPConnector.java:654)
	at com.mongodb.DBTCPConnector.access$300(DBTCPConnector.java:39)
	at com.mongodb.DBTCPConnector$MyPort.getConnection(DBTCPConnector.java:503)
	at com.mongodb.DBTCPConnector$MyPort.get(DBTCPConnector.java:451)
	at com.mongodb.DBTCPConnector.getPrimaryPort(DBTCPConnector.java:409)
	at com.mongodb.DBCollectionImpl.insert(DBCollectionImpl.java:182)
	at com.mongodb.DBCollectionImpl.insert(DBCollectionImpl.java:165)
	at com.mongodb.DBCollection.insert(DBCollection.java:161)
	at com.mongodb.DBCollection.insert(DBCollection.java:107)
	at com.mongodb.DBCollection.save(DBCollection.java:966)
	at com.mongodb.DBCollection.save(DBCollection.java:934)
	at xxx.xxx.xxx.mongo.MyMongoClient.add(MyMongoClient.java:103)
	at xxx.xxx.xxx.mongo.MyMongoClientTest.testMyTest(MyMongoClientTest.java:23)

既然提示这个了，那就加大点吧

acceptableLatencyDifference=15ms

MongoClient mongoClient = new MongoClient(hostList,
					new MongoClientOptions.Builder()
						.acceptableLatencyDifference(1 * 1000)
						.build());

结果除了数字变了，其他一点儿没变。。。

com.mongodb.MongoTimeoutException: Timed out while waiting for a server that matches {serverSelectors=[ReadPreferenceServerSelector{readPreference=primary}, LatencyMinimizingServerSelector{acceptableLatencyDifference=1000 ms}]} after 806 ms

一路跟代码到抛异常的地方，这代码怎么连个注释也没有，实在看不下去了（好吧其实是我太懒不想看了）