/*
 * 創建日期 2005-4-5
 *
 * TODO 要更改此生成的文件的模板，請轉至
 * 窗口 － 首選項 － Java － 代碼樣式 － 代碼模板
 */
import java.io.*;
import java.net.*;
import java.util.*;
/**
 * @author 姜周揚
 *
 * TODO 實際完成下載工作的類,使用一個線程下載一個任務
 * 同時可執行多個下載任務
 * 從指定URL下載文件
 */
class Download extends Observable implements Runnable {
	//下載緩沖區最大限制
	private static final int MAX_BUFFER_SIZE = 1024;
	//下載狀態字
	public static final String STATUSES[]={
			"下載",
			"暫停",
			"完成",
			"取消",
			"錯誤"
	};
	//下載狀態字內部碼
	public static final int DOWNLOADING = 0;
	public static final int PAUSED = 1;
	public static final int COMPLETE = 2;
	public static final int CANCELLED = 3;
	public static final int ERROR = 4;
	//下載地址URL
	private URL url;
	//下載文件字節數大小
	private int size;
	//已經下載的字節數大小
	private int downloaded;
	//當前下載狀態
	private int status;
	//DOWNLOAD構造函數
	public Download(URL url){
		this.url = url;
		size = -1;//文件大小未知
		downloaded = 0;
		status = DOWNLOADING;//設為下載狀態
		//開始下載
		download();
	}
	//獲得下載地址URL
	public String getUrl(){
		return url.toString();
	}
	//獲得下載文件大小
	public int getSize(){
		return size;
	}
	//獲得已下載文件的比例大小
	public float getProgress(){
		return ((float)downloaded/size)*100;
	}
	//獲得此下載狀態
	public int getStatus(){
		return status;
	}
	//暫停下載
	public void pause(){
		status = PAUSED;
		stateChanged();
	}
	//繼續開始下載
	public void resume(){
		status = DOWNLOADING;
		stateChanged();
		download();
	}
	//取消下載
	public void cancel(){
		status = CANCELLED;
		stateChanged();
	}
	//標記此下載發生錯誤
	public void error(){
		status = ERROR;
		stateChanged();
	}
	//開始或重新開始下載
	private void download(){
		Thread thread = new Thread(this);
		thread.start();
	}
	//獲得下載文件名
	private String getFileName(URL url){
		String fileName = url.getFile();
		return fileName.substring(fileName.lastIndexOf('/')+1);
	}
	//下載文件線程開始
	public void run(){
		RandomAccessFile file = null;
		InputStream stream = null;
		
		try{
			//打開URL連接
			//Http1.1支持斷點續傳:Http1.0不支持
			HttpURLConnection connection = (HttpURLConnection) url.openConnection();
			//設置連接請求屬性:斷點續傳關鍵所在
			//Range 為:開始字節數-終止字節數
			connection.setRequestProperty("Range","bytes=" + downloaded + '-');
			//連接到服務器
			connection.connect();
			//服務器返回100的整數為反應:200表示成功連接
			if(connection.getResponseCode()/100 != 2){
				error();
			}
			//獲得下載文件的長度
			int contentLength = connection.getContentLength();
			if(contentLength < 1){
				error();
			}
			//設置size的值,如果還沒設置的話
			if(size == -1){
				size = contentLength;
				stateChanged();
			}
			//打開文件,并且找到文件的末尾
			file = new RandomAccessFile(getFileName(url),"rw");
			file.seek(downloaded);
			//獲取網絡文件輸入流
			while(status == DOWNLOADING){
				/* 緩沖區的大小設置為未下載的大小
				 * 如果文件大小超過緩沖區,則設置為最大限定值
				 */
				byte buffer[];
				if(size - downloaded > MAX_BUFFER_SIZE){
					buffer = new byte[MAX_BUFFER_SIZE];
				}
				else{
					buffer = new byte[size - downloaded];
				}
				//從服務器向緩沖區讀數據
				int read = stream.read(buffer);
				if(read == -1)
					break;
				//將緩沖區中數據寫入文件
				file.write(buffer,0,read);
				downloaded += read;
				stateChanged();
			}
			/* 如果文件下載完畢,退出循環時狀態仍為DOWNLOADING
			 * 設狀態為完成態
			 */
			if(status == DOWNLOADING){
				status = COMPLETE;
				stateChanged();
			}
		}
		catch(Exception e){
			error();
		}
		finally{
			//關閉文件
			if(file != null){
				try{
					file.close();
				}catch(Exception e){}
			}
			//關閉連接
			if(stream != null){
				try{
					stream.close();
				}catch(Exception e){}
			}
		}
	}
	//向已經注冊到這個下載實例的類發送狀態改變消息
	private void stateChanged(){
		setChanged();
		notifyObservers();
	}
	
}