package cn.me.test;

import java.io.InputStream;

import java.io.RandomAccessFile;

import java.net.HttpURLConnection;

import java.net.URL;

/**

 * 多線程下載

 * 1：使用RandomAccessFile在任意的位置寫入數(shù)據(jù)。

 * 2：需要計算第一個線程下載的數(shù)據(jù)量，可以平均分配。如果不夠平均時，

 *    則直接最后一個線程處理相對較少的數(shù)據(jù)

 * 3：必須要在下載之前準(zhǔn)備好相同大小的文件，通過文件頭獲取

 */

public class MultiThreadDownload {

    public static void main(String[] args) throws Exception {

       //1：聲明文件名和下載的地址

       String fileName = "aa.rar";

       String urlStr = "http://localhost:7777/day18";

       //2：聲明Url

       URL url = new URL(urlStr+"/"+fileName);

       //3：獲取連接

       HttpURLConnection con =

           (HttpURLConnection) url.openConnection();

       //4:設(shè)置請求方式

       con.setRequestMethod("GET");

       //5:獲取請求頭,即文件的長度

       int length = con.getContentLength();//獲取下載文件的長度，以計算每個線程應(yīng)該下載的數(shù)據(jù)量。

       //6：在指定的目錄下，創(chuàng)建一個同等大小的文件

       RandomAccessFile file = new RandomAccessFile("d:/a/"+fileName, "rw");//創(chuàng)建一個相同大小的文件。

       //7:設(shè)置文件大小，占位

       file.setLength(length);//設(shè)置文件大小。

       file.close();

       //8：定義線程個數(shù)

       int size = 3;

       //9:計算每一個線程應(yīng)該下載多少字節(jié)的數(shù)據(jù)，如果正好整除則最好，否則加1

       int block = length/size==0?length/size:length/size+1;//計算每個線程應(yīng)該下載的數(shù)據(jù)量。

       System.err.println("每個線程應(yīng)該下載："+block);

       //10：運行三個線程并計算從哪個字節(jié)開始到哪一個字節(jié)結(jié)束

       for(int i=0;i<size;i++){

           int start = i*block;

           int end = start+(block-1);//計算每一個線程的開始和結(jié)束字節(jié)。

         System.err.println(i+"="+start+","+end);

           new MyDownThread(fileName, start, end,url).start();

       }

    }

    static class MyDownThread extends Thread{

       //定義文件名

       private String fileName;

       //定義從何地開始下載

       private int start;

       //定義下載到哪一個字節(jié)

       private int end;

       private URL url;

       public MyDownThread(String fileName,int start,int end,URL url){

           this.fileName=fileName;

           this.start=start;

           this.end=end;

           this.url=url;

       }

       @Override

       public void run() {

           try{

              //11:開始下載

              HttpURLConnection con =

                     (HttpURLConnection) url.openConnection();

              con.setRequestMethod("GET");

              //12：設(shè)置分段下載的請求頭

              con.setRequestProperty("Range","bytes="+start+"-"+end);//設(shè)置從服務(wù)器上讀取的文件塊。

              //13:開始下載，需要判斷206

              if(con.getResponseCode()==206){//訪問成功，則返回的狀態(tài)碼為206。

                  InputStream in = con.getInputStream();

                  //14:聲明隨機寫文件對象，注意rwd是指即時將數(shù)據(jù)寫到文件中，而不使用緩存區(qū)

                  RandomAccessFile out = new RandomAccessFile("d:/a/"+fileName,"rwd");

                  out.seek(start);//設(shè)置從文件的某個位置開始寫數(shù)據(jù)。

                  byte[] b=new byte[1024];

                  int len = 0;

                  while((len=in.read(b))!=-1){

                     out.write(b,0,len);

                  }

                  out.close();

                  in.close();

              }

              System.err.println(this.getName()+"執(zhí)行完成");

           }catch(Exception e){

              throw new RuntimeException(e);

           }

       }

    }

}