java多线程下载和断点续传

本文主要是介绍java多线程下载和断点续传，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

java多线程下载和断点续传，示例代码只实现了多线程，断点只做了介绍。但是实际测试结果不是很理想，不知道是哪里出了问题。所以贴上来请高手修正。

标签：断点续传多线程下载

代码片段(1)[全屏查看所有代码]

1. [代码][Java]代码

 ? 
 import  java.io.File; 
 import  java.io.IOException; 
 import  java.io.RandomAccessFile; 
 import  java.net.HttpURLConnection; 
 import  java.net.URL; 
 public  class  DownloadFile { 
      /** 
       * @param args 
       */ 
      static  int  len; //线程平均下载文件长度 
      static  int  bn ; //每个线程写入文件的字节数 
      static  int  tn;  //线程数 
      static  String urlt; //下载地址 
      static  String fileName; 
      static  RandomAccessFile osf;  //文件操作 
      public  static  void  main(String[] args) { 
          // TODO Auto-generated method stub 
           
          try  { 
              urlt =  "http://im.baidu.com/download/BaiduHi_4.2_Beta.exe" ; 
              fileName =  "C:\\"  + urlt.split( "//" )[ 1 ].split( "/" )[urlt.split( "//" )[ 1 ].split( "/" ).length- 1 ]; 
              System.out.println(fileName); 
              URL url =  new  URL(urlt); 
              HttpURLConnection http = (HttpURLConnection) url.openConnection(); 
              /** 
               * 此处设定5个线程下载一个文件tn = 5; 
               * 判断平均每个线程需下载文件长度： 
               */ 
              System.out.println( "file size:"  + http.getContentLength()); 
              tn =  3 ;          
              len = http.getContentLength() / tn ; //舍去余数（余数自动舍去）计算每个线程应下载平均长度，最后一个线程再加上余数，则是整个文件的长度, 
              File f =  new  File(fileName); 
              if  (f.exists()){ 
                  f.delete(); 
                  osf =  new  RandomAccessFile(f,  "rw" ); 
                  osf.seek(http.getContentLength()- 1 ); 
                  osf.write( 0 ); 
              } else { 
                  osf =  new  RandomAccessFile(f,  "rw" ); 
                  osf.seek(http.getContentLength()- 1 ); 
                  osf.write( 0 ); 
              } 
              System.out.println( "temp 文件长度："  + f.length()); 
              Thread t; //下载子线程， 
              for  ( int  j =  0 ; j < tn; j++) { 
                  if (j == tn -  1 ){ //如果最后一个线程则加上余数长度字节 
                      bn = len + (http.getContentLength() % tn); 
                  } else { 
                      bn = len; 
                  } 
                  System.out.println( "t" + j +  "线程下载长度："  + bn +  "起始字节："  + len*j); 
                  t =  new  DT( 
                          j, 
                          urlt, 
                          fileName, 
                          len*j, 
                          bn 
                           
                  ); 
                  t.start(); 
              } 
          }  catch  (IOException e) { 
              // TODO Auto-generated catch block 
              e.printStackTrace(); 
          } 
      } 
 } 
 import  java.io.File; 
 import  java.io.FileNotFoundException; 
 import  java.io.IOException; 
 import  java.io.InputStream; 
 import  java.io.RandomAccessFile; 
 import  java.net.HttpURLConnection; 
 import  java.net.MalformedURLException; 
 import  java.net.URL; 
 import  java.util.Date; 
 public  class  DT  extends  Thread { 
      String urlt; 
      int  startl; 
      int  end; 
      String fileName; 
      RandomAccessFile osf; 
      public  DT( int  i ,String url,String fileName, int  start, int  end){ 
          this .setName( "t" +i);  //子线程名称 
          this .urlt = url;  //下载地址 
          this .fileName = fileName; 
          this .startl = start;  //子线程读取/写入起始字节 
          this .end = end; //子线程写入结束字节长度 
      } 
      public  void  run(){ 
              try  { 
                  osf =  new  RandomAccessFile(fileName,  "rw" ); 
                  URL url =  new  URL(urlt); 
                  HttpURLConnection http2 = (HttpURLConnection) url.openConnection(); 
                  http2.setRequestProperty( "User-Agent" , "NetFox" );  
               
                  /* 
                   * 断点续传和多线程下载的关键代码关键位置：即设置断点 
                   * http2.setRequestProperty("RANGE", "bytes="+startl+"-");//设置断点位置，向服务器请求从文件的哪个字节开始读取。 
                   * osf.seek(startl);//设置本地文件从哪个字节开始写入 
                   * 如果是单线程，则首先要判断下载文件是否已经存在 及DownloadFile.java 里的 fileName = "C:\\eclipse.zip"; 
                   * 如果存在则开始断点续传，方法同多线程： 
                   * 因为断点续传是从上次传输中断的字节开始，则首先要得到上次中断的位置，既是文件长度（针对单线程）f.length() 
                   * 然后设置HTTP请求头属性RANGE，该属性告知服务器从哪个自己开始读取文件。 
                   * 设置本地文件写入起始字节，及接从上次传输断点继续写入（断点续传） 
                   * osf.seek(offset) 该方法设定从offset后一个字节开始写入文件 
                   * 注意：多线程不能用文件长度做为写文件起始字节，需有配置文件记录上次读写的位置，迅雷下载既是使用该种方法。 
                   * 
                   */ 
                  http2.setRequestProperty( "RANGE" ,  "bytes=" +startl+ "-" ); //设置断点位置，向服务器请求从文件的哪个字节开始读取。 
                  osf.seek(startl); //设置本地文件从哪个字节开始写入 
                   
                  InputStream input = http2.getInputStream(); 
                  byte  b[] =  new  byte [ 1024 ]; //设置缓冲池，每次只读1024字节 
                  Date d =  new  Date(); //子线程开始下载时间 
                  int  l; //计算子线程读取和写入的文件长度，当长度大于每个子线程平均下载长度则终止线程 
                  int  i; 
                  l =  0 ; 
                  System.out.println( this .getName() +  " 开始下载。。。" ); 
                  while  ( (i = input.read(b, 0 , 1024 )) != - 1  && l < end){     //线程下载字节长度控制误差小于缓冲池大小，本示例为缓冲池1024字节 
                      osf.write(b,  0 , i); 
                      b =  new  byte [ 1024 ]; //重新赋值，避免重新读入旧内容 
                      l += i;          
                  } 
                  Date d2 =  new  Date(); //子线程结束下载时间 
                  System.out.println( this .getName() +  " 线程耗时： "  + (d2.getTime() - d.getTime())/ 1000  +  " 秒,实际共下载："  + l +  "字节" ); //子线程下载耗时（秒） 
              }  catch  (FileNotFoundException e1) { 
                  // TODO Auto-generated catch block 
                  e1.printStackTrace(); 
              }  catch  (MalformedURLException e) { 
                  // TODO Auto-generated catch block 
                  e.printStackTrace(); 
              }  catch  (IOException e) { 
                  // TODO Auto-generated catch block 
                  e.printStackTrace(); 
              } 
               
               
           
      } 
       
 } 