java - 插入文档时达到最大池大小时出现 ConnectionPoolTimeoutException

Question

我已经使用 Azure DocumentDB 几天了，在插入数据时遇到了奇怪的行为。 (我使用maven https://github.com/Azure/azure-documentdb-java的java sdk 1.0版本)

要插入数据，我循环遍历我的 pojo，并尝试像这样插入它们:

for (Order order : jsonImporter.getOrderList()) {
    Document doc = new Document(gson.toJson(order, Order.class));
    doc.setId(order.uuid);
    doc.set(TYPE, TYPE_ORDER);
    try {
        client.createDocument(getCollection().getSelfLink(), doc, null, true);
    } catch (DocumentClientException e) {
        System.err.printf("AzureDocumentDB - insertOrder request failed (order uuid %s)", order.uuid);
        System.err.println(e.getMessage());
    }
}

问题是，当我到达第一百个元素(这是最大连接池大小)时，我得到一个异常，即我的连接池无法给我另一个连接。我也尝试修改连接池的设置，增加连接数据，减少“IdleConnectionTimeout”以提前释放连接，但没有成功。
例如，当我将池大小增加到 500 时，在第 500 个元素之后出现异常。

ConnectionPolicy connectionPolicy = new ConnectionPolicy();
connectionPolicy.setMaxPoolSize(500);
connectionPolicy.setIdleConnectionTimeout(10);
client = new DocumentClient(END_POINT, MASTER_KEY, connectionPolicy, ConsistencyLevel.Session);

有人在我的代码中发现 API 滥用吗？有人在插入数据时遇到过同样的行为吗？或者 sdk 或 apache http 客户端中是否存在导致连接未释放的已知错误？我将不胜感激每一个帮助。

异常(exception):

java.lang.IllegalStateException: Http client execution failed.
    at com.microsoft.azure.documentdb.GatewayProxy.performPostRequest(GatewayProxy.java:350)
    at com.microsoft.azure.documentdb.GatewayProxy.doCreate(GatewayProxy.java:90)
    at com.microsoft.azure.documentdb.DocumentClient.doCreate(DocumentClient.java:1968)
    at com.microsoft.azure.documentdb.DocumentClient.createDocument(DocumentClient.java:456)
    ...
Caused by: org.apache.http.conn.ConnectionPoolTimeoutException: Timeout waiting for connection from pool
    at org.apache.http.impl.conn.PoolingClientConnectionManager.leaseConnection(PoolingClientConnectionManager.java:226)
    at org.apache.http.impl.conn.PoolingClientConnectionManager$1.getConnection(PoolingClientConnectionManager.java:195)
    at org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:423)
    at org.apache.http.impl.client.AbstractHttpClient.doExecute(AbstractHttpClient.java:863)
    at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:82)
    at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:106)
    at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:57)
    at com.microsoft.azure.documentdb.GatewayProxy.performPostRequest(GatewayProxy.java:347)

Answer 1

您看到 ConnectionPoolTimeoutException 是因为 DocumentClient 在调用 createXXXXXXXXX() 时不会自动关闭流。此行为旨在支持 createAttachment() 的流式 Blob 附件。

要关闭流，可以调用 close() 来关闭流，或者调用 .getResource() 返回资源，然后关闭流。

换句话说，替换以下行:

client.createDocument(getCollection().getSelfLink(), doc, null, true);

与:

client.createDocument(getCollection().getSelfLink(), doc, null, true).close();

或者:

doc = client.createDocument(getCollection().getSelfLink(), doc, null, true).getResource();