如何在MongoDB中使用Jmeter查询文档

Question

我一直在使用jmeter对mongodb进行加载测试，接下来我将使用一个具有这些数据的不同的db

我已经在这里保存了已保存的mongoHost,mongoPort,databaseName,collectionName

jmeter变量

import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoClient;
import com.mongodb.MongoClientSettings;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.MongoCollection;
import static com.mongodb.client.model.Filters.*;
import org.bson.Document;

import java.util.Arrays;
try{


MongoClientSettings settings = MongoClientSettings.builder()
.applyToClusterSettings {builder -> 
builder.hosts(Arrays.asList(new ServerAddress(vars.get("mongoHost"),vars.get("mongoPort").toInteger())))}
.build();

MongoClient mongoClient = MongoClients.create(settings);
MongoDatabase database = mongoClient.getDatabase(vars.get("databaseName"));
MongoCollection<Document> collection = database.getCollection(vars.get("collectionName"));

vars.putObject("collection", collection);   
return "Connected to " + vars.get("collectionName");
}
catch (Exception e) {
    SampleResult.setSuccessful(false);
    SampleResult.setResponseCode("500");
    SampleResult.setResponseMessage("Exception: " + e);
}

这个连接测试通过了，但我无法从数据库中获取、读取任何数据并通过测试，这是代码

import com.mongodb.client.MongoCollection;
import static com.mongodb.client.model.Filters.*;

import org.bson.Document;
import org.bson.types.ObjectId;

try {
    MongoCollection<Document> collection = vars.getObject("collection");
    
    Document result = collection.find(eq("city","CUSHMAN")).first();

    vars.put("exampleDocumentId", result.get("_id").toString());
    
    return "Document with id=" + result.get("_id") + " found";
}
catch (Exception e) {
    SampleResult.setSuccessful(false);
    SampleResult.setResponseCode("500");
    SampleResult.setResponseMessage("Exception: " + e);
}

错误

Response code:500
Response message:Exception: com.mongodb.MongoTimeoutException: Timed out after 30000 ms while waiting to connect. Client view of cluster state is {type=UNKNOWN, servers=[{address=localhost:27017, type=UNKNOWN, state=CONNECTING, exception={com.mongodb.MongoSocketReadException: Exception receiving message}, caused by {java.io.IOException: An existing connection was forcibly closed by the remote host}}]

谢谢你

Answer 1

我没有看到“连接测试通过”的证据，如果您查看异常详细信息：

• 状态=connecting
• Exception={com.mongodb.mongosocketreadexception：Exception receiving message},
• 由{java.io.ioException：远程主机强制关闭了现有连接}}]
引起

因此，我宁愿检查您是否可以使用其他MongoDB客户端（如Mongo Shell）运行此查询，因为这似乎是一个常见的网络问题，或者您的MongoDB实例只是还没有启动。

为了获得更多信息，您可以为Mongo Java客户端驱动程序增加JMeter日志的冗长，可以通过在log4j2.xml文件中添加下一行来实现：

<Logger name="com.mongodb.client" level="debug" />