{
private long startPos;//下載起點(diǎn)
private long endPos;//下載結(jié)束點(diǎn)
private boolean done = false;
private boolean stop=false;
private String address;//下載地址
private DownloadStat stat;//統(tǒng)計(jì)線程 
private RandomAccessFile file=null;

public DownThread(String address,String localFilePath,long startPos, long endPos,DownloadStat stat) throws IOException
{
   this.address = address;
   this.startPos = startPos;
   this.endPos = endPos;
   this.address=address;
   file=new RandomAccessFile(localFilePath, "rw");
   file.seek(startPos);//設(shè)置啟動(dòng)位置
   this.stat=stat; 
}

public void run()
{
   InputStream input =null;
   HttpURLConnection httpConnection=null;
   try
   {
    httpConnection = (HttpURLConnection) new URL(address).openConnection();
    if(httpConnection==null)
    {
     return;
    }
    String sProperty = new StringBuffer("bytes=").append(startPos).append("-").append(endPos).toString();
    httpConnection.setRequestProperty("RANGE", sProperty);//設(shè)置下載范圍
    input =httpConnection.getInputStream();
    byte[] buf=new byte[1024];
    int offset;
    while(!stop&&(offset=input.read(buf,0,buf.length))!=-1)
    {
     file.write(buf, 0,offset);
     stat.updateDownloadSize(getName(),startPos,endPos,offset);//將下載的數(shù)據(jù)量進(jìn)行累加
    }
   }
   catch (Exception ex)
   {
    ex.printStackTrace();
   }
   finally
   {
    try
    {
     file.close();
     if(input!=null)
     {
      input.close();
     }
    }
    catch (IOException e)
    {
     e.printStackTrace();
    }
    done = true;
    if(httpConnection!=null)
    {
     httpConnection.disconnect();
    }
   }
}
/**
* 判斷是否完成
* @return
*/
public boolean isDone()
{
   return done;
}
/**
* 終止下載
*/
public void stopDown()
{
   this.stop=true;
}
}
/**
* 下載統(tǒng)計(jì)類
* 包括已經(jīng)下載的數(shù)據(jù)量、下載平均速度、已經(jīng)下載時(shí)間、完成百分比等等
* @author zean
* @create date 2008-06-30
*/
public class DownloadStat extends Thread
{
private long beginTime;//本次下載開(kāi)始時(shí)間
private BigDecimal downloadedSize;//本次下載量累計(jì)
private long fileLength;//文件長(zhǎng)度
private BigDecimal initSpeed;
private boolean stopStat=false;
private DownloadHis downloadHis;
private String fileName;
/**
* @param fileLength 文件長(zhǎng)度
* @param downloadHis 下載歷史信息
*/
public void init(long fileLength,String fileName)
{
   this.beginTime=System.currentTimeMillis();
   this.downloadedSize=new BigDecimal(0);
   this.fileLength=fileLength;
   this.initSpeed=new BigDecimal(0);
   this.fileName=fileName;
   if(downloadHis==null)
   {
    downloadHis=new DownloadHis(fileName);
   }
   else
   {
    downloadHis.initDownloadedInfo(fileName);
   }
}
public boolean isDownloaded()
{
   if((int)downloadHis.getHisPercent()==10000)
   {
    return true;
   }
   return false;
}

/**
* 定時(shí)將下載信息寫(xiě)入磁盤(pán),由于文件下載完畢后也有寫(xiě)入操作，所以寫(xiě)入方法加了同步鎖
*/
public void run()
{
   while(!stopStat)
   {
    try
    {
     sleep(30000);//隔30秒自動(dòng)寫(xiě)入一次
    }
    catch (InterruptedException e)
    {
     e.printStackTrace();
    }
    /**
    * 下載完成一個(gè)文件后暫停自動(dòng)寫(xiě)入操作
    */
    if(isDownloaded()||getPercent().intValue()==100)
    {
     try
     {
      synchronized(this)
      {
       wait();
      }
     }
     catch (InterruptedException e)
     {
      e.printStackTrace();
     }
    }
    if(getSpeed().doubleValue()>0)
    {
     writeDownInfoToFile();
    }
   }
}
public void stopStat()
{
   this.stopStat=true;
}
/**
* 更新下載數(shù)據(jù)量(單位:字節(jié))以及下載起始位置
* 由于可能同時(shí)有多個(gè)線程進(jìn)行操作，所以加同步鎖
* @param signalDownSize
*/
public synchronized void updateDownloadSize(String threadId,long startPos,long endPos,long size)
{
   downloadedSize=downloadedSize.add(new BigDecimal(size));
   downloadHis.updateDownInfo(threadId,startPos,endPos,size);
}
public void initDownInfo(String threadId,long startPos,long endPos)
{
   downloadHis.updateDownInfo(threadId,startPos,endPos,0);
}
/**
* 獲取已經(jīng)下載的數(shù)據(jù)量(單位:M)
* @return
*/
public BigDecimal getDownloadedSize()
{
   return (downloadedSize.add(downloadHis.getHisDownloadedSize())).divide(new BigDecimal(1048576),2,BigDecimal.ROUND_HALF_UP);
}

/**
* 已經(jīng)下載時(shí)間(時(shí)-分-秒)
*/
public String getPassedTime()
{
   return parseTime(new BigDecimal(System.currentTimeMillis()-beginTime));
}
/**
* 獲取下載百分比
* @return
*/
public BigDecimal getPercent()
{
   return (downloadedSize.add(downloadHis.getHisDownloadedSize())).multiply(new BigDecimal(100)).divide(new BigDecimal(fileLength), 2, BigDecimal.ROUND_HALF_UP);
}
/**
* 下載平均速度(K/秒)
* @return
*/
public BigDecimal getDownSpeed()
{
   return getSpeed().multiply(new BigDecimal(1000)).divide(new BigDecimal(1024), 1, BigDecimal.ROUND_HALF_UP);
}
/**
* 下載平均速度(字節(jié)/毫秒)
* @return
*/
private BigDecimal getSpeed()
{
   BigDecimal timeOffset=new BigDecimal(System.currentTimeMillis()-beginTime);
   if(timeOffset.longValue()==0)
   {
    return initSpeed;
   }
   return downloadedSize.divide(timeOffset,1,BigDecimal.ROUND_HALF_UP);
}
/**
* 估計(jì)剩余時(shí)間(時(shí)-分-秒)
* @param timespace
* @return
*/
public String getLeaveTime()
{
   if(getSpeed().intValue()<1)
   {
    return "0";
   }
   BigDecimal leaveTime=(new BigDecimal(fileLength).subtract(downloadedSize).subtract(this.downloadHis.getHisDownloadedSize())).divide(getSpeed(), 2, BigDecimal.ROUND_HALF_UP);
   return parseTime(leaveTime);
}
/**
* 將下載信息寫(xiě)入磁盤(pán)
*/
public synchronized void writeDownInfoToFile()
{
   downloadHis.writeDownInfoToFile(fileLength, downloadedSize,getPercent().doubleValue());
}
/**
* 獲取歷史下載信息
* @return
*/
public List getDownloadedInfo()
{
   return this.downloadHis.getDownloadedInfo();
}
/**
* 判斷服務(wù)器文件是否發(fā)生變化
* @return
*/
public boolean isChange()
{
   return (downloadHis.getHisFileLength()!=0&&fileLength!=downloadHis.getHisFileLength());
}
public String getFileName()
{
   return this.fileName;
}
/**
* 獲取歷史下載百分比
* @return
*/
public int getHisPercent()
{
   return downloadHis.getHisPercent();
}
/**
* 解析時(shí)間成 時(shí)-分-秒的形式
* @param timeOffset
* @return
*/
private String parseTime(BigDecimal timeOffset)
{
   BigDecimal times=timeOffset.divide(new BigDecimal(1000), 1, BigDecimal.ROUND_HALF_UP);
   BigDecimal hours = times.divide(new BigDecimal(3600), 0, BigDecimal.ROUND_DOWN);
   BigDecimal mimutes = times.subtract(hours.multiply(new BigDecimal(3600))).divide(new BigDecimal(60), 0, BigDecimal.ROUND_DOWN);
   BigDecimal second = times.subtract(hours.multiply(new BigDecimal(3600))).subtract(mimutes.multiply(new BigDecimal(60)));
   return hours.longValue() + "時(shí)," + mimutes.longValue() + "分," + second.doubleValue() + "秒";
}
}
/**
* 下載歷史記錄
* 用于記錄下載量，各線程下載情況，以及將下載信息寫(xiě)入到本地磁盤(pán)
* @author zean
* @crate date 2008-07-01
*/
public class DownloadHis
{
private List downloadedInfo;// 歷史線程下載記錄
private BigDecimal hisDownloadedSize;//歷史下載量
private long hisFileLength=0;//歷史文件大小，由于源文件大小有可能發(fā)生變化，一旦文件大小與當(dāng)前大小不一致，則需要重新下載
private Map infoMap=null;//
private String fileName=null;
private int hisPercent=0;//歷史下載百分比
public DownloadHis()
{
   infoMap=new HashMap();
}
public DownloadHis(String fileName)
{
   this.fileName=fileName;
   infoMap=new HashMap();
   initDownloadedInfo(fileName);
}

/**
* 初始化歷史下載信息
*/
public void initDownloadedInfo(String fileName)
{
   downloadedInfo=null;
   hisDownloadedSize=new BigDecimal(0);
   infoMap.clear();
   hisFileLength=0;
   hisPercent=0;
   this.fileName=fileName;
   SAXReader reader=new SAXReader();
   File file=new File(getFilePath(fileName));
   if(!file.exists())
   {
    return;
   }
   Document doc=null;
   try
   {
    doc = reader.read(file);
   }
   catch (DocumentException e)
   {
    e.printStackTrace();
   }
   Element root=doc.getRootElement();
   List elements=root.elements();
   if(elements==null||elements.size()<1)
   {
    return;
   }
   List list=new ArrayList();
   Element element=null;
   setHisPercent(root.attributeValue("percent"));
   setHisDownloadedSize(root.attributeValue("downloadedSize"));
   setHisFileLength(root.attributeValue("totalSize"));
   for(int i=0;i<elements.size();i++)
   {
    element=(Element)elements.get(i);
    long startPos=Long.parseLong(element.attributeValue("startPos"));
    long endPos=Long.parseLong(element.attributeValue("endPos"));
    if(startPos<=endPos)
    {
     list.add(new DownInfo(element.attributeValue("threadId"),startPos,endPos));
    }
   }
   setDownloadedInfo(list);
}

/**
* 將下載信息寫(xiě)入磁盤(pán)
*/
protected void writeDownInfoToFile(long fileLength,BigDecimal downloadedSize,double downPercent)
{
   if(!new File(UpdateService.getTempFolder()+fileName).exists())
   {
    return;
   }
   StringBuffer buf=new StringBuffer();
   buf.append("<?xml version=\"1.0\" encoding=\"GB2312\"?>").append("\n<threads totalSize=\""+fileLength+"\" downloadedSize=\""+downloadedSize.add(getHisDownloadedSize()).longValue()+"\" percent=\""+downPercent+"\">\n");
   Set set=infoMap.entrySet();
   Iterator it=set.iterator();
   Map.Entry entry;
   DownInfo downInfo;
   while(it.hasNext())
   {
    entry=(Map.Entry)it.next();
    downInfo=(DownInfo)entry.getValue();
    buf.append("<thread threadId=\""+entry.getKey()+"\" startPos=\""+downInfo.getStartPos()+"\" endPos=\""+downInfo.getEndPos()+"\"></thread>\n");
   }
   buf.append("</threads>");
   FileWriter fw = null;
   try
   {
    fw = new FileWriter(getFilePath(fileName));
    fw.write(buf.toString(), 0, buf.length());
    fw.close();
   }
   catch (IOException e1)
   {
    e1.printStackTrace();
   }
}
/**
* 更新線程下載信息
* @param infoMap 封裝了各個(gè)線程的下載情況
* @param threadId 線程名
* @param startPos 起點(diǎn)位置
* @param endPos 終點(diǎn)位置
* @param size 即時(shí)下載量
*/
public void updateDownInfo(String threadId,long startPos,long endPos,long size)
{
   DownInfo downInfo=(DownInfo)infoMap.get(threadId);
   if(downInfo==null)
   {
    downInfo=new DownInfo(threadId,startPos,endPos);
   }
   else
   {
    downInfo.updateStartPos(size);
   }
   infoMap.put(threadId,downInfo);
}

private void setDownloadedInfo(List downloadedInfo)
{
   this.downloadedInfo = downloadedInfo;
}
/**
* 讀取上次下載的信息作為斷點(diǎn)續(xù)傳的基礎(chǔ)
* @return
* @throws DocumentException
*/
public List getDownloadedInfo()
{
   return downloadedInfo;
}
/**
* 獲取歷史下載百分比
* @return
*/
public int getHisPercent()
{
   return this.hisPercent;
}
private void setHisPercent(String percent)
{
   if(percent!=null)
   {
    this.hisPercent=new BigDecimal(percent).multiply(new BigDecimal(100)).intValue();
   }
}
/**
* 獲取歷史下載量
* @return
*/
public BigDecimal getHisDownloadedSize()
{
   return hisDownloadedSize;
}
private void setHisDownloadedSize(String hisDownloadedSize)
{
   if(hisDownloadedSize!=null)
   {
    this.hisDownloadedSize = new BigDecimal(hisDownloadedSize);
   }
}
/**
* 獲取歷史文件長(zhǎng)度(用于下載前與當(dāng)前下載文件進(jìn)行比較)
* @return
*/
public long getHisFileLength()
{
   return hisFileLength;
}
private void setHisFileLength(String hisFileLength)
{
   if(hisFileLength!=null)
   {
    this.hisFileLength = Long.parseLong(hisFileLength);
   }
}
/**
* 獲取歷史記錄信息文件地址
* @param fileName
* @return
*/
private String getFilePath(String fileName)
{
   return UpdateService.getTempFolder()+fileName+".xml";
}
/**
* 獲取下載文件名
* @return
*/
public String getFileName()
{
   return this.fileName;
}
}