java多線程下載實例詳解

java多線程下載實例詳解。本站提示廣大學習愛好者：（java多線程下載實例詳解）文章只能為提供參考，不一定能成為您想要的結果。以下是java多線程下載實例詳解正文

本文實例講述了java多線程下載。分享給年夜家供年夜家參考，詳細以下：

應用多線程下載文件可以更快完成文件的下載，多線程下載文件之所以快，是由於其搶占的辦事器資本多。如：假定辦事器同時最多辦事100個用戶，在辦事器中一條線程對應一個用戶，100條線程在盤算機中並不是並發履行，而是由CPU劃分時光片輪番履行，假如A運用應用了99條線程下載文件，那末相當於占用了99個用戶的資本，假定一秒內CPU分派給每條線程的均勻履行時光是10ms，A運用在辦事器中一秒內就獲得了990ms的履行時光，而其他運用在一秒內只要10ms的履行時光。就好像一個水龍頭，每秒出水量相等的情形下，放990毫秒的水確定比放10毫秒的水要多。

多線程下載的完成進程：

1.起首獲得下載文件的長度，然後設置當地文件的長度。

HttpURLConnection.getContentLength();
RandomAccessFile file = new RandomAccessFile("youdao.exe","rw");
file.setLength(filesize);//設置當地文件的長度

2.依據文件長度和線程數盤算每條線程下載的數據長度和下載地位。如：文件的長度為6M，線程數為3，那末，每條線程下載的數據長度為2M，每條線程開端下載的地位以下圖所示。

3.應用Http的Range頭字段指定每條線程從文件的甚麼地位開端下載，如：指定從文件的2M地位開端下載文件，代碼以下：
HttpURLConnection.setRequestProperty("Range", "bytes=2097152-");
4.保留文件，應用RandomAccessFile類指定每條線程從當地文件的甚麼地位開端寫入數據

RandomAccessFile threadfile = new RandomAccessFile("<span >youdao.exe</span><span > ","rw");</span>
threadfile.seek(2097152);//從文件的甚麼地位開端寫入數據

上面是經由過程詳細完成類：

在寫完成類之前我們起首要將要下載的文件放在辦事器上並安排：

我是放在了這裡 D:\Tomcat\apache-tomcat-7.0.37\webapps\doudou目次下，並啟動D:\Tomcat\apache-tomcat-7.0.37\bin下的startup.bat

1.DownLoadTest.java

