java断点续传功能实例(java获取远程文件)

 更新时间:2013年12月24日 09:59:54   作者:  
本文介绍了一种利用 Java 来实现断点续传的方法。

复制代码 代码如下:

import java.io.BufferedInputStream;
 import java.io.DataOutputStream;
 import java.io.File;
 import java.io.FileOutputStream;

import java.io.IOException;

import java.io.RandomAccessFile;

import java.net . * ;

/**
* 文件传送客户端:获取远程文件
 */
public class GetRemoteFile_Client_GoOn { public GetRemoteFile_Client_GoOn()
   {
   }

  private boolean FileExist(String pathAndFile) // 确定文件是否已经下载,但没有下载完成
  {
     File file = new File(pathAndFile);
     if (file.exists())
       return true ;
     else
      return false ;
   }

  private long FileSize(String pathAndFile) // 确定已经下载了的文件大小
  {
     File file = new File(pathAndFile);
     return file.length();
   }
   private void FileRename(String fName,String nName) // 将下载完全的文件更名,去掉.tp名
  {
     File file = new File(fName);
     file.renameTo( new File(nName));
     file.delete();
   }
   public static void main(String[] args)
   {
     URL url = null ;
     HttpURLConnection urlc = null ;
     DataOutputStream dos = null ;
     BufferedInputStream bis = null ;
     FileOutputStream fos = null ;
     String localFile = " d:////x.x " ; // 文件保存的地方及文件名,具体情况可以改
    String localFile_bak = localFile + " .tp " ; // 未下载完文件加.tp扩展名,以便于区别
    GetRemoteFile_Client_GoOn gco = new GetRemoteFile_Client_GoOn();
     long fileSize = 0 ;
     long start = System.currentTimeMillis();
     int len = 0 ;
     byte [] bt = new byte [ 1024 ];
     // byte[] buffer=new byte[50*1024];
    RandomAccessFile raFile = null ;
     long TotalSize = 0 ; // 要下载的文件总大小
    try
    {
       url = new URL( " http://www.netbox.cn/download/nbsetup.EXE " );     
      urlc = (HttpURLConnection) url.openConnection();
       TotalSize = Long.parseLong(urlc.getHeaderField( " Content-Length " ));
       System.out.println( " 下载文件大小为: " + TotalSize);
       urlc.disconnect(); // 先断开,下面再连接,否则下面会报已经连接的错误
      urlc = (HttpURLConnection) url.openConnection();
       // 确定文件是否存在
      if (gco.FileExist(localFile_bak)) // 采用断点续传,这里的依据是看下载文件是否在本地有.tp有扩展名同名文件
      {
         System.out.println( " 文件续传中… " );
         fileSize = gco.FileSize(localFile_bak); // 取得文件在小,以便确定随机写入的位置
        System.out.println( " fileSize: " + fileSize);
         // 设置User-Agent
         // urlc.setRequestProperty("User-Agent","NetFox");
         // 设置断点续传的开始位置
        urlc.setRequestProperty( " RANGE " , " bytes= " + fileSize + " - " );
         // urlc.setRequestProperty("RANGE", "bytes="+fileSize); // 这样写不行,不能少了这个"-".
         // 设置接受信息
        urlc.setRequestProperty( " Accept " , " image/gif,image/x-xbitmap,application/msword,*/* " );       
        raFile = new RandomAccessFile(localFile_bak, " rw " ); // 随机方位读取
        raFile.seek(fileSize); // 定位指针到fileSize位置
        bis = new BufferedInputStream(urlc.getInputStream());
         while ((len = bis.read(bt)) > 0 ) // 循环获取文件
        {
           raFile.write(bt, 0 , len);
           // buffer=buffer+bt;
           // System.
        }
         System.out.println( " 文件续传接收完毕! " );       
      }
       else // 采用原始下载
      {
         fos = new FileOutputStream(localFile_bak); // 没有下载完毕就将文件的扩展名命名.bak
        dos = new DataOutputStream(fos);
         bis = new BufferedInputStream(urlc.getInputStream());       
        System.out.println( " 正在接收文件… " );
         int test = 0 ;
         while ((len = bis.read(bt)) > 0 ) // 循环获取文件
        {
           dos.write(bt, 0 , len);
           test ++ ;
           if (test == 50 ) // 这里是测试,你可以删除这里,就可以正常下载了
            break ;
         }       
        // System.out.println("文件正常接收完毕!");
      }     
      System.out.println( " 共用时: " +
                         (System.currentTimeMillis() - start) / 1000 );
       if (bis != null )
         bis.close();
       if (dos != null )
         dos.close();
       if (fos != null )
         fos.close();
       if (raFile != null )
         raFile.close();
       System.out.println( " localFile_bak: " + gco.FileSize(localFile_bak));
       if (gco.FileSize(localFile_bak) == TotalSize) // 下载完毕后,将文件重命名
      {
         gco.FileRename(localFile_bak,localFile);
       }
       System.exit( 0 );
     }
     catch (Exception e)
     {
       try
      {
         if (bis != null )
           bis.close();
         if (dos != null )
           dos.close();
         if (fos != null )
           fos.close();
         if (raFile != null )
           raFile.close();
       }
       catch (IOException f)
       {
         f.printStackTrace();
       }
       e.printStackTrace();
     }
     System.exit( 0 );
   }
 }

