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();
	@Override
	protected 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() {
		
		@Override
		public 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(){
		@Override
		public 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

具体操作见附件源码：