多线程断点下载原理(java代码实例演示) - 新闻资讯 - 云南小程序开发|云南软件开发|云南网站建设-昆明葵宇信息科技有限公司

159-8711-8523

云南网建设/小程序开发/软件开发

知识

不管是网站,软件还是小程序,都要直接或间接能为您产生价值,我们在追求其视觉表现的同时,更侧重于功能的便捷,营销的便利,运营的高效,让网站成为营销工具,让软件能切实提升企业内部管理水平和效率。优秀的程序为后期升级提供便捷的支持!

您当前位置>首页 » 新闻资讯 » 技术分享 >

多线程断点下载原理(java代码实例演示)

发表时间:2020-10-19

发布人:葵宇科技

浏览次数:27


      其实多线程断点下载道理,很简单的,那么我们就来先懂得下,若何实现多线程的断点下载,起首:你必须明白第一点,那么就是,什么是多线程下载,该常识点可以查看本博客上一篇文┞仿,Android之多线程下载道理,断点下载呢,其实就是在这个的基本之上添加了一些器械,那么添加了什么器械了,如今来做一个具体的懂得。
1.鄙人载的过程中,边下载,变用一个文件来记录下载的地位,也就是下载了若干的数据
1.创建文件
2.记录下载若干瘪据
3.存储数据
2.第二次下载的时刻,就去攫取文件中是否存稀有据,攫取前次下载的地位,作为此次开端下载的地位
1.创建文件对象
2.考验是否有次文件和文件琅绫擎是否稀有据
3.攫取数据,将数据拿给此次的开端地位,也就是大年夜这个数据这里开端下载
3.文件下载完成之后,将记录的文件删除,必定要下载完成之后,在将文件删除,不然会彪炳一些异常,比如,此次文件没了,就要从新开端下载等等
4.以上说了这些是不是稍微明白了些,那么下面来看看真正的实践吧
package com.zengtao.demo;
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("文件下载完毕,删除记录文件"); ---------------------------------------------------------------------
}
}
}
}
}

相关案例查看更多