我有一个工作的FTP系统与Android，但我希望能够跟踪字节，因为他们得到上传，这样我就可以更新进度条的上传进度。与Android这可能吗？现在，我使用 org.apache.common.net.ftp 和code我使用的是下面。另外，我在AsyncTask的运行这一点。

I have a working FTP system with android, but I want to be able to track the bytes as they get uploaded, so I can update a progress bar as the upload progresses. Is this possible with Android? Right now, I'm using org.apache.common.net.ftp and the code I'm using is below. Also, I am running this in an AsyncTask.

package com.dronnoc.ftp.complex;

import java.io.BufferedInputStream;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.SocketException;

import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.io.CopyStreamEvent;
import org.apache.commons.net.io.CopyStreamListener;
import org.apache.commons.net.io.Util;

import android.app.Activity;
import android.os.AsyncTask;
import android.os.Bundle;
import android.util.Log;
import android.view.Window;

public class Main extends Activity {
    /** Called when the activity is first created. */
    @Override
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        requestWindowFeature(Window.FEATURE_INDETERMINATE_PROGRESS);


        setContentView(R.layout.main);

        String text = "BIGFILE"; //Big file here

        InputStream data = new ByteArrayInputStream(text.getBytes());

        new ComplexFTPTransfer().execute(data);
    }

    private class ComplexFTPTransfer extends AsyncTask<InputStream, Long[], Void>
    {
        private FTPClient ftp = null;

        @Override
        protected void onPreExecute() {
            super.onPreExecute();

            try {
                ftp = new FTPClient();
                ftp.connect("hostname");
            } catch (SocketException e) {
                this.cancel(true);
            } catch (IOException e) {
                this.cancel(true);
            }

            Main.this.setProgressBarIndeterminateVisibility(true);

        }


        @Override
        protected Void doInBackground(InputStream... params) {
            if(!this.isCancelled())
            {
                try 
                {
                    if(ftp.login("user", "pass"))
                    {
                        ftp.enterLocalPassiveMode();

                        InputStream item = params[0];

                        int streamSize = 0;
                        while(item.read() != -1)
                        {
                            streamSize++;
                        }

                        InputStream is = new BufferedInputStream(params[0], streamSize);
                        OutputStream os = ftp.storeFileStream("/test.txt");

                        Util.copyStream(is, os, streamSize, streamSize, new CopyStreamListener() {

                            @Override
                            public void bytesTransferred(long totalBytesTransferred, int bytesTransferred, long streamSize) {
                                publishProgress(new Long[] {totalBytesTransferred, streamSize});
                            }

                            @Override
                            public void bytesTransferred(CopyStreamEvent event) {

                            }
                        });
                        ftp.completePendingCommand();
                    }
                    ftp.logout();
                    ftp.disconnect();

                }
                catch (IOException e) {

                }
                catch (Exception e) {

                }
            }
            return null;
        }


        @Override
        protected void onProgressUpdate(Long[]... values) {
            super.onProgressUpdate(values);
            Log.d("UPDATE", values[0] + " of " + values[1] + " copied.");
            //TODO Put code here
        }

        @Override
        protected void onPostExecute(Void result) {
            // TODO Auto-generated method stub
            super.onPostExecute(result);
            Main.this.setProgressBarIndeterminateVisibility(false);
        }
    }
}

我想知道的是，如果我可以运行一个进度条，更新每隔几载的字节？ 干杯

What I want to know is if I can run a progress bar, updating every few uploaded bytes? Cheers

推荐答案

This问题有一个InputStream，其中包括一个进度回调的实现。请使用InputStream和文件上传过程中调用publishProgress从回调的增量更新。

This question has an implementation of an InputStream that includes a progress callback. Use that InputStream and call publishProgress from that callback for incremental updates during the file upload.