HttpURLConnection_浅析情绪管理的方法技巧论文

HttpURLConnection_浅析情绪管理的方法技巧论文前言申请CSDN账号大概是四年前的事情了,想想的确的有点历史久远的感觉,只不过这段历史中,我的博客却是历史空白的,主要原因是,当时只是因为是计算机专业,而沽名钓誉的申请了个高大上的CSDN—中国最大的中文IT社区账号,中间经历了稀里糊涂匆匆大一、稍稍有点叱诧风云、指点江山的给力大二、紧接着铮铮铁骨、血性火热的绿色军营,辗转几个春夏轮回,我又回到了曾几何时的“历史舞台”,重新开始了我“武林秘…

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

前言

申请CSDN账号大概是四年前的事情了,想想的确的有点历史久远的感觉,只不过这段历史中,我的博客却是历史空白的,主要原因是,当时只是因为是计算机专业,而沽名钓誉的申请了个高大上的CSDN—中国最大的中文IT社区账号,中间经历了稀里糊涂匆匆大一、稍稍有点叱诧风云、指点江山的给力大二、紧接着铮铮铁骨、血性火热的绿色军营,辗转几个春夏轮回,我又回到了曾几何时的“历史舞台”,重新开始了我“武林秘籍”的修炼之旅,想想修炼成功之后,能与大神切磋武艺,能与女神技术交流,说不定还能勾搭个妹子,说不定哪天还能得到老板的慧眼识英才,赏赐个黄马褂,赐封个爵位啥的,哈哈~想想还真有点小激动呢~~~

扯的有点远了!现在峰回路转,回到主题。这是我的第一篇原创有关技术的博客,也是我技术学习和分享快乐的开始!同时我也是菜鸟一枚,希望大神们带我一起飞

 

【问题】

关于从网上下载一个文件分多个线程同时下载。

主要使用到HttpURLConnection对象的setRequestProperty(String key,String value);方法

简单说一下如何使用,setRequestProperty()方法严格上讲是HttpURLConnection的父类—URLConnection的方法,而URL.openConnection()返回的是一个URLConnection对象,而一般我们都用他的子类HttpURLConnection去做链接和网络传输工作。

【解决思路总述】

  1. 把指定文件(通过HttpURLConnection.getContentLength();获得文件大小),分成指定线程数下载,或者指定每个线程承担下载任务的大小(再次我们仅以后者分析)
  2. 计算所需线程数
  3. 将获得的数据保存本地(使用RandomAccessFile流存储)

【代码】

