无法获取 http POST 文件上传的进度 (Android)

Question

我正在开发一个 Android 应用程序，它使用户能够将文件上传到 Twitpic 等服务。 POST 上传无需任何外部库即可完成，并且工作正常。我唯一的问题是，我无法获取任何进度，因为所有上传都是在我收到响应时完成的，而不是在将字节写入输出流时完成的。 这就是我所做的：

URL url = new URL(urlString); 
HttpURLConnection conn = (HttpURLConnection) url.openConnection(); 
conn.setDoInput(true); 
conn.setDoOutput(true); 
conn.setUseCaches(false); 
conn.setRequestMethod("POST"); 
conn.setRequestProperty("Connection", "Keep-Alive"); 
conn.setRequestProperty("Content-Type", "multipart/form-data;boundary=" + boundary); 
DataOutputStream dos = new DataOutputStream(conn.getOutputStream());

然后我将表单数据写入dos，现在这在这里并不那么重要。之后，我写入文件数据本身（从“in”读取，这是我要发送的数据的InputStream）：

while ((bytesAvailable = in.available()) > 0)
{ 
 bufferSize = Math.min(bytesAvailable, maxBufferSize);
 byte[] buffer = new byte[bufferSize];
 bytesRead = in.read(buffer, 0, bufferSize);
 dos.write(buffer, 0, bytesRead);
} 

之后，我发送多部分表单数据以指示文件结尾。然后，我关闭流：

in.close(); 
dos.flush(); 
dos.close(); 

这一切都工作得很好，到目前为止没有问题。然而，我的问题是，无论文件有多大，到目前为止的整个过程大约需要一两秒。 当我阅读响应时，上传本身似乎发生了：

DataInputStream inStream = new DataInputStream(conn.getInputStream());

这需要几秒钟或几分钟，具体取决于文件有多大以及互联网连接的速度。 我现在的问题是： 1）为什么当我将字节写入“dos”时没有发生上传？ 2）当所有事情同时发生时，如何获取进度以便在上传过程中显示进度对话框？

/编辑： 1）我在标头中设置了内容长度，这稍微改变了问题，但在任何情况下都没有 解决方法： 现在，在最后一个字节写入流后，整个内容就会上传。所以，这并不能改变你无法抓取进度的情况，因为同样，数据是一次性写入的。 2）我在Apache HttpClient v4中尝试了MultipartEntity。那里根本没有 OutputStream，因为所有数据都是在执行请求时写入的。话又说回来，没有办法抢进度。

有没有人有其他想法如何在分段/表单上传中获取流程？

Answer 1

在过去的几天里我已经尝试了很多，我想我已经找到了最初问题的答案：

使用 HttpURLConnection 不可能获取进度，因为 Android 中存在错误/异常行为：
http://code.google.com/p/android/ issues/detail?id=3164#c6

它将在 Froyo 后得到修复，这不是人们可以等待的事情......

所以，我发现的唯一其他选择是使用 Apache HttpClient。 papleu 链接的答案是正确的，但它指一般Java。那里使用的类在 Android 中不再可用（HttpClient 3.1 曾经是 SDK 的一部分）。因此，您可以做的是添加 HttpClient 4 中的库（特别是 apache-mime4j-0.6.jar 和 httpmime-4.0.1.jar），并结合使用第一个答案（由 Tuler 提供）和最后一个答案（由 Hamy 提供） ）：

import java.io.FilterOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.nio.charset.Charset;
import org.apache.http.entity.mime.HttpMultipartMode;
import org.apache.http.entity.mime.MultipartEntity;

public class CountingMultipartEntity extends MultipartEntity {

    private final ProgressListener listener;

    public CountingMultipartEntity(final ProgressListener listener) {
        super();
        this.listener = listener;
    }

    public CountingMultipartEntity(final HttpMultipartMode mode, final ProgressListener listener) {
        super(mode);
        this.listener = listener;
    }

    public CountingMultipartEntity(HttpMultipartMode mode, final String boundary,
            final Charset charset, final ProgressListener listener) {
        super(mode, boundary, charset);
        this.listener = listener;
    }

    @Override
    public void writeTo(final OutputStream outstream) throws IOException {
        super.writeTo(new CountingOutputStream(outstream, this.listener));
    }

    public static interface ProgressListener {
        void transferred(long num);
    }

    public static class CountingOutputStream extends FilterOutputStream {

        private final ProgressListener listener;
        private long transferred;

        public CountingOutputStream(final OutputStream out,
                final ProgressListener listener) {
            super(out);
            this.listener = listener;
            this.transferred = 0;
        }


        public void write(byte[] b, int off, int len) throws IOException {
            out.write(b, off, len);
            this.transferred += len;
            this.listener.transferred(this.transferred);
        }

        public void write(int b) throws IOException {
            out.write(b);
            this.transferred++;
            this.listener.transferred(this.transferred);
        }
    }
}

这适用于 HttpClient 4，但缺点是我的 apk 现在大小为 235 kb（当我使用问题中描述的分段上传时，大小为 90 kb），更糟糕的是，安装的应用程序大小为 735 kb （之前大约 170 kb）。
那真是太糟糕了。只是为了在上传过程中取得进展，应用程序的大小现在是以前的 4 倍多。

Answer 2

试试这个。有用。

connection = (HttpURLConnection) url_stripped.openConnection();
    connection.setRequestMethod("PUT");
    String boundary = "---------------------------boundary";
    String tail = "\r\n--" + boundary + "--\r\n";
    connection.addRequestProperty("Content-Type", "image/jpeg");
    connection.setRequestProperty("Connection", "Keep-Alive");
    connection.setRequestProperty("Content-Length", ""
            + file.length());
    connection.setDoOutput(true);

    String metadataPart = "--"
            + boundary
            + "\r\n"
            + "Content-Disposition: form-data; name=\"metadata\"\r\n\r\n"
            + "" + "\r\n";

    String fileHeader1 = "--"
            + boundary
            + "\r\n"
            + "Content-Disposition: form-data; name=\"uploadfile\"; filename=\""
            + fileName + "\"\r\n"
            + "Content-Type: application/octet-stream\r\n"
            + "Content-Transfer-Encoding: binary\r\n";

    long fileLength = file.length() + tail.length();
    String fileHeader2 = "Content-length: " + fileLength + "\r\n";
    String fileHeader = fileHeader1 + fileHeader2 + "\r\n";
    String stringData = metadataPart + fileHeader;

    long requestLength = stringData.length() + fileLength;
    connection.setRequestProperty("Content-length", ""
            + requestLength);
    connection.setFixedLengthStreamingMode((int) requestLength);
    connection.connect();

    DataOutputStream out = new DataOutputStream(
            connection.getOutputStream());
    out.writeBytes(stringData);
    out.flush();

    int progress = 0;
    int bytesRead = 0;
    byte buf[] = new byte[1024];
    BufferedInputStream bufInput = new BufferedInputStream(
            new FileInputStream(file));
    while ((bytesRead = bufInput.read(buf)) != -1) {
        // write output
        out.write(buf, 0, bytesRead);
        out.flush();
        progress += bytesRead;
        // update progress bar
        publishProgress(progress);
    }

    // Write closing boundary and close stream
    out.writeBytes(tail);
    out.flush();
    out.close();

    // Get server response
    BufferedReader reader = new BufferedReader(
            new InputStreamReader(connection.getInputStream()));
    String line = "";
    StringBuilder builder = new StringBuilder();
    while ((line = reader.readLine()) != null) {
        builder.append(line);
    }

参考：http://delimitry.blogspot.in/2011/08/android -upload-progress.html

Answer 3

可以从 DefaultHttpClient 获取进度。事实上，它会保留在队列中

response = defaultHttpClient.execute( httpput, context );

直到发送完整的数据，但这并不一定意味着您无法获取进度。也就是说，HttpContext 在执行此行时发生变化，因此如果您通过不同的线程访问它，您可能会观察到其中的变化。你需要的是ConnAdapter。它嵌入了 HttpConnectionMetrics

final AbstractClientConnAdapter connAdapter = (AbstractClientConnAdapter) context.getAttribute(ExecutionContext.HTTP_CONNECTION);
final HttpConnectionMetrics metrics = connAdapter.getMetrics();
int bytesSent = (int)metrics.getSentBytesCount();

如果您定期检查它，您将观察进度。确保正确处理线程，并保护所有 try/catch。特别是，处理 Context 不再有效的情况 (IllegalStateException)，这种情况在 Put 取消或完成时发生。

Answer 4

请改用 WatchedInputStream。
它很好，很棒，而且很容易使用。

1. 使用 WatchedInputStream 来包装您的输入流。

2. watchedStream.setListener

   watchedStream.setListener(new WatchedInputStream.Listener() {

   公共无效通知（int读）{
   // 执行一些操作来更新 UI。
   }
   }