package com.wgtgt;

import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.ProtocolException;
import java.net.URL;

public class DownLoadThread extends Thread{

	public DownLoadThread(String path,String tempFolder, int startIndex, int endIndex,
			int threadId) {
		try {
			URL url=new URL(path);
			HttpURLConnection conn=(HttpURLConnection)url.openConnection();
			conn.setConnectTimeout(5000);
			conn.setRequestMethod("POST");
			conn.setRequestProperty("Range", "bytes="+startIndex+"-"+endIndex);
			InputStream is=conn.getInputStream();
			String fileName=conn.getURL().getFile();
			fileName=fileName.substring(fileName.lastIndexOf("/")+1);
			String fullName=tempFolder+"/"+fileName+threadId;
			write(fullName, is);
		} catch (MalformedURLException e) {
			e.printStackTrace();
		} catch (ProtocolException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
		System.out.println("线程"+threadId+"下载结束,如果所有线程均下载完，请合并文件");
	}

	private void write(String fullName, InputStream is){
		OutputStream os=null;
		try {
			os=new FileOutputStream(fullName);
			byte[]buffer=new byte[1024];
			int len=0;
			while((len=is.read(buffer))!=-1){
				os.write(buffer, 0, len);
			}			
		} catch (FileNotFoundException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}finally{
			if(os!=null){
				try {
					os.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		}
	}

}