我需要一个 api 来执行没有长度的八位字节流。它只是实时数据流。我遇到的问题是，当我发出请求时，它似乎在将信息读入输入流之前尝试等待内容结束，但是它没有看到内容结束和超时，并出现 NoHttpResponse 异常。下面是我的代码的简化版本:

private static HttpPost getPostRequest() {
    // Build uri
    URI uri = new URIBuilder()
            .setScheme("https")
            .setHost(entity.getStreamUrl())
            .setPath("/")
            .build();

    // Create http http
    HttpPost httpPost = new HttpPost(uri);

    String nvpsStr = "";
    Object myArray[] = nvps.toArray();
    for(int i = 0; i < myArray.length; i ++) {
        nvpsStr += myArray[i].toString();
        if(i < myArray.length - 1) {
            nvpsStr += "&";
        }
    }

    // Build http payload
    String request = nvpsStr + scv + streamRequest + "\n\n";
    // Attach http data
    httpPost.setEntity(new StringEntity(URLEncoder.encode(request,"UTF-8")));

    return httpPost;
}

// Where client is simply
// private static final CloseableHttpClient client = HttpClients.createDefault();
private static runPostRequest (HttpPost request) {
    CloseableHttpResponse response = client.execute(request);
    try {
        HttpEntity ent = response.getEntity();
        InputStream is = ent.getContent();
        DataInputStream dis = new DataInputStream(is);
        // Only stream the first 200 bytes
        for(int i = 0; i < 200; i++) {
            System.out.println(( (char)dis.readByte()));
        }

    } finally {
        response.close();
    }
}

最佳答案

编辑 2

因此，如果您对线程/可运行对象/处理程序不满意并且对 android AsyncTask 不满意，我会直接转到 HttpUrlConnection(放弃 Apache HttpClient 的整个练习，因为基本上 Google 说 HttpUrlConnection 将支持流式响应它确实有效!)

检测所有细节(如转储 header )可能并不容易。但是对于正常的流式响应对象，我认为它应该可以正常工作....请参阅 HttpsUrlConnection 代码示例的编辑 3

EndEdit2

从问题中不清楚正在使用什么“流”协议(protocol)(渐进式下载或 HTTP 流式传输)或者您实际如何管理客户端上的流式响应。

建议从连接中转储 header 以准确查看客户端和服务器同意的内容？？

我假设您关闭了 UI 线程(在 AsyncTask 中或在 Handler 的回调部分)；如果这不准确，您可能需要稍微重构一下。

假设 HTTP 流与 Apache HttpClient 4.3.5+ 一起使用

如果响应的 header 中没有长度，那么您将在 HTTP 1.1 上执行“分块”响应，您必须读取缓冲区，直到获得“最后一 block ”或决定关闭流或连接:

服务器刚刚开始发送(流式传输)，客户端应该根据关于生成实体内容的详细 Apache 说明，通过使用缓冲区来处理它从 HTTP 响应中获取的“输入流”。 >

我不记得 30 秒的套接字超时是否会抢占 Activity 流？请记住，在 Apache 中，构建器中存在套接字超时和读取 超时的单独设置。不希望套接字关闭，也不希望在服务器提供响应时超时等待可读流的可用字节。

无论如何，客户端处理程序只需要通过检查读入缓冲区的内容来了解​​流是如何结束的...

如果适当的协议(protocol)是“继续”和“分块”，那么客户端上的响应处理程序应该处于流处理程序循环中，直到它看到来自 http spec 的最后一个 block 。 .

 response.getEntity().getContent() 

应该为您提供处理响应流所需的引用，直到“last-chunk”...

我认为你应该 read here关于如何使用缓冲实体，其中需要多次读取才能在响应中的“最后一个 block ”处结束。这是 HttpURLConnection 可能更容易的另一个原因......

执行一个循环来处理缓冲读取，直到匹配“last-chunk”的字节发出 END 信号为止。

然后根据关于消费实体和可重用连接的详细 Apache 说明关闭流或连接。

编辑 apache HttpClient 中流响应的代码

在“处理程序的回调”或“异步任务”中

 request.execute();
...

 processStreamingEntity(response.getEntity());
 response.close();

//implement your own wrapper as mentioned in apache docs

    private void processStreamingEntity(HttpEntity entity) throws IOException {
        InputStreamHttpEntityHC4 bufHttpEntity = new InputStreamHttpEntityHC4(entity);
        while not bufHttpEntity.LAST_CHUNK {
            handleResponse(bufHttpEntity.readLine())
}

编辑 3

HttpURLConnection 版本，如果你这样做的话。 (使用 MessageHandler 但您可以就地使用字节，因为这是来自流式语音示例，文本中的单词正在此处发送回 UI)

private void openHttpsConnection(String urlStr, Handler mhandler) throws IOException {
    HttpsURLConnection httpConn = null;
    String line = null;
    try {
        URL url = new URL(urlStr);
        URLConnection urlConn = url.openConnection();               
        if (!(urlConn instanceof HttpsURLConnection)) {
            throw new IOException ("URL is not an Https URL");
        }               
        httpConn = (HttpsURLConnection)urlConn;
        httpConn.setAllowUserInteraction(false);
        httpConn.setInstanceFollowRedirects(true);
        httpConn.setRequestMethod("GET");
        httpConn.setReadTimeout(50 * 1000);
        BufferedReader is =
                new BufferedReader(new InputStreamReader(httpConn.getInputStream()));                   
        
        while ((line = is.readLine( )) != null) {

                Message msg = Message.obtain();
                msg.what=1;  
                msg.obj=line;                       
                mhandler.sendMessage(msg);
            
        }               
    } catch (MalformedURLException e) {
        e.printStackTrace();
    } catch( SocketTimeoutException e){
        e.printStackTrace();
    } catch (IOException e) {

        e.printStackTrace();
        Message msg = Message.obtain();
            msg.what=2;
            BufferedInputStream in = new BufferedInputStream(httpConn.getErrorStream());
    
            line =new String(readStream(in));
            msg.obj=line;
            mhandler.sendMessage(msg);
          
    }
    finally {httpConn.disconnect();}

}

关于java - 如何使用 apache HttpClient 流式传输响应正文，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/27371201/