Android 文件实现断点上传

Android 实现断点上传文件

使用Socket TCP/IP方式进行文件上传

代码：

package com.example.androidseekuploadfile;import java.io.File;import java.io.OutputStream;import java.io.PushbackInputStream;import java.io.RandomAccessFile;import java.net.Socket;import android.app.Activity;import android.os.Bundle;import android.os.Environment;import android.os.Handler;import android.os.Message;import android.view.View;import android.view.View.OnClickListener;import android.widget.Button;import android.widget.EditText;import android.widget.ProgressBar;import android.widget.TextView;import android.widget.Toast;import com.example.androidseekuploadfile.db.UploadLogService;import com.example.androidseekuploadfile.tools.StreamTool;/** * android实现断点上传文件 * @author miaowei * */public class MainActivity extends Activity {/** * 文件名 */private EditText filenameEditText;/** * 上传结果  */private TextView resultView;/** * 等待框 */private ProgressBar uploadBar;/** * 上传服务 */private UploadLogService logService;/** * 是否开启上传 */private boolean start = true;/** * 上传 */private Button btn_upload;/** * 暂停 */private Button btn_stop;/** * 本地测试 */String pathString = Environment.getExternalStorageDirectory().getAbsolutePath();@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);logService = new UploadLogService(this);    filenameEditText = (EditText)this.findViewById(R.id.filename);    uploadBar = (ProgressBar) this.findViewById(R.id.uploadbar);    resultView = (TextView)this.findViewById(R.id.result);    btn_upload =(Button)this.findViewById(R.id.btn_upload);    btn_stop =(Button)this.findViewById(R.id.btn_stop);   btn_upload.setOnClickListener(onClickListener);btn_stop.setOnClickListener(onClickListener);}/** * 事件处理 */private OnClickListener onClickListener = new OnClickListener() {@Overridepublic void onClick(View v) {switch (v.getId()) {case R.id.btn_upload://上传start = true;String filename = filenameEditText.getText().toString(); //判断SDCard是否存在                if(Environment.getExternalStorageState().equals(Environment.MEDIA_MOUNTED)){                        //取得SDCard的目录                //File uploadFile = new File(Environment.getExternalStorageDirectory(), filename);                 //本地测试使用                File uploadFile = new File(pathString+"/Android/data/com.mapbar.info.collection/files/cache.zip");                                    if(uploadFile.exists()){                    //开始上传文件                        uploadFile(uploadFile);                                            }else{                                             Toast.makeText(MainActivity.this,"文件不存在",Toast.LENGTH_SHORT).show();                        }                    }else{                                     Toast.makeText(MainActivity.this,"未检测到SD卡", Toast.LENGTH_SHORT).show();                    }   break;case R.id.btn_stop://暂停start = false;break;default:break;}}};/**       * 上传文件     * 启动一个线程，使用Handler来避免UI线程ANR错误        * @param uploadFile       */        private void uploadFile(final File uploadFile) {            new Thread(new Runnable() {                         @Override                public void run() {                    try {                //设置长传文件的最大刻度                  uploadBar.setMax((int)uploadFile.length());                 //判断文件是否已有上传记录                    String souceid = logService.getBindId(uploadFile);                     //构造拼接协议                     String head = "Content-Length="+ uploadFile.length() + ";filename="+ uploadFile.getName() + ";sourceid="+                            (souceid==null? "" : souceid)+"\r\n";                     //通过Socket取得输出流                    //测试使用，具体自配                    Socket socket = new Socket("192.168.1.10",8080);                        OutputStream outStream = socket.getOutputStream();                        outStream.write(head.getBytes());                                                PushbackInputStream inStream = new PushbackInputStream(socket.getInputStream());                            //获取到字符流的id与位置                    String response = StreamTool.readLine(inStream);                        String[] items = response.split(";");                        String responseid = items[0].substring(items[0].indexOf("=")+1);                        String position = items[1].substring(items[1].indexOf("=")+1);                     //代表原来没有上传过此文件，往数据库添加一条绑定记录                     if(souceid==null){                        logService.save(responseid, uploadFile);                        }                        RandomAccessFile fileOutStream = new RandomAccessFile(uploadFile, "r");                        fileOutStream.seek(Integer.valueOf(position));                        byte[] buffer = new byte[1024];                        int len = -1;                     //初始化长传的数据长度                     int length = Integer.valueOf(position);                        while(start&&(len = fileOutStream.read(buffer)) != -1){                            outStream.write(buffer, 0, len);                         //设置长传数据长度                         length += len;                            Message msg = new Message();                            msg.getData().putInt("size", length);                            mHandler.sendMessage(msg);                        }                        fileOutStream.close();                        outStream.close();                        inStream.close();                        socket.close();                     //判断上传完则删除数据                    if(length==uploadFile.length()){                                        logService.delete(uploadFile);                    }                                         } catch (Exception e) {                        e.printStackTrace();                    }                }            }).start();        } /** * 使用Handler给创建他的线程发送消息 * UI更新 */private Handler mHandler = new Handler(){@Overridepublic void handleMessage(Message msg) {//获得上传长度的进度 int length = msg.getData().getInt("size");    uploadBar.setProgress(length);                float num = (float)uploadBar.getProgress()/(float)uploadBar.getMax();                //设置显示结果              int result = (int)(num * 100);                resultView.setText(result+ "%");             //上传成功            if(uploadBar.getProgress()==uploadBar.getMax()){                             Toast.makeText(MainActivity.this, "上传成功", Toast.LENGTH_SHORT).show();                } }};}

package com.example.androidseekuploadfile.db;import java.io.File;import android.content.Context;import android.database.Cursor;import android.database.sqlite.SQLiteDatabase;/** * 操作数据库 * @author miaowei * */public class UploadLogService {private DBOpenHelper dbOpenHelper;          public UploadLogService(Context context){          this.dbOpenHelper = new DBOpenHelper(context);      }       /**      * 保存上传文件断点数据       * @param sourceid 标识ID      * @param uploadFile 文件      */    public void save(String sourceid, File uploadFile){          SQLiteDatabase db = dbOpenHelper.getWritableDatabase();          db.execSQL("insert into uploadlog(uploadfilepath, sourceid) values(?,?)",                  new Object[]{uploadFile.getAbsolutePath(),sourceid});      }            /**     * 文件上传完成，删除上传文件断点数据     * @param uploadFile     */    public void delete(File uploadFile){          SQLiteDatabase db = dbOpenHelper.getWritableDatabase();          db.execSQL("delete from uploadlog where uploadfilepath=?", new Object[]{uploadFile.getAbsolutePath()});      }            /**     * 根据文件的上传路径得到绑定的id     * @param uploadFile     * @return     */    public String getBindId(File uploadFile){          SQLiteDatabase db = dbOpenHelper.getReadableDatabase();          Cursor cursor = db.rawQuery("select sourceid from uploadlog where uploadfilepath=?",                   new String[]{uploadFile.getAbsolutePath()});          if(cursor.moveToFirst()){              return cursor.getString(0);          }          return null;      } }

package com.example.androidseekuploadfile.db;import android.content.Context;import android.database.sqlite.SQLiteDatabase;import android.database.sqlite.SQLiteOpenHelper;/** * 数据库帮助类 * @author miaowei * */public class DBOpenHelper extends SQLiteOpenHelper {/** * 文件名 */private String uploadfilepath;/** * 记录文件标识 */private String sourceid;public DBOpenHelper(Context context) {          super(context, "upload.db", null, 1);      }    /** * 创建数据库 */    @Override      public void onCreate(SQLiteDatabase db) {          db.execSQL("CREATE TABLE uploadlog (_id integer primary key autoincrement, uploadfilepath varchar(100), sourceid varchar(10))");      }        @Override      public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {          db.execSQL("DROP TABLE IF EXISTS uploadlog");          onCreate(db);             }  }

分享：http://blog.csdn.net/shimiso/article/details/8529633

具体操作见附件源码：

AndroidSeekUploadFile.rar (1.2 MB)
下载次数: 53

更多相关文章

随机推荐