多线程断点上载实现（J2SE版本）

package cn.itcast.download;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 TestDownload {		public static final String path = "http://localhost:8080/youdao.exe";		public static void main(String[] args) throws IOException {		URL url = new URL(path);		HttpURLConnection conn = (HttpURLConnection) url.openConnection();		conn.setRequestMethod("GET");		conn.setReadTimeout(5000);		conn.setRequestProperty("User-Agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1)");		int code = conn.getResponseCode();		if (code == 200) {			//得到服务器上文件的长度			int len = conn.getContentLength();//			创建从中读取和向其中写入（可选）的随机访问文件流，该文件具有指定名称。//			"rwd"   打开以便读取和写入，对于 "rw"，还要求对文件内容的每个更新都同步写入到底层存储设备。  			RandomAccessFile file = new RandomAccessFile(					getFileName(path), "rwd");			// 1.设置本地文件大小跟服务器的文件大小一致  			file.setLength(len);						// 2 .假设开启3 个线程			int threadnumber = 3;			int blocksize = len / threadnumber;			/**			 * 线程1 0~ blocksize 			 * 线程2 1*bolocksize ~ 2*blocksize 			 * 线程3 2*blocksize ~			 * 文件末尾			 */			for (int i = 0; i < threadnumber; i++) {				int startpostion = i*blocksize;				int endposition = (i+1)*blocksize;				if (i == (threadnumber - 1)) {					endposition = len;				}				//开始为每个线程下载。								DownLoadTask task = new DownLoadTask(i, path, startpostion, endposition);								task.start();				//				在启动线程时候，有两种方法可以使用//				start()为一半通用的启动线程的方法，通过调用线程类Thread的start()方法来启动线程，//				然后线程Thread类通过调用run()方法来实现线程的操作，而其中的run()方法中的内容实为线程体，//				即为该线程所要执行的内容。run()方法执行结束，该线程也就终止了，cpu在执行其他的线程//				如果将线程看做一般的Java类的话，则run()方法相当于普通的方法调用//				，通过普通的java类实例.run()来启动线程，即执行该方法体的内容。最终程序执行的只有主线程这一个。							}					}													}	/**	 * @param path	 * @return	 * 根据服务器上的路径得到文件名称。	 */	public static String getFileName(String path){		int start = path.lastIndexOf("/") + 1;		return path.substring(start, path.length());	}	}class DownLoadTask extends Thread{	public static final String path = "http://localhost:8080/youdao.exe";	int threadid;	String filepath;	int startposition;	int endpositon;	public DownLoadTask(int threadid, String filepath, int startposition,			int endpositon) {		this.threadid = threadid;		this.filepath = filepath;		this.startposition = startposition;		this.endpositon = endpositon;	}		@Override	public void run() {		try {			//引入断点下载  这个文件用于记录该线程下载到了哪个位置，有几个线程就会产生几个这样的文件。			File positionFile = new File(threadid+".txt");						URL url = new URL(filepath);			HttpURLConnection connection = (HttpURLConnection) url.openConnection();						System.out.println("线程" + threadid + "正在下载 " + "开始位置 : "					+ startposition + "结束位置 " + endpositon);						//执行这句话就说明该线程已经是第二次之后执行到这了。			if (positionFile.exists()) {				FileInputStream fis = new FileInputStream(positionFile);				byte[] result = StreamUtil.getBytes(fis);				int newstartposition = Integer.parseInt(new String(result));				if (newstartposition > startposition) {					startposition = newstartposition;				}			}			// "Range", "bytes=2097152-4194303")			connection.setRequestProperty("Range", "bytes="+startposition+"-"+endpositon);			connection.setRequestMethod("GET");			connection.setReadTimeout(5000);			connection.setRequestProperty("User-Agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1)");			InputStream iStream = connection.getInputStream();			RandomAccessFile file = new RandomAccessFile(getFileName(path), "rwd");			// 设置 数据从文件哪个位置开始写			file.seek(startposition);			byte[] bytes = new byte[1024];			int len = 0;			// 代表当前读到的服务器数据的位置 ,同时这个值已经存储的文件的位置			int currentPostion = startposition;			// 创建一个文件对象 ,记录当前某个文件的下载位置			while ((len = iStream.read(bytes)) != -1) {				file.write(bytes, 0, len);								currentPostion += len;				// 需要把currentPostion 信息给持久化到存储设备				String position = currentPostion + "";				FileOutputStream fos = new FileOutputStream(positionFile);				fos.write(position.getBytes());				fos.flush();				fos.close();			}			file.close();									System.out.println("线程" + threadid + "下载完毕");						// 当线程下载完毕后 把文件删除掉			if (positionFile.exists()) {				positionFile.delete();			}								} catch (MalformedURLException e) {			e.printStackTrace();		} catch (IOException e) {			e.printStackTrace();		}			}				public static String getFileName(String path){		int start = path.lastIndexOf("/") + 1;		return path.substring(start, path.length());	}				}