相关文章

  • Spring Cloud Admin健康检查 邮件、钉钉群通知的实现

    Spring Cloud Admin健康检查 邮件、钉钉群通知的实现

    这篇文章主要介绍了Spring Cloud Admin健康检查 邮件、钉钉群通知的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-08-08
  • SpringBoot中YAML语法及几个注意点说明

    SpringBoot中YAML语法及几个注意点说明

    这篇文章主要介绍了SpringBoot中YAML语法及几个注意点说明,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-02-02
  • 分布式医疗挂号系统SpringCache与Redis为数据字典添加缓存

    分布式医疗挂号系统SpringCache与Redis为数据字典添加缓存

    这篇文章主要为大家介绍了分布式医疗挂号系统SpringCache与Redis为数据字典添加缓存,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-04-04
  • Java中如何检查数组是否包含某整数

    Java中如何检查数组是否包含某整数

    这篇文章主要介绍了在 Java 中检查数组是否包含某整数,在本文中,我们使用了几个内置的方法,如anyMatch()、contains()、binarySearch()等,我们将在给定的数组中找到一个值,结合示例代码给大家介绍的非常详细,需要的朋友可以参考下
    2023-05-05
  • java+mysql模拟实现银行系统

    java+mysql模拟实现银行系统

    这篇文章主要为大家详细介绍了java+mysql模拟实现银行系统,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2020-05-05
  • 使用maven运行Java Main的三种方法解析

    使用maven运行Java Main的三种方法解析

    这篇文章主要介绍了使用maven运行Java Main的三种方式的相关内容,具有一定参考价值,需要的朋友可以了解下。
    2017-10-10
  • Java实现后端跨域的常见解决方案

    Java实现后端跨域的常见解决方案

    跨源资源共享(CORS——Cross-Origin Resource Sharing,跨源资源共享,或通俗地译为跨域资源共享)是一种基于 HTTP 头的机制,跨域的解决方案有很多种,前后端都有,本文给大家主要介绍Java实现后端跨域的常见解决方案,需要的朋友可以参考下
    2024-04-04
  • springboot项目打docker镜像实例(入门级)

    springboot项目打docker镜像实例(入门级)

    最近做个项目,我们想把自己的程序打包成镜像,并运行在docker容器中,本文主要介绍了springboot项目打docker镜像实例,具有一定的参考价值,感兴趣的可以了解一下
    2024-06-06
  • Java直接插入排序算法实现

    Java直接插入排序算法实现

    这篇文章主要介绍了Java直接插入排序算法实现,有需要的朋友可以参考一下
    2014-01-01
  • SpringBoot实现接口版本控制的示例代码

    SpringBoot实现接口版本控制的示例代码

    这篇文章主要介绍了springboot如何实现接口版本控制,接口版本控制,比如微服务请求中某个接口需要升级,正常做法是升级我们的版本,文中有详细的代码示例供大家参考,具有一定的参考价值,需要的朋友可以参考下
    2024-03-03

最新评论