package com.wsf.demo;
import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
public class ImageDownload {
    public final static String sate = "http://www.baidu.com/img/bd_logo1.png";//本题所下载的文件是一个百度图标
    public static void main(String[] args) {
        try {
            //创建一个URL对象
            URL url = new URL(sate);
            //建立一个链接
            HttpURLConnection conn = (HttpURLConnection) url.openConnection();
            //制定相应方式
            conn.setRequestMethod("GET");
            //进行连接
            conn.connect();
            //获得响应码
            int code = conn.getResponseCode();
            //获得文件名字
            int position = sate.lastIndexOf("/");
            String fileName = sate.substring(position+1);
            System.out.println("服务器响应码:"+code);
            //如果响应码是200 则链接下载。。。
            if(code == HttpURLConnection.HTTP_OK){
                //获得文件长度
                int contentLength = conn.getContentLength();
                System.out.println("文件总长度:"+contentLength);
                //设定想要启动下载线程,用于把文件分成多少分进行下载
                RandomAccessFile raf = new RandomAccessFile(new File(fileName), "rwd");
                raf.setLength(contentLength);
                raf.close();
                
                //假定每个线程负责下载的长度为1k
                int blockSize = 1024*2;
                //如果能除尽指定线程数  否则线程数+1
                int size = contentLength%blockSize==0 ? contentLength/blockSize : (contentLength/blockSize)+1;
                
                for(int i = 0;i<size;i++){
                    if(i==(size-1)){
                        new DownLoadThread(i, (contentLength-(blockSize*i)), fileName,contentLength).start();
                        System.out.println("启动了第:"+i+"  线程---------------------"+(contentLength-(blockSize*i)));
                        return;
                    }
                    new DownLoadThread(i, blockSize, fileName,(i+1)*blockSize).start();
                    System.out.println("启动了第:"+i+"  线程---------------------"+blockSize);
                }
            }
        } catch (MalformedURLException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}
class DownLoadThread extends Thread{
    private int fileCount;
    private int blockSize;
    private String fileName;
    private int TotalLength;
    
    public DownLoadThread(int fileCount,int blockSize,String fileName,int TotalLength){
        this.fileCount = fileCount;
        this.blockSize = blockSize;
        this.fileName = fileName;
        this.TotalLength= TotalLength;
        
    }
    @Override
    public void run() {
            try {
                URL url = new URL(ImageDownload.sate);
                HttpURLConnection conn = (HttpURLConnection) url.openConnection();
                conn.setRequestMethod("GET");
                conn.setRequestProperty("Range", "bytes="+(TotalLength-blockSize)+"-"+(TotalLength));
                conn.connect();
                System.out.println(fileCount+"开始:"+(TotalLength-blockSize)+",结束:"+TotalLength);
               //多线程同时下载文件,因此要使用随机访问文件流,即同时写入读取,seek(int index)制定存放的位置
                RandomAccessFile raf = new RandomAccessFile(new File(fileName), "rwd");
                raf.seek(TotalLength-blockSize);
                int code = conn.getResponseCode();
                System.out.println(fileCount+">>>Code>>>"+code);
                if(code == HttpURLConnection.HTTP_OK || code == 206){
                    BufferedInputStream bis = new BufferedInputStream(conn.getInputStream());
                    int len = 0;                 
                    byte[]buf = new byte[1024];
                    while((len = bis.read(buf,0,buf.length))!=-1){
                        raf.write(buf, 0, len);
                        System.out.println(fileCount+"下载长度:"+len);
                    }
                    //回收资源
                    raf.close();
                    System.out.println("第"+fileCount+"段下载完毕!!!");
                    return;
                }
                System.out.println("第"+fileCount+"段下载失败!!!");
            } catch (FileNotFoundException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            }
    }
}

 

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/195071.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 自动构建(CICD)

    自动构建(CICD)Docker、Kubernetes的CICD实现思路Jenkins是一个比较流行的持续集成工具GitLab是存储镜像的镜像仓库由客户端将代码push推送到git仓库,gitlab上配置了一个webHook的东西可以触发Jenkins的构建。进入到Jenkins虚线范围内,它所做的事情非常多,从mvn构建代码,对代码进行静态分析,做单元测试,测试通过之后就可以build镜像,镜像构建成功后…

  • django配置文件详解_pycharm配置django

    django配置文件详解_pycharm配置django前言django框架的日志通过python内置的logging模块实现的,既可以记录自定义的一些信息描述,也可以记录系统运行中的一些对象数据,还可以记录包括堆栈跟踪、错误代码之类的详细信息。log

  • mysql复制使用gtid,用gtid_purged跳过事务

    mysql复制使用gtid,用gtid_purged跳过事务

  • Java中Calendar跨年的坑「建议收藏」

    Java中Calendar跨年的坑「建议收藏」上代码:publicstaticvoidmain(String[]args)throwsException{SimpleDateFormatsimpleDateFormat=newSimpleDateFormat(“yyyy-MM”);Calendarcalendar=Calendar.getInstance();calendar.setTime(simpleDateFormat.parse(“2021-08”)

  • wcopy nfc pro智能读卡工具软件_手机NFC复制小区用的门禁卡[通俗易懂]

    wcopy nfc pro智能读卡工具软件_手机NFC复制小区用的门禁卡[通俗易懂]我们说一说目前的门禁卡到底有哪些类型呢?门禁卡一般分为:ID卡和IC卡。而EM卡、M1卡、CPU卡等等,都是这两种卡的细分。它们能够开门,都是基于RFID感应的原理来实现开门的。我们看一张图,在这张图中,能够看到一个数据名词,频率:ID卡的工作频率为125KHz频率,而IC卡的工作频率为13.56MHz,显然因为IC卡的频率高,所以,它的安全性比较高。小区基本上选择IC卡的概率会更高一…

  • 矩阵乘以其矩阵转置

    矩阵乘以其矩阵转置在推导公式和计算中,常常能碰到矩阵乘以其矩阵转置,在此做个总结。1.假设矩阵A是一个m∗nm∗nm*n矩阵,那么A∗ATA∗ATA*A^T得到一个m∗mm∗mm*m矩阵,AT∗AAT∗AA^T*A得到一个n∗nn∗nn*n的矩阵,这样我们就能得到一个方矩阵。看一个例子:Xθ=HXθ=HX\theta=H求解θθ\theta.XTXθ=XTHXTXθ=XT…

发表回复

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

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