Android06_getpost提交_文件上传_多线程下载

package com.zzx.mutidown;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.InputStream;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;
import java.net.URL;

import android.app.Activity;
import android.os.Bundle;
import android.os.Environment;
import android.text.TextUtils;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;
import android.widget.EditText;
import android.widget.ProgressBar;
import android.widget.Toast;

public class MainActivity extends Activity {
    private static int threadcount = 3;
    private static long startindex;
    private static  long endindex;
    private static String path;
    private static int len;
    private static String filename;
    private EditText et_ph;
    private Button bt_sub;
    private static ProgressBar pb_01;
    private static ProgressBar pb_02;
    private static ProgressBar pb_03;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        
        init();
        /**
         * 开启断点下载
         */
        bt_sub.setOnClickListener(new OnClickListener() {
            @Override
            public void onClick(View v) {
                 System.out.println(1111);
                onclick();
            }
        });
    
    }
    
    private void onclick() {
        new Thread(){
            public void run() {
                //获取路径
                String path = "http://192.168.16.80:8080/aaa.txt";
                if(TextUtils.isEmpty(path)){
                    System.out.println("请输入正确的内容");
                    return;
                }
                try {
                    URL url = new URL(path);
                    HttpURLConnection conn = (HttpURLConnection) url.openConnection();
                    //获取长度
                    len = conn.getContentLength();
                    //获取文件名
                    filename = path.substring(path.lastIndexOf("/")+1);
                    RandomAccessFile raf = new RandomAccessFile(Environment.getExternalStorageDirectory().getPath() +"/" + filename, "rwd");
                    raf.setLength(len);
                    //这里记得关流
                    raf.close();
                    //划分每一个子线程的长度
                    for (int i = 0; i < threadcount; i++) {
                        startindex = i*len/threadcount;
                    
                        if(i<threadcount-1){
                        endindex = (i+1)*len/threadcount-1;
                        }else{
                            endindex = len-1;    
                        }
                        if(i==0){
                            pb_01.setMax((int)endindex);
                        }else if(i==1){
                            pb_02.setMax((int)endindex);
                        }else if(i==2){
                            pb_03.setMax((int)endindex);
                        }
                        MyThread mt = new MyThread(startindex, endindex, i);
                        mt.start();
                    }
                } catch (Exception e) {
                    Toast.makeText(MainActivity.this, "网络异常", 0).show();
                }
            };
            
        }.start();
    }

    /**
     * 加载控件
     */
    private void init() {
        et_ph = (EditText) findViewById(R.id.urlpath);
        bt_sub = (Button) findViewById(R.id.submit);
        pb_01 = (ProgressBar) findViewById(R.id.progressBar1);
        pb_02 = (ProgressBar) findViewById(R.id.progressBar2);
        pb_03 = (ProgressBar) findViewById(R.id.progressBar3);
    }
    /**
     * 这里是自定义文件下载子线程
     * @author msi
     *
     */
    static class MyThread extends Thread{
        /**
         * 初始化线程类
         * @param startindex    开始的位置
         * @param endindex    结束的位置
         * @param breakpoint    断点的位置
         */
        private long startindex;
        private  long endindex;
        private static int deleteindex = threadcount;
        private  long i ;
        private  long breakpoint;
        public MyThread(long startindex,long endindex,int i){
            this.startindex = startindex;
            this.endindex = endindex;
            this.i = i;
            
        }
        public void run() {
            try {
                File file = new File(Environment.getExternalStorageDirectory().getPath() +"/" +i + ".properties");
                //获取断点
                if(!file.exists()||file.length()<=0){
                     breakpoint = startindex;
                        if(i==0){
                            pb_01.setProgress(0);
                        }else if(i==1){
                            pb_02.setProgress(0);
                        }else if(i==2){
                            pb_03.setProgress(0);
                        }
                }else{
                BufferedReader br = new BufferedReader(new FileReader(file));
                breakpoint = Integer.parseInt(br.readLine());
                pbset();
                }
                System.out.println("Thread" + i + "开启了,它下载的范围是" + breakpoint + ">>" +endindex );
                
                RandomAccessFile raf = new RandomAccessFile(Environment.getExternalStorageDirectory().getPath() +"/" +filename, "rwd");
                raf.seek(breakpoint);
                String path = "http://192.168.16.80:8080/aaa.txt";
                //1,访问网络
                URL url = new URL(path);
                //2,获取链接
                HttpURLConnection conn = (HttpURLConnection) url.openConnection();
                //3,设置请求头信息
                conn.setRequestProperty("Range", "bytes=" + breakpoint + "-" + endindex);
                //4,获取已经被创建的等大小文件,开始写信息
                //5,获取输入流输出流
                InputStream is =conn.getInputStream();
                //6,流对接
                byte[] arr = new byte[2];
                int len = 0;
                while((len = is .read(arr))!=-1){
                    Thread.sleep(500);
                    raf.write(arr,0,len);
                    breakpoint+=len;
                    //把断点信息写到文件中去
                    RandomAccessFile bp = new RandomAccessFile(Environment.getExternalStorageDirectory().getPath() +"/" + i + ".properties", "rwd");
                    System.out.println(i + "线程的断点是" + breakpoint);
                    bp.write((breakpoint + "").getBytes());
                    bp.close();
                    pbset();
                }
                System.out.println(i + "线程执行完了");
                synchronized (MainActivity.class) {
                    deleteindex--;
                    System.out.println(deleteindex);
                    if(deleteindex==0){
                        System.out.println(deleteindex);
                        for(int i=0;i<3;i++){
                        File filei = new File(Environment.getExternalStorageDirectory().getPath() +"/" +i + ".properties");
                        filei.delete();
                        }
                    }
                    System.out.println("下完完毕");
                }
                //写完之后关流
                is.close();
                raf.close();
            } catch (Exception e) {
                System.out.println("子线程异常");
            }
            super.run();
        }
        /**
         * 设置进度
         */
        public void pbset() {
            if(i==0){
                pb_01.setProgress((int)breakpoint);
            }else if(i==1){
                pb_02.setProgress((int)breakpoint);
            }else if(i==2){
                pb_03.setProgress((int)breakpoint);
            }
        }
    }
    
}