这里需要用到一个类RandomAccessFile,下面是JDK里面对此类的描述!
此类的实例支持对随机访问文件的读取和写入。随机访问文件的行为类似存储在文件系统中的一个大型 byte 数组。存在指向该隐含数组的光标或索引,称为文件指针;输入操作从文件指针开始读取字节,并随着对字节的读取而前移此文件指针。如果随机访问文件以读取/写入模式创建,则输出操作也可用;输出操作从文件指针开始写入字节,并随着对字节的写入而前移此文件指针。写入隐含数组的当前末尾之后的输出操作导致该数组扩展。该文件指针可以通过 getFilePointer
方法读取,并通过 seek
方法设置。
通常,如果此类中的所有读取例程在读取所需数量的字节之前已到达文件末尾,则抛出 EOFException
(是一种 IOException
)。如果由于某些原因无法读取任何字节,而不是在读取所需数量的字节之前已到达文件末尾,则抛出 IOException
,而不是 EOFException
。需要特别指出的是,如果流已被关闭,则可能抛出 IOException
。
该类有两个构造方法RandomAccessFile(File file/String name,String mode);
其中Mode如下表
r | 以只读方式打开。调用结果对象的任何 write 方法都将导致抛出 IOException |
rw | 打开以便读取和写入。如果该文件尚不存在,则尝试创建该文件 |
rws | 打开以便读取和写入,对于 "rw",还要求对文件的内容或元数据的每个更新都同步写入到底层存储设备 |
rwd | 打开以便读取和写入,对于 "rw",还要求对文件内容的每个更新都同步写入到底层存储设备 |
下面是一个实例:
public class MulThreadDownLoad { public static void main(String[] args) { String path = "http://localhost:4484/WebSite1/21.bmp";// 一个本地web服务,指向一张图片 try { new MulThreadDownLoad().download(path, 3); } catch (Exception e) { e.printStackTrace(); } } private void download(String path, int threadsize) throws Exception { URL url = new URL(path); HttpURLConnection conn = (HttpURLConnection) url.openConnection(); conn.setConnectTimeout(5000); conn.setRequestMethod("GET"); if (conn.getResponseCode() == 200) { int length = conn.getContentLength(); File file = new File(getFilename(path)); RandomAccessFile accessFile = new RandomAccessFile(file, "rwd"); // 在本地生成一个长度为length的文件 accessFile.setLength(length); accessFile.close(); // 每条线程负责下载的数据量 int block = length / threadsize == 0 ? length / threadsize : length / threadsize + 1; for (int threadid = 0; threadid < threadsize; threadid++) { new Thread(new Runa(threadid, block, url, file)).start(); } } else System.out.println(conn.getResponseCode() + ""); } private class Runa implements Runnable { private int threadid; private int block; private URL url; private File file; public Runa(int threadid, int block, URL url, File file) { this.threadid = threadid; this.block = block; this.url = url; this.file = file; } @Override public void run() { int start = threadid * block;// 计算该线程从网络文件的什么位置开始下载 int end = (threadid + 1) * block - 1;// 计算该线程下载网络文件的结束位置 try { RandomAccessFile accessFile = new RandomAccessFile(file, "rwd");// 创建从中读取和向其中写入(可选)的随机访问文件流 accessFile.seek(start); HttpURLConnection conn = (HttpURLConnection) url.openConnection(); conn.setConnectTimeout(5000); conn.setRequestMethod("GET"); conn.setRequestProperty("Range", "bytes=" + start + "-" + end);// 设置从start开始下载,到end结束 // if (conn.getResponseCode() == 200) { // 如果是分段下载,请求状态码不是200而是206! InputStream ins = conn.getInputStream(); byte[] buffer = new byte[1024]; int length = 0; while ((length = ins.read(buffer)) != -1) { accessFile.write(buffer, 0, length); } accessFile.close(); ins.close(); // } } catch (Exception e) { e.printStackTrace(); } } } private String getFilename(String path) { return path.substring(path.lastIndexOf("/") + 1); } }
下面是多线程下载原理图
Android和JavaEE中,多线程下载原理相同。
转载于:https://www.cnblogs.com/a284628487/archive/2013/04/20/3033175.html
发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/110156.html原文链接:https://javaforall.cn
【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛
【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...