在响应完成之前关闭HttpURLConnection

Question

背景

我正在HttpURLConnection客户端使用HTTP流（服务器推送）情况下的响应。尽管服务器可以通过关闭响应来关闭连接，但是客户端也需要这样做。

问题

客户端InputStream在一个单独的线程中处理，如下所示：

@Override
public void run() {
    try {
        for (int b = in.read(); b >= 0; b = in.read()) {
            char c = (char) b;
            // Do something with the character
            // ...
        }
    }
    catch (IOException e) {
    }
}

因此，当我HttpURLConnection.disconnect()从发起连接的线程进行调用时（重要的信息是它与处理输入的线程不同），该调用将无限期挂起。我什至把它留了一夜，它仍然挂着。即使打电话Thread.interrupt()也无济于事。

有什么建议吗？

Answer 1

InputStream.available()在没有可用字节的情况下，如果不更改读取线程以进行轮询使用并睡眠一小段时间，似乎无法完成此操作，同时检查某个标志以查看线程是否应结束。

解决方案是仅使用Apache HTTP组件。通过将GET请求的代码封装在一个类中，可以很容易地将其集成到现有代码中。

public class HttpGetConnection implements AutoCloseable {
    public HttpGetConnection(String url) throws IOException {
        client = new DefaultHttpClient();
        get = new HttpGet(url);
        response = client.execute(get);
        entity = response.getEntity();
    }

    public InputStream getContent() throws IOException {
        content = entity.getContent();
        return content;
    }

    @Override
    public void close() throws Exception {
        get.abort();
        try {
            content.close();
        }
        catch (IOException e) {
        }
    }

    private HttpClient client;
    private HttpGet get;
    private HttpResponse response;
    private HttpEntity entity;
    private InputStream content;
}

原始帖子中的循环可以保持不变，并且读取线程将在调用后不久终止HttpGetConnection.close()。