Commit 82b4cdc4 by jinfeng.wang

fix

parent fdad3b58
package com.mobvista.apptag.utils;
import com.mongodb.MongoClientSettings;
import com.mongodb.ReadPreference;
import com.mongodb.ServerAddress;
import com.mongodb.client.*;
import com.mongodb.client.model.Filters;
......@@ -34,7 +35,7 @@ public class GetPackageFromMongo {
MongoClientSettings settings = MongoClientSettings.builder()
.retryWrites(true)
.applyToConnectionPoolSettings(builder ->
builder.maxConnectionIdleTime(600000, TimeUnit.MILLISECONDS))
builder.maxConnectionIdleTime(6000, TimeUnit.MILLISECONDS))
.applyToClusterSettings(builder -> {
builder.hosts(Arrays.asList(new ServerAddress(mongoUrl, 27017)));
}).build();
......@@ -46,6 +47,8 @@ public class GetPackageFromMongo {
// 连接到数据库
MongoDatabase mongoDatabase = mongoClient.getDatabase("new_adn");
mongoDatabase.withReadPreference(ReadPreference.secondary());
System.out.println("Connect to database successfully");
MongoCollection<Document> collection = mongoDatabase.getCollection("campaign");
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment