17

我正在开发一个 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）我在标题中设置了Content-Length，这稍微改变了问题，但并没有以任何方式解决它：现在整个内容在最后一个字节写入流后上传。所以，这并没有改变你无法抓取进度的情况，因为数据是一次写入的。2）我在 Apache HttpClient v4 中尝试了 MultipartEntity。那里根本没有 OutputStream，因为所有数据都是在执行请求时写入的。再说一次，没有办法抓住进展。

有没有人知道如何在多部分/表单上传中获取进程？

4

4 回答 4

20

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

无法使用 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 倍多。

于 2010-07-14T12:29:26.163 回答
1

试试这个。有用。

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

于 2014-05-01T12:42:41.293 回答
0

可以从 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 取消或完成时。

于 2012-03-05T08:47:08.943 回答
0

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

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

  2. watchStream.setListener

    watchedStream.setListener(new WatchedInputStream.Listener() {

    public void notify(int read) { // 更新 UI。
    } }

于 2012-03-28T07:24:35.150 回答