package www.csdn.net.down;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
public class DownLoadTest {
 public File file;
 public RandomAccessFile accessFile;
 // 線程的數目
 public static int threadNum = 3;
 // 每一個線程擔任下載的年夜小
 int blockSize;
 // 創立拜訪的途徑
 public String path = "http://localhost:8080/doudou/youdao.exe";
 public static int threadCount;// 數目
 public void testDown() {
  try {
   // 創立出URL對象
   URL url = new URL(path);
   // 創立出 HttpURLConnection對象
   HttpURLConnection httpURLConnection = (HttpURLConnection) url
     .openConnection();
   // 設置 發要求發送的方法
   httpURLConnection.setRequestMethod("GET");
   // 設置要求能否超不時間
   httpURLConnection.setConnectTimeout(5000);
   // 設置
   httpURLConnection
     .setRequestProperty("User-Agent",
       " Mozilla/5.0 (compatible; MSIE 10.0; Windows NT 6.2; Trident/6.0)");
   // 能否呼應勝利
   if (httpURLConnection.getResponseCode() == 200) {
    // 獲得文件的年夜小
    int size = httpURLConnection.getContentLength();
    System.out.println("文件的年夜小" + size);
    // 創立文件
    file = new File("youdao.exe");
    accessFile = new RandomAccessFile(file, "rwd");
    // 設置文件的年夜小
    accessFile.setLength(size);
    // 每一個線程下載的年夜小
    blockSize = size / threadNum;
    // 開三個線程 操作此文件
    for (int i = 1; i <= threadNum; i++) {
     // 1 2 3
     // 盤算出每一個線程開端的地位
     int startSize = (i - 1) * blockSize;
     // 停止地位
     int endSize = (i) * blockSize;
     // 當線程是最初一個線程的時刻
     if (i == threadNum) {
      // 斷定文件的年夜小能否年夜於盤算出來的停止地位
      if (size > endSize) {
       // 停止地位 等於 文件的年夜小
       endSize = size;
      }
     }
     // 為每一個線程創立一個隨機的讀取
     RandomAccessFile threadAccessFile = new RandomAccessFile(
       file, "rwd");
     new Thread(new DownLoadThread(i, threadAccessFile,
       startSize, endSize, path)).start();
    }
   }
  } catch (MalformedURLException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  } catch (IOException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
 }
 public static void main(String[] args) {
  DownLoadTest downLoadTest = new DownLoadTest();
  // 挪用下載辦法
  downLoadTest.testDown();
 }
}
class DownLoadThread implements Runnable {
 // 下載文件的封裝
 public RandomAccessFile accessFile; // 每一個線程 都具有一個accessFile的文件對象 線程1 線程2 線程3
 // 線程下載文件的肇端地位
 public int startSize;
 public int endSize;
 // 文件下載的path途徑
 public String path;
 public int threadId; // 線程的標識
 public DownLoadThread(int threadId, RandomAccessFile accessFile,
   int startSize, int endSize, String path) {
  this.threadId = threadId;
  this.accessFile = accessFile;
  this.startSize = startSize;
  this.endSize = endSize;
  this.path = path;
 }
 @Override
 public void run() {
  // 履行run辦法
  try {
   // 創立文件
   File threadFile = new File(threadId + ".txt");
   if (threadFile.exists()) {
    // 讀取該文件的內容
    // 創立文件的輸出流對象
    FileInputStream fis = new FileInputStream(threadFile);
    // 采取對象類讀取
    byte data[] = StreamTools.isToData(fis);
    // 轉化成字符串
    String threadLen = new String(data);
    if ((threadLen != null) && (!"".equals(threadLen))) {
     startSize = Integer.valueOf(threadLen);
     // 處理 416bug的毛病
     if (startSize > endSize) {
      startSize = endSize - 1;
     }
    }
   }
   // 創立URL對象
   URL url = new URL(path);
   // 創立HttpURLConnection對象
   HttpURLConnection httpURLConnection = (HttpURLConnection) url
     .openConnection();
   // 設置要求的頭
   httpURLConnection.setRequestMethod("GET");
   // 設置要求能否超不時間
   httpURLConnection.setConnectTimeout(5000);
   // 設置
   httpURLConnection
     .setRequestProperty("User-Agent",
       " Mozilla/5.0 (compatible; MSIE 10.0; Windows NT 6.2; Trident/6.0)");
   // 症結的設置
   httpURLConnection.setRequestProperty("Range", "bytes=" + startSize
     + "-" + endSize);
   // 輸入以後線程
   System.out.println("以後線程" + threadId + " 下載開端地位:" + startSize
     + " 下載停止地位:" + endSize);
   // 呼應勝利
   // 設置隨機讀取文件的 開端地位
   accessFile.seek(startSize);
   // 獲得響應流對象
   InputStream is = httpURLConnection.getInputStream();
   // 創立輸入流對象
   byte buffer[] = new byte[1024];
   int len = 0;
   int threadTotal = 0;// 每一個線程下載後保留記載 /
   while ((len = is.read(buffer)) != -1) {
    accessFile.write(buffer, 0, len);
    threadTotal += len;// 記載你寫入的長度 //xml文件
    // 經由過程文件記載文件下載的長度
    FileOutputStream fos = new FileOutputStream(threadFile);
    fos.write((threadTotal + "").getBytes());
    fos.flush();
    fos.close();
   }
   accessFile.close();
   is.close();
   System.out.println(threadId + "線程履行終了");
   //線程操作
   synchronized (DownLoadTest.class) {
    DownLoadTest.threadCount++;
    if (DownLoadTest.threadCount >= DownLoadTest.threadNum) {
     for(int i=1;i<=DownLoadTest.threadNum;i++){
      File file = new File(i+".txt");
      if(file.exists()){
       file.delete();
      }
     }
    }
   }
  } catch (MalformedURLException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  } catch (IOException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
 }
}

2.流對象的封裝 StreamTools.java

package www.csdn.net.down;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
public class StreamTools {
 public static byte[] isToData(InputStream is) throws IOException{
  // 字節輸入流
  ByteArrayOutputStream bops = new ByteArrayOutputStream();
  // 讀取數據的緩存區
  byte buffer[] = new byte[1024];
  // 讀取長度的記載
  int len = 0;
  // 輪回讀取
  while ((len = is.read(buffer)) != -1) {
   bops.write(buffer, 0, len);
  }
  // 把讀取的內容轉換成byte數組
  byte data[] = bops.toByteArray();
  bops.flush();
  bops.close();
  is.close();
  return data;
 }
}

願望本文所述對年夜家Java法式設計有所贊助。