java - 扩展的MultipartEntity无法正确写出流

我想在我的AndroidHttpClient中实现一个ProgressDialog。我在CountingMultipartEntity中找到了一个简单的实现。
另外，我添加了内容长度支持。我覆盖了方法addPart。
FileBody上传几乎可以正常工作。当上载包含一个文件时，它可以完美工作，但是当有两个文件时，第二个文件仅部分上载。
InputStreamBody有效，但仅当我不计算InputStream的长度时才有效。所以我必须重置它，但是如何？

这是我最重要的addPart：

@Override
public void addPart(String name, ContentBody cb) {
    if (cb instanceof FileBody) {
        this.contentLength += ((FileBody) cb).getFile().length();
    } else if (cb instanceof InputStreamBody) {
        try {
            CountingInputStream in =
                new CountingInputStream(((InputStreamBody) cb).getInputStream());
            ObjectInputStream ois = new ObjectInputStream(in);
            ois.readObject();
            this.contentLength += in.getBytesRead();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    super.addPart(name, cb);
}

CountingInputStream是InputStream的简单扩展：

public class CountingInputStream extends InputStream {
    private InputStream source;
    private long bytesRead = 0;

    public CountingInputStream(InputStream source) {
        this.source = source;
    }

    public int read() throws IOException {
        int value = source.read();
        bytesRead++;
        return value;
    }

    public long getBytesRead() {
        return bytesRead;
    }
}

计数几乎可以正常工作，只有2个字节，不应存在。但这是如此重要。

首先，我认为必须重置流。在in.getReadedBytes();之后调用的重置将导致IOException。

感谢您的任何建议。

最佳答案

我发现了我的错误。我已经覆盖了方法getContentLength()，这对于传输很重要，在删除自己的版本后，文件传输可以正常工作。

为了获得InputStream的大小，我使用了上面的类，但是编辑了getBytesRead()方法，因为ObjectInputStream导致StreamCorruptedException：

public long getBytesRead() {
    try {
        while (read() != -1)
            ;
    } catch (IOException e) {
        e.printStackTrace();
    }

    return bytesRead;
}

要获取内容长度，如果没有任何流，则可以采用给定的方法getContentLength()。
否则，您必须实现自己的内容长度计算。上面的方法addPart(String name, ContentBody cb)提供了一种方法。您可以从类MultiPartyEntity和HttpMultipart中获得有关内容长度计算的更多详细信息。

AddPart

java - 扩展的MultipartEntity无法正确写出流