0

使用 apache htttpasyncclient 时如何正确处理各种异常情况？考虑以下基于此示例的伪代码我已将消费者参数添加到执行调用的位置。目的是发出一个异步 http 请求，当字节进来时数据作为流处理，而不是在处理之前等待完整的响应完成。可能会出现各种问题，例如 http 请求的超时异常、连接失败（可能是没有网络）等。是否始终保证例如在响应未及时返回的超时时 releaseResources() 总是叫。问题是需要将latch.countDown() 放在下面的代码中的什么位置，以始终保证无论发生什么异常，await 调用都不会挂起。StreamConsumer.releaseResources() 中对 latch.countDown() 的调用是否足以防止在等待时挂起？

public static void main(final String[] args) throws Exception {
    client.execute(HttpAsyncMethods.createGet(u), new StreamConsumer(...), new FutureCallback<Boolean>() {
        @Override
        public void cancelled() {
            // Is latch call needed here?
            // latch.countDown();
        }

        @Override
        public void completed(Boolean response) {
            // Is latch call needed here?
            // latch.countDown();
        }

        @Override
        public void failed(Exception e) {
            // Is latch call needed here?
            // latch.countDown();
        }
    });

    latch.await();
}


static class StreamConsumer extends AsyncByteConsumer<Boolean> {
    @Override
    protected void onResponseReceived(final HttpResponse response) {
       latch.countDown();
    }

    @Override
    protected void onByteReceived(final ByteBuffer buf, final IOControl ioctrl) throws IOException {

    }

    @Override
    protected void releaseResources() {
        latch.countDown();
    }

}
4

1 回答 1

0

CloseableHttpAsyncClient#execute方法在将请求提交到请求执行管道时立即终止，并返回一个Future表示操作未来结果的对象。

因此，示例中的闩锁需要确保客户端不会在CloseableHttpAsyncClient#execute调用后立即关闭。

如果一个人CloseableHttpAsyncClient用作具有已定义生命周期（应该如此）的单例，则请求完成和客户端关闭的同步可能是不必要的。

于 2019-03-06T08:23:50.730 回答