自己弄的个多线程下载的程序，为什么有时候可以下载完全，有时候会卡在一个地方不动？下载代码如下：

1. import java.io.*;
   
2. import java.net.*;
   
3. 
   
4. /*
   
5. 需求：自定义设计多线程下载工具类
   
6. 思路：
   
7. 1，先通过URL对象获取到需下载的内容的地址并连接到指定URL获取文件信息
   
8. 2，计算所需下载文件的大小，并按照需要（线程数）将文件等分
   
9. 3，创建多个线程，每个线程都会负责相应的下载部分（主要利用RandomAccessFile类的任意存储特点）
   
10. 4，进行测试
    
11. */
    
12. public class DownLoad
    
13. {
    
14.         //定义下载资源的路径
    
15.         private String path;
    
16.         //指定下载的文件的保存位置
    
17.         private String targetFile;
    
18.         //定义需要使用多少个线程下载资源
    
19.         private int threadNum;
    
20.         //定义下载的线程对象
    
21.         private DownThread[] threads;
    
22.         //定义文件的总大小
    
23.         private long fileSize;
    
24.         //定义构造器，初始化资源路径，线程数等字段
    
25.         public DownLoad(String path,String targetFile,int threadNum)
    
26.         {
    
27.                 this.path=path;
    
28.                 this.targetFile=targetFile;
    
29.                 this.threadNum=threadNum;
    
30.                 //初始化trheads数组
    
31.                 threads=new DownThread[threadNum];
    
32.         }
    
33.         //定义方法，用以获取下载文件的相关信息，并根据线程数将文件进行等分
    
34.         public void download()throws Exception
    
35.         {
    
36.                 //定义并初始化指定路径的URL对象
    
37.                 URL url=new URL(path);
    
38.                 //通过URL对象获取对指定路径的连接
    
39.                 HttpURLConnection conn=(HttpURLConnection)url.openConnection();
    
40.                 //设置连接超时属性
    
41.                 conn.setConnectTimeout(5*1000);
    
42.                 //设置连接请求方式
    
43.                 conn.setRequestMethod("GET");
    
44.                 //设置请求的接收文件的相关属性
    
45.                 conn.setRequestProperty("Accept","*/*");
    
46.                 conn.setRequestProperty("Accept-Language","zh-CN");
    
47.                 conn.setRequestProperty("Charset","UTF-8");
    
48.                 conn.setRequestProperty("Connection","Keep-Alive");
    
49.                 //得到文件的大小
    
50.                 fileSize=conn.getContentLength();
    
51.                 conn.disconnect();
    
52.                 //按线程数将文件等分
    
53.                 long partSize=fileSize/threadNum+1;
    
54.                 //使用指定文件创建RandomAccessFile对象
    
55.                 RandomAccessFile file=new RandomAccessFile(targetFile,"rw");
    
56.                 //设置本地文件的大小
    
57.                 file.setLength(fileSize);
    
58.                 file.close();
    
59.                 //创建并启动线程
    
60.                 for(int i=0;i<threadNum;i++)
    
61.                 {
    
62.                         //计算每个线程下载的开始位置
    
63.                         long startPos=i*partSize;
    
64.                         //每个线程使用一个RandomAccessFile进行下载
    
65.                         RandomAccessFile part=new RandomAccessFile(targetFile,"rw");
    
66.                         //设置下载位置
    
67.                         part.seek(startPos);
    
68.                         //创建下载线程
    
69.                         threads[i]=new DownThread(startPos,partSize,part);
    
70.                         //启动线程
    
71.                         threads[i].start();
    
72.                 }
    
73.         }
    
74.         //定义方法用于获取下载完成的百分比
    
75.         public double getComplete()
    
76.         {
    
77.                 //统计所有线程已经下载的大小的总和
    
78.                 int sumSize=0;
    
79.                 for(int i=0;i<threadNum;i++)
    
80.                 {
    
81.                         sumSize+=threads[i].length;
    
82.                 }
    
83.                 //返回已完成的百分比
    
84.                 return sumSize*1.0/fileSize;
    
85.         }
    
86.         //测试代码
    
87.         public String getCompletes()
    
88.         {
    
89.                 //统计所有线程已经下载的大小的总和
    
90.                 int sumSize=0;
    
91.                 for(int i=0;i<threadNum;i++)
    
92.                 {
    
93.                         sumSize+=threads[i].length;
    
94.                 }
    
95.                 //返回已完成的百分比
    
96.                 return fileSize+" "+threads[0].length+" "+threads[1].length+" "+threads[2].length+"
    
97. 
    
98. "+threads[3].length+" "+(sumSize*1.0/fileSize);
    
99.         }
    
100.         //定义内部线程类，用于下载文件
     
101.         private class DownThread extends Thread
     
102.         {
     
103.                 //当前线程的下载位置
     
104.                 private long startPos;
     
105.                 //定义当前线程负责下载的文件大小
     
106.                 private long partSize;
     
107.                 //定义下载用的文件对象
     
108.                 private RandomAccessFile part;
     
109.                 //计算已经下载的文件大小
     
110.                 public long length=0;
     
111.                 //定义构造器，初始化数据
     
112.                 public DownThread(long startPos,long partSize,RandomAccessFile part)
     
113.                 {
     
114.                         this.startPos=startPos;
     
115.                         this.partSize=partSize;
     
116.                         this.part=part;
     
117.                 }
     
118.                 //重写run方法
     
119.                 public void run()
     
120.                 {
     
121.                         try
     
122.                         {
     
123.                                 //定义并初始化指定路径的URL对象
     
124.                                 URL url=new URL(path);
     
125.                                 //通过URL对象获取对指定路径的连接
     
126.                                 HttpURLConnection conn=(HttpURLConnection)url.openConnection();
     
127.                                 //设置连接超时属性
     
128.                                 conn.setConnectTimeout(5*1000);
     
129.                                 //设置连接请求方式
     
130.                                 conn.setRequestMethod("GET");
     
131.                                 //设置请求的接收文件的相关属性
     
132.                                 conn.setRequestProperty("Accept","*/*");
     
133.                                 conn.setRequestProperty("Accept-Language","zh-CN");
     
134.                                 conn.setRequestProperty("Charset","UTF-8");
     
135.                                 //获取文件输入流
     
136.                                 InputStream inStream=conn.getInputStream();
     
137.                                 //跳过startPos个字节（只下载自己负责的部分）
     
138.                                 inStream.skip(startPos);
     
139.                                 //定义字节数组，保存数据
     
140.                                 byte[] buf=new byte[1024];
     
141.                                 int hasRead=0;
     
142.                                 //读取网络数据，并写入本地文件
     
143.                                 while(length<partSize&&(hasRead=inStream.read(buf))!=-1)
     
144.                                 {
     
145.                                         //将数据写入指定文件的指定位置
     
146.                                         part.write(buf,0,hasRead);
     
147.                                         //累计下载的总大小
     
148.                                         length+=hasRead;
     
149.                                         this.yield();
     
150.                                 }
     
151.                                 part.close();
     
152.                                 inStream.close();
     
153.                         }
     
154.                         catch(Exception e)
     
155.                         {
     
156.                                 e.printStackTrace();
     
157.                         }
     
158.                 }
     
159.         }
     
160. }

