没有合适的资源?快使用搜索试试~ 我知道了~
温馨提示
试读
22页
运用socket进行断点续传; 1 从客户端读取版本及服务器地址等信息 2 通过webservice将本地版本号与服务器版本号进行比对,如果服务器发布的版本号大于客户端版本号,则从服务器查找要更新的文件。 3 启动主线程,根据线程个数划分每个线程的下载范围。 4启动下载子线程开始下载,子线程将下载的数据量调用统计类进行累计。 4 通过下载统计类得到下载信息,包括下载速度、下载量、剩余时间估计、完成百分比等等。 5 通过下载信息存档类定时将下载信息写入磁盘,作为断点续传的基础。
资源推荐
资源详情
资源评论
支持断点续传 java 多线程下载
2008 年 07 月 01 日 星期二 12:55
最近一个项目有个非 B/S 也非 C/S 架构的离线申报系统,这个系统涉及到版本
更新。没做过多线程下载,所以看了一些例子,结果都比较让人失望,有个多
线程下载的例子是启动两个线程下载两个文件,倒,当时差点打 110 了。还有
些例子也不完整,完整的能下载,但下载的文件打不开,没办法,还是自己来
了。
界面预览
先说下思路吧
主要类包括
DownInfo.java 线程下载信息类
DownloadFrame.java 下载界面
DownloadHis.java 下载历史记录,定时记录下载信息,为断点续传提供基础
DownloadMain.java 下载主线程
DownloadStat.java 下载信息统计类
DownThread.java 下载子线程
ResponseCode.java response 响应编码
UpdateService.java 更新服务类,用于读取本地版本信息,服务器更新信息,
该类需要自己实现
1 从客户端读取版本及服务器地址等信息
2 通过 webservice 将本地版本号与服务器版本号进行比对,如果服务器发布的
版本号大于客户端版本号,则从服务器查找要更新的文件。
3 启动主线程,根据线程个数划分每个线程的下载范围。
4 启动下载子线程开始下载,子线程将下载的数据量调用统计类进行累计。
4 通过下载统计类得到下载信息,包括下载速度、下载量、剩余时间估计、完
成百分比等等。
5 通过下载信息存档类定时将下载信息写入磁盘,作为断点续传的基础。
源码如下:
1 从客户端读取版本及服务器地址等信息
2 通过 webservice 将本地版本号与服务器版本号进行比对,如果服务器发布的
版本号大于客户端版本号,则从服务器查找要更新的文件。
3 启动主线程,根据线程个数划分每个线程的下载范围。
4 启动下载子线程开始下载,子线程将下载的数据量调用统计类进行累计。
4 通过下载统计类得到下载信息,包括下载速度、下载量、剩余时间估计、完
成百分比等等。
5 通过下载信息存档类定时将下载信息写入磁盘,作为断点续传的基础。
源码如下:
1 从客户端读取版本及服务器地址等信息
2 通过 webservice 将本地版本号与服务器版本号进行比对,如果服务器发布的
版本号大于客户端版本号,则从服务器查找要更新的文件。
3 启动主线程,根据线程个数划分每个线程的下载范围。
4 启动下载子线程开始下载,子线程将下载的数据量调用统计类进行累计。
4 通过下载统计类得到下载信息,包括下载速度、下载量、剩余时间估计、完
成百分比等等。
5 通过下载信息存档类定时将下载信息写入磁盘,作为断点续传的基础。
源码如下:
/**
* 线程下载信息
* @author zean
*/
public class DownInfo
{
private String threadId;//线程 id
private BigDecimal startPos=new BigDecimal(0);//开始位置,随着下载增长
private BigDecimal endPos=new BigDecimal(0);//结束位置
public DownInfo(String threadId, long startPos, long endPos)
{
this.threadId=threadId;
this.startPos = new BigDecimal(startPos);
this.endPos = new BigDecimal(endPos);
}
public long getStartPos()
{
return startPos.longValue();
}
public long getEndPos()
{
return endPos.longValue();
}
public void updateStartPos(long size)
{
this.startPos =startPos.add(new BigDecimal(size));
}
public String getThreadId()
{
return threadId;
}
public void setThreadId(String threadId)
{
this.threadId = threadId;
}
}
Java 实例:利用 java 多线程断点续传实践
2010-07-19 12:22
/**
* author:annegu
* date:2009-07-16
*/
annegu 做了一个简单的 Http 多线程的下载程序,来讨论一下多线程并
发下载以及断点续传的问题。
这个程序的功能,就是可以分多个线程从目标地址上下载数据,每个线程
负责下载一部分,并可以支持断点续传和超时重连。
下载的方法是 download(),它接收两个参数,分别是要下载的页面的 url
和编码方式。在这个负责下载的方法中,主要分了三个步骤。第一步是用来设
置断点续传时候的一些信息的,第二步就是主要的分多线程来下载了,最后是
数据的合并。
1、多线程下载:
/** *//** http://www.bt285.cn
http://www.5a520.cn
*/
public String download(String urlStr, String
charset) {
this.charset = charset;
long contentLength = 0;
CountDownLatch latch = new
CountDownLatch(threadNum);
long[] startPos = new long[threadNum];
long endPos = 0;
try {
// 从 url 中获得下载的文件格式与名字
this.@leName =
urlStr.substring(urlStr.lastIndexOf("/") + 1);
this.url = new URL(urlStr);
URLConnection con = url.openConnection();
setHeader(con);
// 得到 content 的长度
contentLength = con.getContentLength();
// 把 context 分为 threadNum 段的话,每段的
长度。
this.threadLength = contentLength /
threadNum;
// 第一步,分析已下载的临时文件,设置断点,如
果是新的下载任务,
则建立目标文件。在第 4 点中说明。
startPos = setThreadBreakpoint(@leDir,
@leName, contentLength, startPos);
//第二步,分多个线程下载文件
ExecutorService exec =
Executors.newCachedThreadPool();
for (int i = 0; i < threadNum; i++) {
// 创建子线程来负责下载数据,每段数据的起
始位置为
(threadLength * i + 已下载长度)
startPos[i] += threadLength * i;
/**//*设置子线程的终止位置,非最后一个线程
即为(threadLength * (i + 1) - 1)
最后一个线程的终止位置即为下载内容的长度*/
if (i == threadNum - 1) {
endPos = contentLength;
} else {
endPos = threadLength * (i + 1) - 1;
}
// 开启子线程,并执行。
ChildThread thread = new
ChildThread(this, latch, i, startPos[i], endPos);
childThreads[i] = thread;
exec.execute(thread);
}
try {
// 等待 CountdownLatch 信号为 0,表示所有
子线程都结束。
latch.await();
exec.shutdown();
// 第三步,把分段下载下来的临时文件中的内
容写入目标文件中。在第 3 点中说明。
tempFileToTargetFile(childThreads);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
在 ChildThread 的构造方法中,除了设置一些从主线程中带来的 id, 起始
位置之外,就是新建了一个临时文件用来存放当前线程的下载数据。临时文件
的命名规则是这样的:下载的目标文件名+”_”+线程编号。
现在让我们来看看从网络中读数据是怎么读的。我们通过
URLConnection 来获得一个 http 的连接。有些网站为了安全起见,会对请求
的 http 连接进行过滤,因此为了伪装这个 http 的连接请求,我们给
httpHeader 穿一件伪装服。下面的 setHeader 方法展示了一些非常常用的典
型的 httpHeader 的伪装方法。比较重要的有:Uer-Agent 模拟从 Ubuntu 的
@refox 浏览器发出的请求;Referer 模拟浏览器请求的前一个触发页面,例如
从 skycn 站点来下载软件的话,Referer 设置成 skycn 的首页域名就可以了;
Range 就是这个连接获取的流文件的起始区间。
剩余21页未读,继续阅读
vito1144
- 粉丝: 0
- 资源: 2
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功
- 1
- 2
前往页