- 浏览: 933184 次
- 性别:
- 来自: 魔都
文章分类
- 全部博客 (745)
- MultiThread (19)
- My Plan (118)
- JavaBasic (61)
- MyInterview (104)
- InternetTechnique (5)
- ProjectConclusion (1)
- Maven (5)
- MogoDb (5)
- Hadoop (11)
- Memcached (6)
- TechniqueCollect (1)
- Ibaits (1)
- Android (34)
- ItLife (40)
- Tree (2)
- ProjectArchitect (7)
- Open Source (3)
- liunx (5)
- socket (8)
- Spring (27)
- DesginPattern (35)
- WebBasic (13)
- English (13)
- structs (1)
- structs2 (2)
- Oracle (17)
- Hibernate (2)
- JavaScript (4)
- Jdbc (1)
- Jvm (15)
- Ibatis (1)
- DataStructures (13)
- Https/Socket/Tcp/Ip (3)
- Linux (4)
- Webservice (7)
- Io (2)
- Svn (1)
- Css (1)
- Ajax (1)
- ExtJs (1)
- UML (2)
- DataBase (6)
- BankTechnique (3)
- SpringMvc (3)
- Nio (3)
- Load Balancing/Cluster (3)
- Tools (1)
- javaPerformanceOptimization (8)
- Lucene(SEO) (1)
- My Think (80)
- NodeJs (1)
- Quartz (1)
- Distributed-java (1)
- MySql (7)
- Project (4)
- junit (4)
- framework (1)
- enCache (1)
- git (2)
- SCJP (1)
- sd (1)
最新评论
-
lkjxshi:
你都这水平了还考这个证干嘛
SCJP 认证考试指南 -
钟逸华:
问的真多
百度java开发面试题(转) -
zuimeitulip:
觉得我就是这样的,从小阅读量就很少,导致现在的读的速度非常慢, ...
让读书成为一种习惯 -
DDT_123456:
我觉得你是不符合要求。问你hashmap的那个问题,你那样回答 ...
阿里面试2(转) -
jingjing0907:
刚刚写了很多读过此博客的感受,竟然没有发上去,以为我注册账号还 ...
让读书成为一种习惯
在android下面的断点续传和java下面没有太大的冲突,就是在配置文件里面加上一些特定的访问权限就可以了 如下式在AndroidManifest.xml加入的权限 <!-- 访问internet权限 --> <uses-permission android:name="android.permission.INTERNET" /> <!-- 在SDCard中创建与删除文件权限--> <uses-permission android:name="android.permission.MOUNT_UNMOUNT_FILESYSTEMS" /> <!-- 往SDCard写入数据权限--> <uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE" /> 这个准备工作做好了就可以直接编码了 第一步创建multiThreaddownload.java package com.cn.download; import java.io.File; import java.io.FileInputStream; import java.io.InputStream; import java.io.RandomAccessFile; import java.net.URL; import java.net.URLConnection; import com.cn.coocaa.download.FileDownloadThread; public class MultiThreadDownload extends Thread { //定义的一些常量变量,看名字就知道什么意思了 private static final int BUFFER_SIZE = 1024; private int blockSize; private int threadNum = 5; private int fileSize; private int downloadedSize; String urlStr, threadNo, fileName; private String savePath; private int downloadPercent = 0 , downloadSpeed = 0, usedTime=0; private long startTime,curTime; private boolean completed = false; //用URL,保存路径,保存名称来构造。 public MultiThreadDownload(String URL, String savePath, String fileName) { this.urlStr = URL; this.savePath = savePath; this.fileName = fileName; } @Override public void run() { FileDownloadThread[] fds = new FileDownloadThread[threadNum]; try { URL url = new URL(urlStr); URLConnection conn = url.openConnection(); fileSize = conn.getContentLength(); blockSize = fileSize / threadNum; File file[] = new File[threadNum]; //根据默认的线程数,或者自己修改设置的线程数来分块,创建分块后的文件块 for (int i = 0; i < threadNum; i++) { file[i] = new File(savePath + fileName + ".part" + String.valueOf(i)); //将分块的文件交给每个线程处理,最后一块应该大于等于平均块,因为可能有余数 FileDownloadThread fdt = new FileDownloadThread(url, file[i], i * blockSize, (i + 1) != threadNum ? ((i + 1) * blockSize - 1) : fileSize); fdt.setName("Thread" + i); fdt.start(); fds[i] = fdt; } startTime = System.currentTimeMillis(); //获取起始下载的时间,用次来计算速度。 boolean finished = false; while (!finished) { downloadedSize = 0; finished = true; for (int i = 0; i < fds.length; i++) { downloadedSize += fds[i].getDownloadSize(); if (!fds[i].isFinished()) { finished = false; } } //计算下载的百分比 downloadPercent = (downloadedSize*100)/fileSize; //获取当前时间,计算平均下载速度 curTime = System.currentTimeMillis(); usedTime =(int)((curTime-startTime)/1000); if(usedTime==0) usedTime =1; downloadSpeed = (downloadedSize/usedTime)/1024; sleep(1000); } //这个是分块下载完成的标志 completed = true; //进行模块整合 RandomAccessFile raf = new RandomAccessFile(savePath + fileName, "rw"); byte[] tempbytes = new byte[BUFFER_SIZE]; InputStream in = null; int byteread = 0; for (int i = 0; i < threadNum; i++) { in = new FileInputStream(file[i]); while ((byteread = in.read(tempbytes)) != -1) { raf.write(tempbytes, 0, byteread); } //每次整合完一块就删除一块。 in.close(); file[i].delete(); } raf.close(); } catch (Exception e) { // TODO: handle exception } } //获取下载百分比 public int getDownloadPercent(){ return this.downloadPercent; } //获取下载速度 public int getDownloadSpeed(){ return this.downloadSpeed; } //修改默认线程数 public void setThreadNum(int threadNum){ this.threadNum = threadNum; } //分块下载完成的标志 public boolean isCompleted(){ return this.completed; } } 第二步 创建filedownloadthread.java package com.cn.download; import java.io.BufferedInputStream; import java.io.File; import java.io.IOException; import java.io.RandomAccessFile; import java.net.URL; import java.net.URLConnection; public class FileDownloadThread extends Thread { private static final int BUFFER_SIZE = 1024; private URL url; private File file; private int startPosition; private int endPosition; private int curPosition; private boolean finished = false; private int downloadSize = 0; //分块构造函数 public FileDownloadThread(URL url, File file, int startPosition, int endPosition) { this.url = url; this.file = file; this.startPosition = startPosition; this.curPosition = startPosition; this.endPosition = endPosition; } public void run() { BufferedInputStream bis = null; RandomAccessFile fos = null; byte[] buf = new byte[BUFFER_SIZE]; URLConnection con = null; try { //打开URL连接 con = url.openConnection(); con.setAllowUserInteraction(true); //判断是否该文件存在,如果存在且下载完成,直接返回。 if ((file.length() + startPosition) == endPosition) { this.finished = true; } //文件未下载完成,获取到当前指针位置,继续下载。 else { con.setRequestProperty("Range", "bytes=" + (startPosition + file.length()) + "-" + endPosition); fos = new RandomAccessFile(file, "rw"); fos.seek(file.length()); bis = new BufferedInputStream(con.getInputStream()); while (curPosition < endPosition) { int len = bis.read(buf, 0, BUFFER_SIZE); if (len == -1) { break; } fos.write(buf, 0, len); curPosition = curPosition + len; if (curPosition > endPosition) { downloadSize += len - (curPosition - endPosition) + 1; } else { downloadSize += len; } } this.finished = true; bis.close(); fos.close(); } } catch (IOException e) { System.out.println(getName() + " Error:" + e.getMessage()); } } public boolean isFinished() { return finished; } public int getDownloadSize() { return downloadSize; } } 上述两个文件就完成了多线程断点续传。 无需使用任何配置文件或者数据库,就可以接上次的断点进行续传操作。 原理流程: 1、获取文件大小 2、将文件按照所设定的线程数进行分块请求。 3、检查是否存在断点情况,如果有断点情况则进行断点查找,然后再请求。 4、分块下载。 5、下载完成后文件整合,将分块文件删除掉。 6、好了,你需要下载的文件就可以完成了。 总之了,在这里也是一种实现无需配置文件的方式吧,我提供的只是一个外部调用包,所以这个配置文件或者数据库记录的东西有很大的局限性,所以就切割了, 如果有什么更好的想法,希望能相互交流交流。 转载请注明:http://alloxa.blog.51cto.com/
发表评论
-
子线程循环10次,接着主线程循环100,接着又回到子线程循环10次,接着再回到主线程又循环100,如此循环50次,请写出程序。
2013-04-15 14:00 1237public class ThreadTest { ... -
java并发包(java.util.concurrent)
2013-03-26 23:46 1991java并发包(java.util.concurrent) ... -
java 死锁及解决
2013-03-19 22:54 933url:http://leowzy.iteye.com/bl ... -
断点续传的原理
2013-03-08 12:32 1142url:http://www.cnblogs.com/Kil ... -
《java并发编程实践》读书笔记
2012-08-21 23:07 974文章链接:http://www.iteye.com/blogs ... -
ThreadLocal详解
2012-06-27 23:47 939文章链接: http://www.iteye.com/top ... -
多线程并发(java编程思想笔记)
2012-06-25 23:50 24291.Executor,java.util.concurr ... -
多线程例题(空中网)
2012-06-17 19:16 1000文章链接:http://blog.csdn ... -
ArrayBlockingQueue(阻塞队列)
2012-06-17 19:00 1539package cn.itcast.day3.thread; ... -
多线程笔记(黑马)
2012-06-17 18:59 9981.多线程范围内间的线 ... -
设计缓冲系统(多线程)
2012-06-17 18:57 1027package cn.itcast.day3.thread; ... -
Java多线程与并发库高级应用(传智播客)
2012-06-13 15:14 3735------------------------------- ... -
多线程断点续传下载
2012-06-05 20:58 1758package cn.itcast.net.downlo ... -
多线程高新(黑马程序员)
2012-03-30 16:23 1207------------------------------- ... -
生产者/消费者JAVA多线程
2012-03-28 09:58 1033文章链接:http://blog.csdn.net/bnuch ... -
主线程跟子线程怎么通讯 java
2012-03-17 19:24 4598学到多线程,编了一个简单地电脑城进出货模拟系统。 代码有点长 ... -
主线程与子线程之间通讯, 子线程与子线程之间的通讯 Java
2012-03-17 19:19 5351线程之间的通讯可以有两种方法. 一.利用全局变量. 大家都可 ... -
理解多线程
2011-09-27 17:40 846一、理解多线程 多 ...
相关推荐
java 多线程断点续传 java 多线程断点续传 java 多线程断点续传
java多线程断点续传[借鉴].pdf
该程序实现了java的多线程下载,显示下载进度条
java多线程断点续传.pdf
刚刚整理的java断点续传,多线程处理,不知道怎么把多线程去掉
java实现FTP多线程断点续传
1. 把每个下载文件切成若干个块(Block),然后得到一个位图,用来标记每个块的下载情况,并保存到文件里,用于实现断点续传。 2. HTTP Header里增加Range,如果服务器返回Cotent-Range 说明服务器支持文件定位,可以...
这是我java的课程设计。本程序实现类似迅雷的多线程断点续传下载功能,并且有简单的界面,可以显示下载中各个线程的下载状况。 用Eclipse编译一下就能运行了。希望和大家共同学习!
java实现FTP多线程断点续传,上传下载! - java学习与交流 - j2ee学习网 - j2ee学习网 (2012年5月21日) 用 Java 实现断点续传 (HTTP) (2012年5月21日) Java写的支持断点续传的FTP--crybaby的博客 (2012年5月21日) ...
java FTP多线程 批量 断点续传,使用 1.建一个支持多线程FTP服务端; 如:xxftp有Windows和Linux版本; 2.建一个项目导入文件测试;
java相关的 ftp知识 如:ftp服务器、ftp主被动通讯模式、断点续传、单个文件多线程下载
最近研究了一下socket套接字 实现java多线程 断点续传文件 在网上查找了很多例子 然后学习了大家的方法 最后利用网上的例子 自己整合了一份多线程 断点续传文件的代码 并且能实现客户端发送完毕之后 接收服务器端的...
这是java实现多线程断点续传下载功能的源代码,对于学习java网络编程、多线程等基础知识的同学有一定的参考作用,希望能够这个资源能够对你们有帮助
java中http断点续传的实现原理,介绍了主要方法和简单的实现
多线程 断点续传 java 下载 java多线程实例
应用多线程MultiThread断点续传工具类,经典小例子。可运行。
这个是java开发的多线程断点续传下载demo,内有详细注释,是练习android多线程断点续传下载时写的测试demo,下面的android开发的多线程断点续传下载demo是基于这个移植过去的,使用java开发的可以参考这个。
自己为了课程设计写的程序,基于java的多线程断点续传程序
socket做的支持多线程断点上传or断点续传Java源码
Java多线程与线程安全实践-基于Http协议的断点续传 Java多线程与线程安全实践-基于Http协议的断点续传 Java多线程与线程安全实践-基于Http协议的断点续传 Java多线程与线程安全实践-基于Http协议的断点续传 Java多...