复制代码

测试代码如下：

1. import java.lang.Math;
   
2. /*
   
3. 测试程序
   
4. */
   
5. 
   
6. public class DownTest
   
7. {
   
8.         public static void main(String[] args)throws Exception
   
9.         {       
   
10.                 //初始化DownLoad对象
    
11.                 final DownLoad download=new DownLoad
    
12. 
    
13. ("http://zhangmenshiting.baidu.com/data2/music/57130533/73007331395604861128.mp3?
    
14. 
    
15. xcode=b453c78019aaef462150ccef90c23ba01489e1db000d3934","测试.mp3",4);
    
16.                 //开始下载
    
17.                 download.download();
    
18.                 //定义线程，每过0.1秒统计任务的完成度
    
19.                 new Thread()
    
20.                 {
    
21.                         public void run()
    
22.                         {
    
23.                                 while(download.getComplete()<1)
    
24.                                 {
    
25.                                         System.out.println("已完成："+download.getComplete());
    
26.                                         try
    
27.                                         {
    
28.                                                 Thread.sleep(1000);
    
29.                                         }
    
30.                                         catch(Exception e){}
    
31.                                 }
    
32.                         }
    
33.                 }.start();
    
34.         }
    
35. }

复制代码

自己弄的个多线程下载的程序，为什么有时候可以下载完全，有时候会卡在一个地方不动？下载代码如下：

1. import java.io.*;
   
2. import java.net.*;
   
3. 
   
4. /*
   
5. 需求：自定义设计多线程下载工具类
   
6. 思路：
   
7. 1，先通过URL对象获取到需下载的内容的地址并连接到指定URL获取文件信息
   
8. 2，计算所需下载文件的大小，并按照需要（线程数）将文件等分
   
9. 3，创建多个线程，每个线程都会负责相应的下载部分（主要利用RandomAccessFile类的任意存储特点）
   
10. 4，进行测试
    
11. */
    
12. public class DownLoad
    
13. {
    
14.         //定义下载资源的路径
    
15.         private String path;
    
16.         //指定下载的文件的保存位置
    
17.         private String targetFile;
    
18.         //定义需要使用多少个线程下载资源
    
19.         private int threadNum;
    
20.         //定义下载的线程对象
    
21.         private DownThread[] threads;
    
22.         //定义文件的总大小
    
23.         private long fileSize;
    
24.         //定义构造器，初始化资源路径，线程数等字段
    
25.         public DownLoad(String path,String targetFile,int threadNum)
    
26.         {
    
27.                 this.path=path;
    
28.                 this.targetFile=targetFile;
    
29.                 this.threadNum=threadNum;
    
30.                 //初始化trheads数组
    
31.                 threads=new DownThread[threadNum];
    
32.         }
    
33.         //定义方法，用以获取下载文件的相关信息，并根据线程数将文件进行等分
    
34.         public void download()throws Exception
    
35.         {
    
36.                 //定义并初始化指定路径的URL对象
    
37.                 URL url=new URL(path);
    
38.                 //通过URL对象获取对指定路径的连接
    
39.                 HttpURLConnection conn=(HttpURLConnection)url.openConnection();
    
40.                 //设置连接超时属性
    
41.                 conn.setConnectTimeout(5*1000);
    
42.                 //设置连接请求方式
    
43.                 conn.setRequestMethod("GET");
    
44.                 //设置请求的接收文件的相关属性
    
45.                 conn.setRequestProperty("Accept","*/*");
    
46.                 conn.setRequestProperty("Accept-Language","zh-CN");
    
47.                 conn.setRequestProperty("Charset","UTF-8");
    
48.                 conn.setRequestProperty("Connection","Keep-Alive");
    
49.                 //得到文件的大小
    
50.                 fileSize=conn.getContentLength();
    
51.                 conn.disconnect();
    
52.                 //按线程数将文件等分
    
53.                 long partSize=fileSize/threadNum+1;
    
54.                 //使用指定文件创建RandomAccessFile对象
    
55.                 RandomAccessFile file=new RandomAccessFile(targetFile,"rw");
    
56.                 //设置本地文件的大小
    
57.                 file.setLength(fileSize);
    
58.                 file.close();
    
59.                 //创建并启动线程
    
60.                 for(int i=0;i<threadNum;i++)
    
61.                 {
    
62.                         //计算每个线程下载的开始位置
    
63.                         long startPos=i*partSize;
    
64.                         //每个线程使用一个RandomAccessFile进行下载
    
65.                         RandomAccessFile part=new RandomAccessFile(targetFile,"rw");
    
66.                         //设置下载位置
    
67.                         part.seek(startPos);
    
68.                         //创建下载线程
    
69.                         threads[i]=new DownThread(startPos,partSize,part);
    
70.                         //启动线程
    
71.                         threads[i].start();
    
72.                 }
    
73.         }
    
74.         //定义方法用于获取下载完成的百分比
    
75.         public double getComplete()
    
76.         {
    
77.                 //统计所有线程已经下载的大小的总和
    
78.                 int sumSize=0;
    
79.                 for(int i=0;i<threadNum;i++)
    
80.                 {
    
81.                         sumSize+=threads[i].length;
    
82.                 }
    
83.                 //返回已完成的百分比
    
84.                 return sumSize*1.0/fileSize;
    
85.         }
    
86.         //测试代码
    
87.         public String getCompletes()
    
88.         {
    
89.                 //统计所有线程已经下载的大小的总和
    
90.                 int sumSize=0;
    
91.                 for(int i=0;i<threadNum;i++)
    
92.                 {
    
93.                         sumSize+=threads[i].length;
    
94.                 }
    
95.                 //返回已完成的百分比
    
96.                 return fileSize+" "+threads[0].length+" "+threads[1].length+" "+threads[2].length+"
    
97. 
    
98. "+threads[3].length+" "+(sumSize*1.0/fileSize);
    
99.         }
    
100.         //定义内部线程类，用于下载文件
     
101.         private class DownThread extends Thread
     
102.         {
     
103.                 //当前线程的下载位置
     
104.                 private long startPos;
     
105.                 //定义当前线程负责下载的文件大小
     
106.                 private long partSize;
     
107.                 //定义下载用的文件对象
     
108.                 private RandomAccessFile part;
     
109.                 //计算已经下载的文件大小
     
110.                 public long length=0;
     
111.                 //定义构造器，初始化数据
     
112.                 public DownThread(long startPos,long partSize,RandomAccessFile part)
     
113.                 {
     
114.                         this.startPos=startPos;
     
115.                         this.partSize=partSize;
     
116.                         this.part=part;
     
117.                 }
     
118.                 //重写run方法
     
119.                 public void run()
     
120.                 {
     
121.                         try
     
122.                         {
     
123.                                 //定义并初始化指定路径的URL对象
     
124.                                 URL url=new URL(path);
     
125.                                 //通过URL对象获取对指定路径的连接
     
126.                                 HttpURLConnection conn=(HttpURLConnection)url.openConnection();
     
127.                                 //设置连接超时属性
     
128.                                 conn.setConnectTimeout(5*1000);
     
129.                                 //设置连接请求方式
     
130.                                 conn.setRequestMethod("GET");
     
131.                                 //设置请求的接收文件的相关属性
     
132.                                 conn.setRequestProperty("Accept","*/*");
     
133.                                 conn.setRequestProperty("Accept-Language","zh-CN");
     
134.                                 conn.setRequestProperty("Charset","UTF-8");
     
135.                                 //获取文件输入流
     
136.                                 InputStream inStream=conn.getInputStream();
     
137.                                 //跳过startPos个字节（只下载自己负责的部分）
     
138.                                 inStream.skip(startPos);
     
139.                                 //定义字节数组，保存数据
     
140.                                 byte[] buf=new byte[1024];
     
141.                                 int hasRead=0;
     
142.                                 //读取网络数据，并写入本地文件
     
143.                                 while(length<partSize&&(hasRead=inStream.read(buf))!=-1)
     
144.                                 {
     
145.                                         //将数据写入指定文件的指定位置
     
146.                                         part.write(buf,0,hasRead);
     
147.                                         //累计下载的总大小
     
148.                                         length+=hasRead;
     
149.                                         this.yield();
     
150.                                 }
     
151.                                 part.close();
     
152.                                 inStream.close();
     
153.                         }
     
154.                         catch(Exception e)
     
155.                         {
     
156.                                 e.printStackTrace();
     
157.                         }
     
158.                 }
     
159.         }
     
160. }

复制代码

测试代码如下：

1. import java.lang.Math;
   
2. /*
   
3. 测试程序
   
4. */
   
5. 
   
6. public class DownTest
   
7. {
   
8.         public static void main(String[] args)throws Exception
   
9.         {       
   
10.                 //初始化DownLoad对象
    
11.                 final DownLoad download=new DownLoad
    
12. 
    
13. ("http://zhangmenshiting.baidu.com/data2/music/57130533/73007331395604861128.mp3?
    
14. 
    
15. xcode=b453c78019aaef462150ccef90c23ba01489e1db000d3934","测试.mp3",4);
    
16.                 //开始下载
    
17.                 download.download();
    
18.                 //定义线程，每过0.1秒统计任务的完成度
    
19.                 new Thread()
    
20.                 {
    
21.                         public void run()
    
22.                         {
    
23.                                 while(download.getComplete()<1)
    
24.                                 {
    
25.                                         System.out.println("已完成："+download.getComplete());
    
26.                                         try
    
27.                                         {
    
28.                                                 Thread.sleep(1000);
    
29.                                         }
    
30.                                         catch(Exception e){}
    
31.                                 }
    
32.                         }
    
33.                 }.start();
    
34.         }
    
35. }

复制代码