java多线程断点下载原理(代码实例演示)
g3mc
10年前
其实多线程断点下载原理,很简单的,那么我们就来先了解下,如何实现多线程的断点下载,首先:你必须明白第一点,那么就是,什么是多线程下载,该知识点可以查看本博客上一篇文章,Android之多线程下载原理,断点下载呢,其实就是在这个的基础之上添加了一些东西,那么添加了什么东西了,现在来做一个详细的了解。
1.在下载的过程中,边下载,变用一个文件来记录下载的位置,也就是下载了多少的数据
1.创建文件
2.记录下载多少数据
3.存储数据
2.第二次下载的时候,就去读取文件中是否存有数据,读取上次下载的位置,作为这次开始下载的位置
1.创建文件对象
2.检验是否有次文件和文件里面是否有数据
3.读取数据,将数据拿给这次的开始位置,也就是从这个数据这里开始下载
3.文件下载完成之后,将记录的文件删除,一定要下载完成之后,在将文件删除,不然会跳出一些异常,比如,这次文件没了,就要重新开始下载等等
4.以上说了这些是不是稍微明白了些,那么下面来看看真正的实践吧
示例源码:
import java.io.File; import java.io.FileInputStream; import java.io.InputStream; import java.io.RandomAccessFile; import java.net.HttpURLConnection; import java.net.URL; /** * 文件下载器 * * @author Administrator zengtao * */ public class DemoLoader { private static DemoLoader loader = new DemoLoader(); private static int threadCount = 3; private static int runningThread = 3; private DemoLoader() { } public static DemoLoader getInstance() { return loader; } /** * 去服务器端下载文件 * * @param path * 服务器地址 */ public void downFile(String path) { // 去服务器端获取文件的长度,在本地创建一个跟服务器一样大小的文件 try { URL url = new URL(path); HttpURLConnection connection = (HttpURLConnection) url .openConnection(); connection.setDoInput(true); connection.setRequestMethod("GET"); connection.setReadTimeout(5000); int code = connection.getResponseCode(); if (code == 200) { // 1.获取服务器端文件的长度 int fileLength = connection.getContentLength(); // 2.本地创建一个跟服务器一样大小的文件 RandomAccessFile raf = new RandomAccessFile("setup.exe", "rwd"); raf.setLength(fileLength); raf.close(); // 3.假设三个线程下载 int blockSize = fileLength / threadCount; for (int threadId = 0; threadId < threadCount; threadId++) { int startIndex = (threadId - 1) * blockSize; int endIndex = threadId * blockSize - 1; if (threadId == threadCount) { endIndex = fileLength; } // log 假设下载 System.out.println("假设线程:" + threadId + ",下载:" + startIndex + "--->" + endIndex); // 4.开始下载 new DownLoadThread(threadId, startIndex, endIndex, path) .start(); } System.out.println("文件总长度为:" + fileLength); } else { System.out.println("请求失败!"); } } catch (Exception e) { e.printStackTrace(); } } /** * 下载文件的线程 * * @author Administrator zengtao * */ public class DownLoadThread extends Thread { private int threadId; private int startIndex; private int endIndex; private String path; /** * * @param threadId * 线程id * @param startIndex * 线程下载开始位置 * @param endIndex * 线程下载结束位置 * @param path * 线程下载结束文件放置地址 */ public DownLoadThread(int threadId, int startIndex, int endIndex, String path) { super(); this.threadId = threadId; this.startIndex = startIndex; this.endIndex = endIndex; this.path = path; } @Override public void run() { super.run(); try { // 1.检验是否有存的记录 ------------------------------------------------------------------------------------------------- File file = new File(threadId + ".txt"); if (file.exists() && file.length() > 0) { FileInputStream fis = new FileInputStream(file); byte[] temp = new byte[1024]; int leng = fis.read(temp); String loadLength = new String(temp, 0, leng); int load = Integer.parseInt(loadLength); startIndex = load; fis.close(); } URL url = new URL(path); HttpURLConnection connection = (HttpURLConnection) url .openConnection(); // 2.请求服务器下载部分的文件,制定开始的位置,和结束位置 connection.setRequestProperty("Range", "bytes=" + startIndex + "-" + endIndex); // log 真实下载 System.out.println("真实线程:" + threadId + ",下载:" + startIndex + "--->" + endIndex); connection.setDoInput(true); connection.setRequestMethod("GET"); connection.setReadTimeout(5000); // 3.从服务器获取的全部数据,返回:200,从服务器获取部分数据,返回:206 int code = connection.getResponseCode(); System.out.println("code = " + code); InputStream is = connection.getInputStream(); RandomAccessFile raf = new RandomAccessFile("setup.exe", "rwd"); raf.seek(startIndex); // 随机写文件的时候,从什么时候开始 int len = 0; int total = 0; // 记录下载多少 ----------------------------------------- byte[] buff = new byte[1024]; while ((len = is.read(buff)) != -1) { RandomAccessFile info = new RandomAccessFile(threadId + ".txt", "rwd"); raf.write(buff, 0, len); total += len; info.write(("" + startIndex + total).getBytes()); // 4.存数据:(真正下载到开始的位置)下载的+开始的---------------------------------------- info.close(); } is.close(); raf.close(); System.out.println("线程:" + threadId + ",下载完成"); } catch (Exception e) { e.printStackTrace(); } finally { // 5.notice一定要文件都下载完毕之后再将记录文件删除 runningThread--; if (runningThread == 0) { for (int i = 1; i <= threadCount; i++) { File file = new File(i + ".txt"); file.delete(); } System.out.println("文件下载完毕,删除记录文件"); --------------------------------------------------------------------- } } } } }