Java多线程断点下载

标签：abs   ati   数据   readline   保存   信息   字节   ide   else   

public static class DownloadThread  extends Thread{


        private int threadId;
        private int startIndex;
        private int endIndex;
        private int lastPostion;
        public DownloadThread(int threadId,int startIndex,int endIndex){
            this.threadId = threadId;
            this.startIndex = startIndex;
            this.endIndex = endIndex;
        }

        @Override
        public void run() {
            synchronized (DownloadThread.class) {

                runningTrheadCount = runningTrheadCount +1;//开启一线程，线程数加1
            }

            //分段请求网络连接，分段保存文件到本地
            try{
                URL url = new URL(path);
                HttpURLConnection openConnection = (HttpURLConnection) url.openConnection();
                openConnection.setRequestMethod("GET");
                openConnection.setConnectTimeout(5*1000);


                System.out.println("理论上下载：  线程："+threadId+"，开始位置："+startIndex+";结束位置:"+endIndex);

                //读取上次下载结束的位置,本次从这个位置开始直接下载。
                File file2 = new File(threadId+".txt");
                if(file2.exists()){
                    BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(new FileInputStream(file2)));
                    String lastPostion_str = bufferedReader.readLine();
                    lastPostion = Integer.parseInt(lastPostion_str);//读取文件获取上次下载的位置

                    //设置分段下载的头信息。  Range:做分段数据请求用的。
                    openConnection.setRequestProperty("Range", "bytes="+lastPostion+"-"+endIndex);//bytes:0-500:请求服务器资源中0-500之间的字节信息  501-1000:
                    System.out.println("实际下载1：  线程："+threadId+"，开始位置："+lastPostion+";结束位置:"+endIndex);
                    bufferedReader.close();
                }else{

                    lastPostion = startIndex;
                    //设置分段下载的头信息。  Range:做分段数据请求用的。
                    openConnection.setRequestProperty("Range", "bytes="+lastPostion+"-"+endIndex);//bytes:0-500:请求服务器资源中0-500之间的字节信息  501-1000:
                    System.out.println("实际下载2：  线程："+threadId+"，开始位置："+lastPostion+";结束位置:"+endIndex);
                }



                System.out.println("getResponseCode"+openConnection.getResponseCode() );



                if(openConnection.getResponseCode() == 206){//200：请求全部资源成功， 206代表部分资源请求成功
                    InputStream inputStream = openConnection.getInputStream();
                    //请求成功将流写入本地文件中，已经创建的占位那个文件中

                    RandomAccessFile randomAccessFile = new RandomAccessFile(filename, "rw");
                    randomAccessFile.seek(lastPostion);//设置随机文件从哪个位置开始写。
                    //将流中的数据写入文件
                    byte[] buffer = new byte[1024];
                    int length = -1;
                    int total = 0;//记录本次线程下载的总大小

                    while((length= inputStream.read(buffer)) !=-1){
                        randomAccessFile.write(buffer, 0, length);

                        total = total+ length;
                        //去保存当前线程下载的位置，保存到文件中
                        int currentThreadPostion = lastPostion + total;//计算出当前线程本次下载的位置
                        //创建随机文件保存当前线程下载的位置
                        File file = new File(threadId+".txt");
                        RandomAccessFile accessfile = new RandomAccessFile(file, "rwd");
                        accessfile.write(String.valueOf(currentThreadPostion).getBytes());
                        accessfile.close();



                    }
                    //关闭相关的流信息
                    inputStream.close();
                    randomAccessFile.close();

                    System.out.println("线程："+threadId+"，下载完毕");



                    //当所有线程下载结束，删除存放下载位置的文件。
                    synchronized (DownloadThread.class) {
                        runningTrheadCount = runningTrheadCount -1;//标志着一个线程下载结束。
                        if(runningTrheadCount == 0 ){
                            System.out.println("所有线程下载完成");
                            for(int i =0 ;i< threadCount;i++){
                                File file = new File(i+".txt");
                                System.out.println(file.getAbsolutePath());
                                file.delete();
                            }
                        }

                    }


                }


            }catch (Exception e) {
                e.printStackTrace();
            }



            super.run();
        }

    }

上面代码主要做了4 件事 
1、设置分段下载的头信息； 
2、分段下载网络资源 
3、当中断时把当前各个线程当前下载的位置分别保存到一个临时文件中 
4、下载完成后把临时文件删除 上面代码中都给出了详细的注释

其中有一点要注意 
openConnection.setRequestProperty(“Range”, “bytes=”+lastPostion+”-“+endIndex); 
如果”bytes=格式不对的话会导致设置不成功，返回的将不是部分资源的返回码 
另一个要说明的就是randomAccessFile.seek(startThread);是设置各个线程下载的开始位置 

Java多线程断点下载

标签：abs   ati   数据   readline   保存   信息   字节   ide   else   

原文地址：http://www.cnblogs.com/zqyanywn/p/6087840.html