歡迎來到Linux教程網
設為首頁 加入收藏
Linux教程網
Linux教程網
Linux教程網
您现在的位置： Linux教程網 >> UnixLinux >  >> Linux編程 >> Linux編程

Java多線程下載源碼

Java多線程下載源碼，僅作參考之用
  1. import java.io.File;  
  2. import java.io.FileNotFoundException;  
  3. import java.io.IOException;  
  4. import java.io.InputStream;  
  5. import java.io.RandomAccessFile;  
  6. import java.net.HttpURLConnection;  
  7. import java.net.URL;  
  8.   
  9. public class MyThreadDownloader  
  10. {  
  11.     public static void main(String args[])  
  12.     {  
  13.         // 下載連接   
  14.         String downloadURL = "http://localhost:8080/cangjingkong.avi";  
  15.         // 下載開啟線程數   
  16.         int threadSize = 3;  
  17.         try  
  18.         {  
  19.             new MyThreadDownloader().download(downloadURL, threadSize);  
  20.         }  
  21.         catch (Exception e)  
  22.         {  
  23.             e.printStackTrace();  
  24.         }  
  25.     }  
  26.   
  27.     private void download(String downloadURL, int threadSize) throws Exception  
  28.     {  
  29.         String fileName = getFileName(downloadURL);  
  30.   
  31.         URL url = new URL(downloadURL);  
  32.   
  33.         HttpURLConnection connection = (HttpURLConnection) url.openConnection();  
  34.         // 設置超時   
  35.         connection.setConnectTimeout(5000);  
  36.         // 設置請求方式   
  37.         connection.setRequestMethod("GET");  
  38.         // 獲取文件長度   
  39.         int fileLength = connection.getContentLength();  
  40.         // 保存文件   
  41.         File localFile = new File(fileName);  
  42.         // 臨時文件不存內存,直接進行數據讀寫"rwd"   
  43.         RandomAccessFile randomAccessFile = new RandomAccessFile(localFile,"rwd");  
  44.         // 直接創建與服務器獲取長度相等的文件   
  45.         randomAccessFile.setLength(fileLength);  
  46.         // 文件操作over,關閉   
  47.         randomAccessFile.close();  
  48.   
  49.         // 計算每條線程負責下載的數據量   
  50.         int downblock = fileLength % threadSize == 0 ? fileLength / threadSize  
  51.                 : fileLength / threadSize + 1;  
  52.         // 分配每條線程下載任務   
  53.         for (int threadID = 0; threadID < threadSize; threadID++)  
  54.         {  
  55.             //開啟多線程下載任務   
  56.             new DownloadThread(threadID, url, localFile, downblock).start();  
  57.         }  
  58.     }  
  59.   
  60.   
  61.     /** 
  62.      * @param downloadURL 
  63.      *            下載連接 
  64.      * @return 返回下載文件名 
  65.      */  
  66.     private String getFileName(String downloadURL)  
  67.     {  
  68.         return downloadURL.substring(downloadURL.lastIndexOf("/") + 1);  
  69.     }  
  70.   
  71.     public final class DownloadThread extends Thread  
  72.     {  
  73.         private int threadID;      // 當前下載線程ID   
  74.         private URL url;           // 下載連接   
  75.         private File localFile;    // 目標文件   
  76.         private int downblock;     // 分段下載長度   
  77.         private int startPosition; // 開始下載位置   
  78.         private int endPosition;   // 結束下載位置   
  79.   
  80.         public DownloadThread(int threadID, URL url, File localFile,  
  81.                 int downblock)  
  82.         {  
  83.             this.threadID = threadID;  
  84.             this.url = url;  
  85.             this.localFile = localFile;  
  86.             this.downblock = downblock;  
  87.         }  
  88.   
  89.         public void run()  
  90.         {  
  91.             startPosition = threadID * downblock;  
  92.             endPosition = (threadID + 1) * downblock;  
  93.             try  
  94.             {  
  95.                 RandomAccessFile randomAccessFile = new RandomAccessFile(localFile,"rwd");  
  96.                 randomAccessFile.seek(startPosition);  
  97.                   
  98.                 HttpURLConnection connection = (HttpURLConnection) url.openConnection();  
  99.                 connection.setReadTimeout(5000);  
  100.                 connection.setRequestMethod("GET");  
  101.                 connection.setRequestProperty("Range", "bytes="+startPosition+"-"+endPosition);  
  102.                   
  103.                 InputStream inputStream = connection.getInputStream();  
  104.                 byte[] buffer = new byte[1024];  
  105.                 int len = 0;  
  106.                 while ((len = inputStream.read(buffer)) != -1)  
  107.                 {  
  108.                     randomAccessFile.write(buffer, 0, len);  
  109.                 }  
  110.                   
  111.                 inputStream.close();  
  112.                 randomAccessFile.close();  
  113.                   
  114.                 System.out.println("第"+(threadID+1)+"條線程已經下載完成");  
  115.                   
  116.             }  
  117.             catch (FileNotFoundException e)  
  118.             {  
  119.                 e.printStackTrace();  
  120.             }  
  121.             catch (IOException e)  
  122.             {  
  123.                 e.printStackTrace();  
  124.             }  
  125.         }  
  126.     }  
  127. }  
未做任何處理

Linux編程

理解Java多線程

Java終止線程

Java 線程池 ExecutorService

Java多線程-鎖

Java多線程編程——Java內存模型

Java線程池框架源碼分析

測試多線程下載的Java類

Java多線程下載輔助類實現

相關文章
  • Linux編程
  • SHELL編程
  • PERL編程
    • Copyright © Linux教程網 All Rights Reserved