从try资源结构返回未来

Question

我有下面的方法，它使用Apache Commons Http客户机向给定的URI发送异步GET，并返回Future和响应。

CloseableHttpAsyncClient实现了Closeable，因此我使用try/resource结构。

public static Future<HttpResponse> sendAsyncGet(String uri) throws IOException {
    try (CloseableHttpAsyncClient asyncHttpClient = HttpAsyncClients.createDefault()) {
        asyncHttpClient.start();
        HttpGet httpGet = new HttpGet(uri);
        return asyncHttpClient.execute(httpGet, null);
    }

下面您可以看到其用法：

Future<HttpResponse> future = sendAsyncGet("http://www.apache.org");
future.get(3, TimeUnit.SECONDS);

问题是，当我调用get on a future时，它不会返回所需的HttpResponse。如果我使用重载的get（）方法，它将一直等待，直到超过超时或永远。我想这是因为try/resource没有正确发布。

如何改进给定的方法/代码以便能够正确使用：方法正文中包含的try/资源结构的未来？

更新：

这是maven依赖性:

   <dependency>
        <groupId>org.apache.httpcomponents</groupId>
        <artifactId>httpasyncclient</artifactId>
        <version>4.1.1</version>
        <scope>test</scope>
    </dependency>

Answer 1

尝试使用资源将在收到响应之前关闭异步客户端。

您可能希望通过将来传递给执行调用的回调来关闭异步客户端。

public static Future<HttpResponse> sendAsyncGet(String uri) throws IOException {
    final CloseableHttpAsyncClient asyncHttpClient;

    asyncHttpClient = HttpAsyncClients.createDefault();
    asyncHttpClient.start();

    return asyncHttpClient.execute(new HttpGet(uri), new FutureCallback<HttpResponse>() {
        private void close() {
            try {
                asyncHttpClient.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

        @Override
        public void completed(HttpResponse response) {
            close();
            System.out.println("completed");
        }

        @Override
        public void failed(Exception e) {
            close();
            e.printStackTrace();
        }

        @Override
        public void cancelled() {
            close();
            System.out.println("cancelled");
        }
    });
}