-
Type: Task
-
Resolution: Gone away
-
Priority: Major - P3
-
None
-
Affects Version/s: None
-
Component/s: Connection Management
-
Labels:None
// code placeholder import com.mongodb.MongoClient; import com.mongodb.MongoClientURI; import com.mongodb.client.MongoClients; public class Mongo { public static void main(String[] ss) { String url = "mongodb://**:****@dds-2ev38e6dab5433341368-pub.mongodb.rds.aliyuncs.com:3717,dds-2ev38e6dab5433342459-pub.mongodb.rds.aliyuncs.com:3717/?" + "authSource=admin&readPreference=primary&replicaSet=aa"; // Working com.mongodb.client.MongoClient client = MongoClients.create(url); System.out.println(client.getDatabase("jcl_dev").getCollection("product_new").count()); //Not Working MongoClientURI connectionString = new MongoClientURI(url); MongoClient mongoClient = new MongoClient(connectionString); System.out.println(mongoClient.getDatabase("jcl_dev").getCollection("product_new").count()); } }
INFO: Exception in monitor thread while connecting to server dds-aaaaaa.aliyuncs.com:3717INFO: Exception in monitor thread while connecting to server dds-2ev38e6dab5433341368-pub.mongodb.rds.aliyuncs.com:3717com.mongodb.MongoSocketReadException: Prematurely reached end of stream at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:112) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:570) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:441) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:295) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:255) at com.mongodb.internal.connection.CommandHelper.sendAndReceive(CommandHelper.java:83) at com.mongodb.internal.connection.CommandHelper.executeCommand(CommandHelper.java:33) at com.mongodb.internal.connection.InternalStreamConnectionInitializer.initializeConnectionDescription(InternalStreamConnectionInitializer.java:105) at com.mongodb.internal.connection.InternalStreamConnectionInitializer.initialize(InternalStreamConnectionInitializer.java:62) at com.mongodb.internal.connection.InternalStreamConnection.open(InternalStreamConnection.java:127) at com.mongodb.internal.connection.DefaultServerMonitor$ServerMonitorRunnable.run(DefaultServerMonitor.java:117) at java.lang.Thread.run(Thread.java:748)