swing写的迅雷界面

/* * SubTask.java * * Created on 2007年11月17日, 下午4:48 * * To change this template, choose Tools | Template Manager * and open the template in the editor. */ package com.tewang.download.manager; import com.tewang.download.common.DLConstant; import com.tewang.download.common.Util; import com.tewang.download.sounds.Sound; import com.tewang.download.submanager.DownThread; import com.tewang.download.submanager.FileInfo; import com.tewang.download.submanager.FilePosition; import com.tewang.download.submanager.SubThread; import com.tewang.download.userinterface.TaskManagerListener; import java.applet.Applet; import java.applet.AudioClip; import java.awt.Desktop; import java.io.File; import java.io.FileNotFoundException; import java.io.IOException; import java.io.Serializable; import java.net.HttpURLConnection; import java.net.URL; import java.util.ArrayList; import java.util.Calendar; import java.util.Date; import java.util.List; import java.util.logging.Level; import java.util.logging.Logger; import javax.swing.JOptionPane; /** * * @author tewang */ public class SubTask implements DLConstant, Runnable, Serializable { public static final long serialVersionUID = 20071211L; private TaskManagerListener tml; private int type;//任务类型 (正在下载,已经下载,垃圾箱) private int status = ONDOWNLOAD;//任务状态(正在下载,暂停下载,下载失败,下载完毕) private String fileName;//文件名称 private long length;//文件大小 private long downLength;//文件已经下载的大小 private int progress;//文件进度 private String resource;//资源 private long speed;//下载速度 private int restTime;//剩余时间 private int takeTime;//用时(已经花了的时间) private String fileType;//文件类型 private String note;//文件注释 private Date date;//下载日期 private String blog;//博客 private FileInfo fileInfo = null;//文件信息 private List<FilePosition> blockList;//把文件分块,每块文件的起始位置和终点位置 private List<SubThread> subThreadList;//每个子线程 private boolean stop = true;//任务是否被停止,任务默认是停止的 /** Creates a new instance of SubTask */ public SubTask(FileInfo fileInfo, int type, TaskManagerListener tml) { this.type = type; this.tml = tml; this.fileInfo = fileInfo; this.fileName = fileInfo.getFile().getName(); try { length = this.getFileSize(); blockList = new ArrayList<FilePosition>(); subThreadList = new ArrayList<SubThread>(); computeBlockList(); initDownThread(); } catch (Exception ex) { Logger.getLogger(DownThread.class.getName()).log(Level.SEVERE, null, ex); } new Thread(this).start(); startTask(); } @Override public String toString() { return "任务类型:" + type + " 文件名称:" + fileName + " 文件大小:" + length + " 文件已经下载的大小:" + downLength + "\n文件进度:" + progress + " 资源:" + resource + " 下载速度:" + speed + " 剩余时间:" + restTime + "\n用时(已经花了的时间):" + takeTime + " 文件类型:" + fileType + " 文件注释:" + note + "\n 下载日期:" + date + " 博客:" + blog + " 文件信息:" + fileInfo; } /** * 已经下载的大小 * @param readBytes */ public synchronized void addDownLength(int readBytes) { downLength = downLength + readBytes; } // /** // * 重新下载要清空相关的内容 // */ // public void clearConent() { // status = ONDOWNLOAD;//要把状态变为正在下载 // downLength = 0;//文件已经下载的大小 // progress = 0;//文件进度 // speed = 0;//下载速度 // restTime = 0;//剩余时间 // takeTime = 0;//用时(已经花了的时间) // } public void run() { long lastSecondLength = downLength;//前一秒文件已经下载的大小 while (!stop) { try { if (length != 0) { progress = (int) (100 * downLength / length); }//计算下载进度 speed = downLength - lastSecondLength; lastSecondLength = downLength; if (speed != 0) { restTime = (int) ((length - downLength) / speed); } takeTime++; if (subThreadList.size() == 0) {//说明任务已经完成.... doFinishDownLoad(); } Thread.sleep(1000); } catch (Exception e) { e.printStackTrace(); } } } /** * 下载完成所要处理的事情 */ private void doFinishDownLoad() { //开始播放声音 AudioClip au = Applet.newAudioClip(Sound.class.getResource("download-complete.wav")); au.play(); // int i = 0;//对文件重新命名,如是重新命名失败,就要重试,重试次数限制三次 // reNameFile(i); //设置下载状态为已经完成. status = FINISH; //关闭当前主线程 stop = true; this.setDate(Calendar.getInstance().getTime());//设置下载完成的时间 boolean b = tml.moveTask(this, BEEN_DOWNED);//把任务移到"已下载"里 } private void print(List<FilePosition> list) { for (FilePosition p : list) { System.out.println(p); } } /** * 把文件分块,每块文件的起始位置和终点位置 */ private void computeBlockList() { int block = getFileInfo().getBlock(); for (int i = 0; i < block; i++) { long startPos = (long) (i * length / block); long endPos = 0; if (i == (block - 1)) { endPos = length; } else { endPos = (i + 1) * length / block; } FilePosition fp = new FilePosition(startPos, endPos); blockList.add(fp); } } private void initDownThread() throws FileNotFoundException { for (int i = 0; i < getFileInfo().getBlock(); i++) { SubThread st = new SubThread(fileInfo.getFile(), getFileInfo().getUrl(), blockList.get(i), i, this, subThreadList); subThreadList.add(st); } } /** * 获得文件长度 * @return */ public long getFileSize() { int nFileLength = -1; try { URL url = getFileInfo().getUrl(); HttpURLConnection httpConnection = (HttpURLConnection) url.openConnection(); // httpConnection.setRequestProperty("User-Agent", "NetFox"); int responseCode = httpConnection.getResponseCode(); if (responseCode >= 400) { System.err.println("responseCode:" + responseCode); return -2; //-2 为Web服务器响应错误 } String sHeader; for (int i = 1;; i++) { sHeader = httpConnection.getHeaderFieldKey(i); if (sHeader != null) { if (sHeader.equals("Content-Length")) { nFileLength = Integer.parseInt(httpConnection.getHeaderField(sHeader)); break; } } else { break; } } } catch (IOException e) { e.printStackTrace(); } catch (Exception e) { e.printStackTrace(); } return nFileLength; } /** * 删除任务 */ private boolean remove() { switch (type) { case ON_DOWN: return tml.moveTask(this, DUSTBIN); case BEEN_DOWNED: return tml.moveTask(this, DUSTBIN); case DUSTBIN: return tml.remove(this); } return false; } public int getType() { return type; } public void setType(