Я использую cursor.toArray() для возврата моего collection.find(query) в качестве списка, а время отклика для моего API составляет 100 миллисекунд. Данных, извлеченных в курсор, очень мало (пара сотен записей), база данных индексируется в поле, которое я запрашиваю. Я также установил размер партии cursor.batchSize(1000).
db.collection.find({"{ "ZIP" : { "$in" : [ "12345"]}}"}) - это мой запрос, и моя база данных проиндексирована на «ZIP». Я вижу, что тот же запрос выполняется на оболочке в течение 4 мс.
Тот же запрос на оболочке Монго вряд ли займет 5 мс.
Драйвер Mogo, который я использую:
<!-- https://mvnrepository.com/artifact/org.mongojack/mongojack -->
<dependency>
<groupId>org.mongojack</groupId>
<artifactId>mongojack</artifactId>
<version>2.8.2</version>
</dependency>
код
@Path("/")
@Produces(MediaType.APPLICATION_JSON)
@Api(value = "listing-mongo")
public class MlsMongoResource {
private JacksonDBCollection<Mlsdatadao, String> collection;
Clock clock;
public MlsMongoResource(JacksonDBCollection<Mlsdatadao, String> collection) {
this.collection = collection;
this.clock = Clock.systemUTC();
}
@GET
@Path("/listings-mongo")
@Produces(value = MediaType.APPLICATION_JSON)
@Timed
public List<Mlsdatadao> getListings(@BeanParam MlsListingParameters mlsBeanParam) {
BasicDBList basicDbList = new BasicDBList();
mlsBeanParam.validateBean();
setLocations(basicDbList,mlsBeanParam.zipcodes);
BasicDBObject query = new BasicDBObject("$and", basicDbList);
DBCursor<Mlsdatadao> cursor = null;
long start = 0;
try{
start = System.currentTimeMillis();
cursor = collection.find(query);
cursor.batchSize(1000);
} catch (Exception e){
System.out.println("IN collection.find() " + e.getCause());
}
System.out.println("QUERY LIST IS " + basicDbList);
if(cursor == null) {
System.out.println("Cursor is null");
}
List<Mlsdatadao> result = cursor.toArray();
cursor.close();(System.currentTimeMillis() - start));
return result;
}
private void setLocations(BasicDBList basicDbList, List<String> zipcodes) {
if (CollectionUtils.isNotEmpty(zipcodes)) {
basicDbList.add(setZipcodes(zipcodes));
}
}
private BasicDBObject setZipcodes(List<String> zipcodes) {
return new BasicDBObject("ZIP" , new BasicDBObject("$in", zipcodes) );
}
}
Применение:
public class MongoApplication extends Application <MlsMongoConfiguration> {
public static void main(String[] args) throws Exception {
new MlsMongoApplication().run(args);
}
@Override
public String getName() {
return "mls-dropwizard-mongo";
}
@Override
public void initialize(Bootstrap<MlsMongoConfiguration> bootstrap) {
bootstrap.addBundle(new SwaggerBundle<MlsMongoConfiguration>() {
@Override
protected SwaggerBundleConfiguration getSwaggerBundleConfiguration(MlsMongoConfiguration configuration) {
return configuration.swaggerBundleConfiguration;
}
});
}
@Override
public void run(MlsMongoConfiguration configuration, Environment environment) throws Exception {
MongoClientOptions.Builder clientOptions = new MongoClientOptions.Builder();
clientOptions.minConnectionsPerHost(1000);//min
clientOptions.maxWaitTime(1000);
clientOptions.connectionsPerHost(1000);
//Create Mongo instance
//Mongo mongo = new Mongo(configuration.mongohost, configuration.mongoport);
MongoClient mongoClient = new MongoClient(new ServerAddress(configuration.mongohost, configuration.mongoport), clientOptions.build());
//Add Managed for managing the Mongo instance
//MongoManaged mongoManaged = new MongoManaged(mongo);
MongoManaged mongoManaged = new MongoManaged(mongoClient);
environment.lifecycle().manage(mongoManaged);
//Add Health check for Mongo instance. This will be used from the Health check admin page
environment.healthChecks().register("MongoHealthCheck", new MongoHealthCheck(mongoClient));
//Create DB instance and wrap it in a Jackson DB collection
DB db = mongoClient.getDB(configuration.mongodb);
JacksonDBCollection<Mlsdatadao, String> jacksonDBCollection = JacksonDBCollection.wrap(db.getCollection("mlsdata"), Mlsdatadao.class, String.class);
environment.jersey().register(new MlsMongoResource(jacksonDBCollection));
}
}
Есть ли способ избежать cursor.toArray()? Любые другие советы по настройке производительности были бы очень полезны.
Спасибо.