Android 多线程下载网络文件

Android 多线程下载网络文件

这里需要用到一个类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 多线程下载网络文件

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账号...

(0)


相关推荐

  • c语言调用bool函数,C语言中 bool的用法

    c语言调用bool函数,C语言中 bool的用法布尔型(bool)变量的值只有真(true)和假(false)。布尔型变量可用于逻辑表达式,也就是“或”“与”“非”之类的逻辑运算和大于小于之类的关系运算,逻辑表达式运算结果为真或为假。bool可用于定义函数类型为布尔型,函数里可以有returnTRUE;returnFALSE之类的语句。布尔型运算结果常用于条件语句:if(逻辑表达式){如果是true执行这里;}else{…

  • 时限调度算法给出的调度顺序_时间片轮转法进行进程调度

    时限调度算法给出的调度顺序_时间片轮转法进行进程调度调度算法-时间轮一.背景在我们的业务场景中,经常会使用到定时任务功能,比如定时发送消息,定时执行数据同步,比如之前的文章介绍的分布式事务中的本地事务表方式的解决方案等等,特别是在现在大数据量和分布式服务环境下,定时任务调度越来越频繁,所以对应的定时任务调度的算法实现也越来越完善。在之前的单机环境下,我们可以使用ScheduledThreadPool起一个延迟任务线程池,定时的执行任务,又或者使用spring提供的@Schedule注解配合上cron表达式开启一个定时任务,又或者是lin

  • INSERT INTO SELECT语句与SELECT INTO FROM语句区别

    INSERT INTO SELECT语句与SELECT INTO FROM语句区别1.INSERTINTOSELECT语句语句形式为:InsertintoTable2(field1,field2,…)selectvalue1,value2,…fromTable1或者:InsertintoTable2select*fromTable1注意:(1)要求目标表Table2必须存在,并且字段field,field2…也必须存在(2)注意Table2的主

  • 中石化面试题java,中石化面试经验

    中石化面试题java,中石化面试经验面试过程:应聘途径:社会招聘面试内容:1对1面试面试难度:简单面试感觉:一般面试官提的问题:到了面试那里,像上次那样在会议室等着。大概有四、五十人左右吧,分成了几组人,第一组人先去做性格测评,说要八十分钟左右,其他人在等,说那些领导在开会,商议面试的事宜。领导开会开到十一点半才出来,宣讲一下相关内容,结果把一些还没做完测试的人拉了下来。宣讲完,那些做完测试的人就先去面试,因为估计不到什么时候才面完…

    2022年10月15日
  • jmeter-http代理服务器,录制脚本,抓包-包含模式,过滤指定域名(url)数据

    jmeter-http代理服务器,录制脚本,抓包-包含模式,过滤指定域名(url)数据

  • phpstorm2021 4月永久激活码_通用破解码

    phpstorm2021 4月永久激活码_通用破解码,https://javaforall.cn/100143.html。详细ieda激活码不妨到全栈程序员必看教程网一起来了解一下吧!

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号