zoukankan      html  css  js  c++  java
  • 多线程短点叙传

    package com.itheima.multithreaddownload;
     
    import java.io.BufferedReader;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.io.RandomAccessFile;
    import java.net.HttpURLConnection;
    import java.net.URL;
     
    import android.os.Bundle;
    import android.os.Environment;
    import android.os.Handler;
    import android.app.Activity;
    import android.view.View;
    import android.widget.ProgressBar;
    import android.widget.TextView;
     
    public class MainActivity extends Activity {
     
    String path = "http://169.254.244.136:8080/QQPlayer.exe";
    int threadCount = 3;
    int finishedThread = 0;
    //所有线程下载总进度
    int downloadProgress = 0;
    private ProgressBar pb;
    private TextView tv;
     
    Handler handler = new Handler(){
    public void handleMessage(android.os.Message msg) {
    tv.setText((long)pb.getProgress() * 100 / pb.getMax() + "%");
    }
    };
    @Override
    protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);
     
    pb = (ProgressBar) findViewById(R.id.pb);
    tv = (TextView) findViewById(R.id.tv);
    }
     
     
    public void click(View v){
    Thread t = new Thread(){
    @Override
    public void run() {
    //发送http请求,拿到目标文件长度
    try {
    URL url = new URL(path);
    HttpURLConnection conn = (HttpURLConnection) url.openConnection();
    conn.setRequestMethod("GET");
    conn.setConnectTimeout(8000);
    conn.setReadTimeout(8000);
     
    if(conn.getResponseCode() == 200){
    //获取长度
    int length = conn.getContentLength();
     
    //创建临时文件
    File file = new File(Environment.getExternalStorageDirectory(), getNameFromPath(path));
    RandomAccessFile raf = new RandomAccessFile(file, "rwd");
    //设置临时文件大小与目标文件一致
    raf.setLength(length);
    raf.close();
     
    //设置进度条的最大值
    pb.setMax(length);
     
    //计算每个线程下载区间
    int size = length / threadCount;
     
    for (int id = 0; id < threadCount; id++) {
    //计算每个线程下载的开始位置和结束位置
    int startIndex = id * size;
    int endIndex = (id + 1) * size - 1;
    if(id == threadCount - 1){
    endIndex = length - 1;
    }
    System.out.println("线程" + id + "下载的区间:" + startIndex + " ~ " + endIndex);
    new DownLoadThread(id, startIndex, endIndex).start();
    }
     
    }
    } catch (Exception e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
    }
     
    }
    };
    t.start();
    }
     
    public String getNameFromPath(String path){
    int index = path.lastIndexOf("/");
    return path.substring(index + 1);
    }
     
    class DownLoadThread extends Thread{
     
    int threadId;
    int startIndex;
    int endIndex;
     
     
    public DownLoadThread(int threadId, int startIndex, int endIndex) {
    super();
    this.threadId = threadId;
    this.startIndex = startIndex;
    this.endIndex = endIndex;
    }
     
     
    @Override
    public void run() {
    try {
    File fileProgress = new File(Environment.getExternalStorageDirectory(), threadId + ".txt");
    int lastProgress = 0;
    if(fileProgress.exists()){
    //读取进度临时文件中的内容
    FileInputStream fis = new FileInputStream(fileProgress);
    BufferedReader br = new BufferedReader(new InputStreamReader(fis));
    //得到上一次下载进度
    lastProgress = Integer.parseInt(br.readLine());
    //改变下载的开始位置,上一次下过的,这次就不请求了
    startIndex += lastProgress;
    fis.close();
     
    //把上一次下载进度加到进度条进度中
    downloadProgress += lastProgress;
    pb.setProgress(downloadProgress);
     
    //发送消息,让文本进度条改变
    handler.sendEmptyMessage(1);
    }
     
    //发送http请求,请求要下载的数据
    URL url = new URL(path);
    HttpURLConnection conn = (HttpURLConnection) url.openConnection();
    conn.setRequestMethod("GET");
    conn.setConnectTimeout(8000);
    conn.setReadTimeout(8000);
    //设置请求数据的区间
    conn.setRequestProperty("Range", "bytes=" + startIndex + "-" + endIndex);
     
    //请求部分数据,成功的响应码是206
    if(conn.getResponseCode() == 206){
    InputStream is = conn.getInputStream();
     
    byte[] b = new byte[1024];
    int len = 0;
    //当前线程下载的总进度
    int total = lastProgress;
    File file = new File(Environment.getExternalStorageDirectory(), getNameFromPath(path));
    RandomAccessFile raf = new RandomAccessFile(file, "rwd");
    //设置写入的开始位置
    raf.seek(startIndex);
    while((len = is.read(b)) != -1){
    raf.write(b, 0, len);
    total += len;
    System.out.println("线程" + threadId + "下载了:" + total);
     
     
    //创建一个进度临时文件,保存下载进度
    RandomAccessFile rafProgress = new RandomAccessFile(fileProgress, "rwd");
    //每次下载1024个字节,就,就马上把1024写入进度临时文件
    rafProgress.write((total + "").getBytes());
    rafProgress.close();
     
    //每次下载len个长度的字节,马上把len加到下载进度中,让进度条能反应这len个长度的下载进度
    downloadProgress += len;
    pb.setProgress(downloadProgress);
     
    //发送消息,让文本进度条改变
    handler.sendEmptyMessage(1);
     
    }
    raf.close();
    System.out.println("线程" + threadId + "下载完毕------------------");
     
    //3条线程全部下载完毕,才去删除进度临时文件
    finishedThread++;
     
    synchronized (path) {
    if(finishedThread == threadCount){
    for (int i = 0; i < threadCount; i++) {
    File f = new File(Environment.getExternalStorageDirectory(), i + ".txt");
    f.delete();
    }
    finishedThread = 0;
    }
    }
    }
     
    }
    catch (Exception e) {
    e.printStackTrace();
    }
    }
    }
    }
     
     
     
    #多线程断点续传下载
    ### 多线程:快
    * 原理:抢占服务器资源
    * 单线程下载:线程从第0个字节开始下,下到最后一个字节,在本地硬盘的临时文件中从第0个字节开始写,写到最后一个字节,下载完成时,临时文件也写完了,本地就创建了一个与服务器文件一模一样的文件
    * 多线程下载:每条线程下载的开始位置和结束位置都是不一样的,每条线程下载的数据合在一起才是服务器的完整的文件
    ###断点续传:
    * 下载从上一次下载结束的位置开始
    * 原理:每次下载把下载进度保存至一个文本临时文件中,下一次下载时从文本临时文件获取上一次下载的进度,从这个进度开始继续下载
    ###进度条
    * 计算下载百分比进度时要在long类型下计算
     
     
    ---
    #多线程下载(掌握)
    >原理:服务器CPU分配给每条线程的时间片相同,服务器带宽平均分配给每条线程,所以客户端开启的线程越多,就能抢占到更多的服务器资源
     
    ###确定每条线程下载多少数据(掌握)
    * 发送http请求至下载地址
     
    String path = "http://192.168.1.102:8080/editplus.exe";
    URL url = new URL(path);
    HttpURLConnection conn = (HttpURLConnection) url.openConnection();
    conn.setReadTimeout(5000);
    conn.setConnectTimeout(5000);
    conn.setRequestMethod("GET");
    * 获取文件总长度,然后创建长度一致的临时文件
     
    if(conn.getResponseCode() == 200){
    //获得服务器流中数据的长度
    int length = conn.getContentLength();
    //创建一个临时文件存储下载的数据
    RandomAccessFile raf = new RandomAccessFile(getFileName(path), "rwd");
    //设置临时文件的大小
    raf.setLength(length);
    raf.close();
    * 确定线程下载多少数据
     
    //计算每个线程下载多少数据
    int blockSize = length / THREAD_COUNT;
    ###计算每条线程下载数据的开始位置和结束位置(掌握)
     
    for(int id = 1; id <= 3; id++){
    //计算每个线程下载数据的开始位置和结束位置
    int startIndex = (id - 1) * blockSize;
    int endIndex = id * blockSize - 1;
    if(id == THREAD_COUNT){
    endIndex = length;
    }
     
    //开启线程,按照计算出来的开始结束位置开始下载数据
    new DownLoadThread(startIndex, endIndex, id).start();
    }
    ###再次发送请求至下载地址,请求开始位置至结束位置的数据(掌握)
     
    String path = "http://192.168.1.102:8080/editplus.exe";
     
    URL url = new URL(path);
    HttpURLConnection conn = (HttpURLConnection) url.openConnection();
    conn.setReadTimeout(5000);
    conn.setConnectTimeout(5000);
    conn.setRequestMethod("GET");
     
    //向服务器请求部分数据
    conn.setRequestProperty("Range", "bytes=" + startIndex + "-" + endIndex);
    conn.connect();
    * 下载请求到的数据,存放至临时文件中
     
    if(conn.getResponseCode() == 206){
    InputStream is = conn.getInputStream();
    RandomAccessFile raf = new RandomAccessFile(getFileName(path), "rwd");
    //指定从哪个位置开始存放数据
    raf.seek(startIndex);
    byte[] b = new byte[1024];
    int len;
    while((len = is.read(b)) != -1){
    raf.write(b, 0, len);
    }
    raf.close();
    }
     
    ---
    #带断点续传的多线程下载(掌握)
    * 定义一个int变量记录每条线程下载的数据总长度,然后加上该线程的下载开始位置,得到的结果就是下次下载时,该线程的开始位置,把得到的结果存入缓存文件
     
    //用来记录当前线程总的下载长度
    int total = 0;
    while((len = is.read(b)) != -1){
    raf.write(b, 0, len);
    total += len;
    //每次下载都把新的下载位置写入缓存文本文件
    RandomAccessFile raf2 = new RandomAccessFile(threadId + ".txt", "rwd");
    raf2.write((startIndex + total + "").getBytes());
    raf2.close();
    }
    * 下次下载开始时,先读取缓存文件中的值,得到的值就是该线程新的开始位置
     
    FileInputStream fis = new FileInputStream(file);
    BufferedReader br = new BufferedReader(new InputStreamReader(fis));
    String text = br.readLine();
    int newStartIndex = Integer.parseInt(text);
    //把读到的值作为新的开始位置
    startIndex = newStartIndex;
    fis.close();
    * 三条线程都下载完毕之后,删除缓存文件
     
    RUNNING_THREAD--;
    if(RUNNING_THREAD == 0){
    for(int i = 0; i <= 3; i++){
    File f = new File(i + ".txt");
    f.delete();
    }
    }
     
    ---
    #手机版的断点续传多线程下载器
    * 把刚才的代码直接粘贴过来就能用,记得在访问文件时的路径要改成Android的目录,添加访问网络和外部存储的路径
    ###用进度条显示下载进度(掌握)
    * 拿到下载文件总长度时,设置进度条的最大值
     
    //设置进度条的最大值
    pb.setMax(length);
    * 进度条需要显示三条线程的整体下载进度,所以三条线程每下载一次,就要把新下载的长度加入进度条
    * 定义一个int全局变量,记录三条线程的总下载长度
     
    int progress;
    * 刷新进度条
     
    while((len = is.read(b)) != -1){
    raf.write(b, 0, len);
     
     
    //把当前线程本次下载的长度加到进度条里
    progress += len;
    pb.setProgress(progress);
    * 每次断点下载时,从新的开始位置开始下载,进度条也要从新的位置开始显示,在读取缓存文件获取新的下载开始位置时,也要处理进度条进度
     
    FileInputStream fis = new FileInputStream(file);
    BufferedReader br = new BufferedReader(new InputStreamReader(fis));
    String text = br.readLine();
    int newStartIndex = Integer.parseInt(text);
     
    //新开始位置减去原本的开始位置,得到已经下载的数据长度
    int alreadyDownload = newStartIndex - startIndex;
    //把已经下载的长度设置入进度条
    progress += alreadyDownload;
    ###添加文本框显示百分比进度(熟悉)
     
    tv.setText(progress * 100 / pb.getMax() + "%");
     
    ---
    #HttpUtils的使用(熟悉)
    >HttpUtils本身就支持多线程断点续传,使用起来非常的方便
     
    * 创建HttpUtils对象
     
    HttpUtils http = new HttpUtils();
    * 下载文件
     
    http.download(url, //下载请求的网址
    target, //下载的数据保存路径和文件名
    true, //是否开启断点续传
    true, //如果服务器响应头中包含了文件名,那么下载完毕后自动重命名
    new RequestCallBack<File>() {//侦听下载状态
     
    //下载成功此方法调用
    @Override
    public void onSuccess(ResponseInfo<File> arg0) {
    tv.setText("下载成功" + arg0.result.getPath());
    }
     
    //下载失败此方法调用,比如文件已经下载、没有网络权限、文件访问不到,方法传入一个字符串参数告知失败原因
    @Override
    public void onFailure(HttpException arg0, String arg1) {
    tv.setText("下载失败" + arg1);
    }
     
    //在下载过程中不断的调用,用于刷新进度条
    @Override
    public void onLoading(long total, long current, boolean isUploading) {
    super.onLoading(total, current, isUploading);
    //设置进度条总长度
    pb.setMax((int) total);
    //设置进度条当前进度
    pb.setProgress((int) current);
    tv_progress.setText(current * 100 / total + "%");
    }
    });
     
  • 相关阅读:
    python 数据结构--Set(集合)
    python 数据结构--Dictionary(字典)
    idea使用心得
    SpringBoot(一):构建第一个SpringBoot工程
    springboot服务的一些问题
    maven使用问题总结

    多线程学习三:Thread API,ThreadLocal,synchronized,volatile和Condition
    多线程学习二:线程池 ExecutorService
    多线程学习一:创建多线程的方式
  • 原文地址:https://www.cnblogs.com/SoulCode/p/6393404.html
Copyright © 2011-2022 走看看