Welcome 微信登录
编程资源 图片资源库 蚂蚁家优选 PDF转换器 软件资源

软件开发、小程序制作、系统集成与运维、空间租用、硬件开发、视频监控、技术咨询与支持——联系电话：0311-88999002/88999003

首页 / 操作系统 / Linux / Android 多线程下载

  1. package my.Thread;  
  2.   
  3. import java.io.BufferedInputStream;  
  4. import java.io.RandomAccessFile;  
  5. import java.net.HttpURLConnection;  
  6. import java.net.URL;  
  7. import java.net.URLConnection;  
  8. import java.util.concurrent.CountDownLatch;  
  9.   
  10.   
  11. import Android.app.Activity;  
  12. import android.os.Bundle;  
  13. import android.os.Environment;  
  14. import android.view.View;  
  15. import android.view.View.OnClickListener;  
  16. import android.widget.Button;  
  17. import android.widget.TextView;  
  18.   
  19. public class ManyThreadActivity extends Activity {  
  20.     /** Called when the activity is first created. */  
  21.      private Button button;  
  22.      private TextView textView;  
  23.      private static final int THREAD_COUNT = 4;  
  24.      private CountDownLatch latch = new CountDownLatch（THREAD_COUNT）;  
  25.      private long completeLength = 0;  
  26.      private long fileLength;  
  27.      public static String SaveFile=Environment.getExternalStorageDirectory（）+"/DownFile/"+"test.Mp3";    
  28.      public static final String url="http://210.30.12.33:8080/mp3/Beyond.mp3";  
  29.     @Override  
  30.     public void onCreate（Bundle savedInstanceState） {  
  31.         super.onCreate（savedInstanceState）;  
  32.         setContentView（R.layout.main）;  
  33.         button=（Button）findViewById（R.id.button1）;  
  34.         textView=（TextView） findViewById（R.id.editText1）;  
  35.         textView.setText（url）;  
  36.         button.setOnClickListener（new MyListener（））;  
  37.     }  
  38.     class MyListener implements OnClickListener{  
  39.   
  40.         @Override  
  41.         public void onClick（View v） {  
  42.             // TODO Auto-generated method stub   
  43.             try {  
  44.                 download（url）;  
  45.             } catch （Exception e） {  
  46.                 // TODO Auto-generated catch block   
  47.                 e.printStackTrace（）;  
  48.             }  
  49.         }  
  50.           
  51.     }  
  52.   
  53.     //进行下载的线程   
  54.     class DownloadThread extends Thread {  
  55.         private URL url;  
  56.         private RandomAccessFile file;  
  57.         private long from;  
  58.         private long end;  
  59.   
  60.         /** 
  61.          * @param url 下载的URL 
  62.          * @param file 下载完成之后存储的文件 
  63.          * @param from 当前线程对应文件的起始位置 
  64.          * @param end 当前线程对应文件的结束位置 
  65.          */  
  66.         DownloadThread（URL url, RandomAccessFile file, long from, long end） {  
  67.             this.url = url;  
  68.             this.file = file;  
  69.             this.from = from;  
  70.             this.end = end;  
  71.         }  
  72.   
  73.         public void run（） {  
  74.             try {  
  75.                 long pos = from;  
  76.                 byte[] buf = new byte[1024*8];  
  77.   
  78.                 HttpURLConnection cn = （HttpURLConnection） url.openConnection（）;  
  79.                  
  80.                 //设置请求的起始和结束位置。   
  81.                 cn.setRequestProperty（"Range", "bytes=" + from + "-" + end）;  
  82.   
  83.                 BufferedInputStream bis = new BufferedInputStream（cn.getInputStream（））;  
  84.                 int len;  
  85.                 while （（len = bis.read（buf）） > 0） {  
  86.                     synchronized （file） {  
  87.                         file.seek（pos）;  
  88.                         file.write（buf, 0, len）;  
  89.                     }  
  90.                     pos += len;  
  91.                     completeLength += len;  
  92.                     System.out.println（completeLength * 100 / fileLength + "%"）;  
  93.                 }  
  94.                 cn.disconnect（）;  
  95.             } catch （Exception e） {  
  96.                 e.printStackTrace（）;  
  97.             }  
  98.             latch.countDown（）;  
  99.         }  
  100.     }  
  101.   
  102.     public void download（String address） throws Exception {  
  103.         URL url = new URL（address）;  
  104.         URLConnection cn = url.openConnection（）;  
  105.         fileLength = cn.getContentLength（）;  
  106.         long packageLength = fileLength / THREAD_COUNT;//每个线程要下载的字节数   
  107.         long leftLength = fileLength % THREAD_COUNT;//剩下的字节数   
  108.          
  109.         RandomAccessFile file = new RandomAccessFile（SaveFile, "rw"）;  
  110.          
  111.         System.out.println（fileLength）;  
  112.         //计算每个线程请求的起始位置和结束位置。   
  113.         /* 
  114.          * 第一个线程的起始位置是0~0+packageLength（每个线程要下载的字节数） 
  115.          * 第二个线程的起始位置是endPos+1（第一个线程的packageLength+1）~endPos+1+packageLength 
  116.          * 第二个线程的起始位置是......... 
  117.          */  
  118.         long pos = 0;  
  119.         for （int i = 0; i < THREAD_COUNT; i++） {  
  120.             long endPos = pos + packageLength;  
  121.             new DownloadThread（url, file, pos, endPos）.start（）;  
  122.             if（leftLength > 0） {  
  123.                 endPos++;  
  124.                 leftLength--;  
  125.             }  
  126.             pos = endPos;  
  127.         }  
  128.         latch.await（）;  
  129.     }  
  130.   
  131. }  
保存为test.mp3文件
版权所有©石家庄振强科技有限公司2024 冀ICP备08103738号-5 网站地图