断点续传的Java桌面程序

说明

断点续传指的是在下载或上传时，将下载或上传任务（一个文件或一个压缩包）人为的划分为几个部分，每一个部分采用一个线程进行上传或下载，如果碰到网络故障，可以从已经上传或下载的部分开始继续上传下载未完成的部分，而没有必要从头开始上传下载。用户可以节省时间，提高速度。常见的支持断点续传的上传、下载软件：QQ旋风、迅雷、快车（迷你快车）、web迅雷、影音传送带、快车、BitComet、电驴eMule、哇嘎Vagaa、RF[RaySourse/RayFile]、酷6、土豆、优酷、百度视频、新浪视频、腾讯视频、百度云等都支持断点续传。

实现方式

在下载文件的同时，创建一个info文件保存传输的文件节点，当服务器断开或者暂停下载的时候，通过info文件记录已下载的结点位置，当再次进行下载任务的时候，将info文件进行分析，告诉服务器需要继续传输的文件节点位置进行续传操作。例如如下面要求从 1526118 字节开始：

GET http://ozcte1ybf.bkt.clouddn.com/level5.mp4 HTTP/1.0
User-Agent: Mozilla/5.0 (Windows NT 6.3; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/63.0.3239.84 Safari/537.36
RANGE: bytes=1526118-
Accept: text/html, image/gif, image/jpeg, *; q=.2, */*; q=.2
这里多了一行 RANGE: bytes=1526118- 

这一行的意思就是告诉服务器level5.mp4这个文件从 1526118 字节开始传，前面的字节不用传了。 服务器收到这个请求以后，返回的信息如下： 

206
Content-Length=15261183
Content-Range=bytes 1526118-15261182/15261183
Date=Wed, 27 Dec 2017 09:17:07 GMT
ETag="A1A1A8B84E5C2F5E7A16E0886721419E"
Content-Type=application/octet-stream
Server=Tengine
Last-Modified=Sun, 22 Jan 2017 15:13:55 GMT

返回的信息增加了一行： Content-Range=bytes 1526118-15261182/15261183

返回的代码也变成 206 ，而不再是 200 了。知道了这些原理，就可以进行断点续传的编程了。

注：206状态码含义：
206 Partial Content

具体代码

主要用了 6 个类，包括一个测试类：
SiteFileFetch.java         负责整个文件的抓取，控制内部线程 (FileSplitterFetch 类 )。 
FileSplitterFetch.java   负责部分文件的抓取。 
FileAccess.java             负责文件的存储。 
SiteInfoBean.java         要抓取的文件的信息，如文件保存的目录，名字，抓取文件的 URL 等。 
Utility.java                    工具类，放一些简单的方法。

TestMethod.java          测试类。

FileAccess.java

package fileHandling;import java.io.IOException;
import java.io.RandomAccessFile;
import java.io.Serializable;/*** * 负责文件的存储* @author yunlingfly* @since 2018-3-11* */
public class FileAccess implements Serializable {private static final long serialVersiOnUID= -6335788938054788024L;RandomAccessFile oSavedFile;long nPos;public FileAccess() throws IOException {this("", 0);}public FileAccess(String sName, long nPos) throws IOException {oSavedFile = new RandomAccessFile(sName, "rw");this.nPos = nPos;oSavedFile.seek(nPos);}public synchronized int write(byte[] b, int nStart, int nLen) {int n = -1;try {oSavedFile.write(b, nStart, nLen);n = nLen;} catch (IOException e) {e.printStackTrace();}return n;}}

FileSplitterFetch.java

package fileHandling;import java.io.IOException;
import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.URL;/*** * 负责部分文件的抓取* @author yunlingfly* @since 2018-3-11*/
public class FileSplitterFetch extends Thread {// File URLString sURL;// File Snippet Start Positionlong nStartPos;// File Snippet End Positionlong nEndPos;// Thread&＃39;s IDint nThreadID;// Downing is overboolean bDownOver = false;// Stop identicalboolean bStop = false;// File Access interfaceFileAccess fileAccessI = null;public FileSplitterFetch(String sURL, String sName, long nStart, long nEnd, int id) throws IOException {this.sURL = sURL;this.nStartPos = nStart;this.nEndPos = nEnd;nThreadID = id;fileAccessI = new FileAccess(sName, nStartPos);}public void run() {while (nStartPos 0 && nStartPos

SiteFileFetch.java

package fileHandling;import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.HttpURLConnection;
import java.net.URL;/*** * 负责整个文件的抓取，控制内部线程(FileSplitterFetch类)* * @author yunlingfly* @since 2018-3-11*/
public class SiteFileFetch extends Thread {// 文件信息BeanSiteInfoBean siteInfoBean = null;// 开始位置long[] nStartPos;// 结束位置long[] nEndPos;// 子线程对象FileSplitterFetch[] fileSplitterFetch;// 文件长度long nFileLength;// 是否第一次取文件boolean bFirst = true;// 停止标志boolean bStop = false;// 文件下载的临时信息File tmpFile;// 输出到文件的输出流DataOutputStream output;public SiteFileFetch(SiteInfoBean bean) throws IOException {siteInfoBean = bean;// tmpFile = File.createTempFile ("zhong","1111",new// File(bean.getSFilePath()));tmpFile = new File(bean.getSFilePath() + File.separator + bean.getSFileName() + ".info");if (tmpFile.exists()) {bFirst = false;read_nPos();} else {nStartPos = new long[bean.getNSplitter()];nEndPos = new long[bean.getNSplitter()];}}public void run() {// 获得文件长度// 分割文件// 实例FileSplitterFetch// 启动FileSplitterFetch线程// 等待子线程返回try {if (bFirst) {nFileLength = getFileSize();if (nFileLength == -1) {System.err.println("File Length is not known!");} else if (nFileLength == -2) {System.err.println("File is not access!");} else {for (int i = 0; i = 400) {processErrorCode(responseCode);return -2; // -2 represent access is error}String sHeader;for (int i = 1;; i++) {// DataInputStream in = new// DataInputStream(httpConnection.getInputStream ());// Utility.log(in.readLine());sHeader = httpConnection.getHeaderFieldKey(i);if (sHeader != null) {if (sHeader.equals("Content-Length")) {nFileLength = Integer.parseInt(httpConnection.getHeaderField(sHeader));break;}} elsebreak;}} catch (IOException e) {e.printStackTrace();} catch (Exception e) {e.printStackTrace();}Utility.log(nFileLength);return nFileLength;}// 保存下载信息（文件指针位置）private void write_nPos() {try {output = new DataOutputStream(new FileOutputStream(tmpFile));output.writeInt(nStartPos.length);for (int i = 0; i

SiteInfoBean.java

package fileHandling;/*** * 要抓取的文件的信息，如文件保存的目录，名字，抓取文件的URL等* * @author yunlingfly* @since 2018-3-11*/
public class SiteInfoBean {// Site&＃39;s URLprivate String sSiteURL;// Saved File&＃39;s Pathprivate String sFilePath;// Saved File&＃39;s Nameprivate String sFileName;// Count of Splited Downloading Fileprivate int nSplitter;public SiteInfoBean() {// default value of nSplitter is 5this("", "", "", 5);}public SiteInfoBean(String sURL, String sPath, String sName, int nSpiltter) {sSiteURL = sURL;sFilePath = sPath;sFileName = sName;this.nSplitter = nSpiltter;}public String getSSiteURL() {return sSiteURL;}public void setSSiteURL(String value) {sSiteURL = value;}public String getSFilePath() {return sFilePath;}public void setSFilePath(String value) {sFilePath = value;}public String getSFileName() {return sFileName;}public void setSFileName(String value) {sFileName = value;}public int getNSplitter() {return nSplitter;}public void setNSplitter(int nCount) {nSplitter = nCount;}}

Utility.java

package fileHandling;/*** * 工具类，日志处理，线程等待* @author yunlingfly* @since 2018-3-11*/
public class Utility {public Utility() {}public static void sleep(int nSecond) {try {Thread.sleep(nSecond);} catch (Exception e) {e.printStackTrace();}}public static void log(String sMsg) {System.err.println(sMsg);}public static void log(int sMsg) {System.err.println(sMsg);}}

测试运行类TestJframe.java

package fileHandling;import java.awt.BorderLayout;
import java.awt.EventQueue;import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.border.EmptyBorder;
import java.awt.GridLayout;
import javax.swing.JLabel;
import javax.swing.JTextField;
import javax.swing.JButton;
import java.awt.event.ActionListener;
import java.awt.event.ActionEvent;/*** * 界面展示* @author yunlingfly* @since 2018-3-11* */
public class TestJframe extends JFrame {private static final long serialVersiOnUID= -2866562095512884191L;private JPanel contentPane;private JTextField textField;private SiteFileFetch fileFetch;/*** Launch the application.*/public static void main(String[] args) {EventQueue.invokeLater(new Runnable() {public void run() {try {TestJframe frame = new TestJframe();frame.setVisible(true);} catch (Exception e) {e.printStackTrace();}}});}/*** Create the frame.*/public TestJframe() {// 设置标题setTitle("桌面断点下载程序");// JFrame关闭后退出。setDefaultCloseOperation(EXIT_ON_CLOSE);// JFrame可见。setVisible(true);// 设置JFrame的长和宽。setSize(800, 500);// 设置JFrame是否可以改变大小。setResizable(false);// JFrame打开后居中。setLocationRelativeTo(getOwner());setDefaultCloseOperation(EXIT_ON_CLOSE);// 如果没有这句，界面关闭后程序的内存没有清空。当然也可以用// setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);// setBounds(400, 100, 600, 400);cOntentPane= new JPanel();contentPane.setBorder(new EmptyBorder(5, 5, 5, 5));contentPane.setLayout(new BorderLayout(0, 0));setContentPane(contentPane);JPanel panel = new JPanel();contentPane.add(panel, BorderLayout.CENTER);panel.setLayout(new GridLayout(3, 1, 0, 0));JPanel panel_1 = new JPanel();panel.add(panel_1);JLabel label = new JLabel("请输入下载的文件名：");panel_1.add(label);textField = new JTextField();panel_1.add(textField);textField.setColumns(10);JPanel panel_2 = new JPanel();panel.add(panel_2);JButton button = new JButton("下载");// 编写下载按钮事件button.addActionListener(new ActionListener() {public void actionPerformed(ActionEvent e) {System.out.println("开始下载");// 根据需要可以在这里添加选择下载的文件夹和保存名称,比如使用JFileChooser等String fileName = textField.getText();download(fileName);}});panel_2.add(button);JButton button_1 = new JButton("暂停");// 编写暂停按钮事件button_1.addActionListener(new ActionListener() {public void actionPerformed(ActionEvent e) {System.out.println("暂停...");// 停止下载文件fileFetch.siteStop();}});panel_2.add(button_1);JButton button_2 = new JButton("恢复");button_2.addActionListener(new ActionListener() {public void actionPerformed(ActionEvent e) {// 从断点继续下载,由于该性质,根据文件名(下载任务号)使得可以断点下载不同的文件,即多任务可选择性优先下载某个文件String fileName = textField.getText();download(fileName);}});panel_2.add(button_2);JPanel panel_3 = new JPanel();panel.add(panel_3);JLabel lblfly = new JLabel("该测试程序由芸灵fly编写");panel_3.add(lblfly);}public void download(String fileName) {try {// 从服务器取文件，根据需要可以将fileName换成url来更换下载地址前缀（这里默认从笔者的服务器下东西）// 存到D:\\shudian，命名和下载的文件名一致，开启10个线程// SiteInfoBean(下载地址,保存位置,保存文件名,开启线程数)四个参数SiteInfoBean bean = new SiteInfoBean("http://ozcte1ybf.bkt.clouddn.com/" + fileName, "D:\\shudian",fileName, 10);fileFetch = new SiteFileFetch(bean);fileFetch.start();} catch (Exception e) {e.printStackTrace();}}
}

运行结果：