Как реализовать функцию возобновления точки останова HTTP в Java

Скопируйте код кода следующим образом:

RandomAccess oSavedFile = новый RandomAccessFile("down.zip","rw");
длинный nPos = 2000070;
//Находим указатель файла на позицию nPos
oSavedFile.seek(nPos);
байт[] b = новый байт[1024];
интервал nRead;
//Читаем поток байтов из входного потока и записываем его в файл
while((nRead=input.read(b,0,1024)) > 0)
{
oSavedFile.write(b,0,nRead);
}

Скопируйте код кода следующим образом:

/*
**SiteFileFetch.java
*/
пакет NetFox;
импортировать java.io.*;
импортировать java.net.*;
общественный класс SiteFileFetch расширяет поток {
SiteInfoBean siteInfoBean = null //Информация о файле Bean;
long[] nStartPos; //Начальная позиция;
long[] nEndPos; //Конечная позиция;
FileSplitterFetch[] fileSplitterFetch //Объект подпотока;
long nFileLength //Длина файла
boolean bFirst = true // Стоит ли получать файл в первый раз;
boolean bStop = false //Знак остановки;
File tmpFile //Временная информация для загрузки файла;
DataOutputStream output; //Вывод потока в файл
public SiteFileFetch (компонент SiteInfoBean) выдает IOException
{
siteInfoBean = компонент;
//tmpFile = File.createTempFile("zhong","1111",new File(bean.getSFilePath()));
tmpFile = новый файл(bean.getSFilePath()+File.separator + bean.getSFileName()+".info");
если (tmpFile.exists ())
{
бФирст = ложь;
read_nPos();
}
еще
{
nStartPos = новый длинный [bean.getNSplitter()];
nEndPos = новый длинный [bean.getNSplitter()];
}
}
публичный недействительный запуск()
{
//Получаем длину файла
//разделяем файл
//Экземпляр FileSplitterFetch
//Запускаем поток FileSplitterFetch
//Подождем, пока дочерний поток вернется
пытаться{
если(бпервый)
{
nFileLength = getFileSize();
если (nFileLength == -1)
{
System.err.println("Длина файла неизвестна!");
}
иначе, если (nFileLength == -2)
{
System.err.println("К файлу нет доступа!");
}
еще
{
for(int i=0;i<nStartPos.length;i++)
{
nStartPos[i] = (long)(i*(nFileLength/nStartPos.length));
}
for(int i=0;i<nEndPos.length-1;i++)
{
nEndPos[i] = nStartPos[i+1];
}
nEndPos[nEndPos.length-1] = nFileLength;
}
}
//Запускаем дочерний поток
fileSplitterFetch = новый FileSplitterFetch [nStartPos.length];
for(int i=0;i<nStartPos.length;i++)
{
fileSplitterFetch[i] = новый FileSplitterFetch(siteInfoBean.getSSiteURL(),
siteInfoBean.getSFilePath() + File.separator + siteInfoBean.getSFileName(),
nStartPos[i],nEndPos[i],i);
Utility.log("Thread " + i + " , nStartPos = " + nStartPos[i] + ", nEndPos = " + nEndPos[i]);
fileSplitterFetch[i].start();
}
// fileSplitterFetch[nPos.length-1] = новый FileSplitterFetch(siteInfoBean.getSSiteURL(),
siteInfoBean.getSFilePath() + File.separator + siteInfoBean.getSFileName(),nPos[nPos.length-1],nFileLength,nPos.length-1);
// Utility.log("Thread " + (nPos.length-1) + " , nStartPos = " + nPos[nPos.length-1] + ",
nEndPos = " + nFileLength);
// fileSplitterFetch[nPos.length-1].start();
//Подождем, пока дочерний поток завершится
//число чисел = 0;
//Завершить ли цикл while
логическое значение BreakWhile = false;
пока(!bStop)
{
write_nPos();
Утилита.sleep(500);
перерывПока = Истина;
for(int i=0;i<nStartPos.length;i++)
{
if(!fileSplitterFetch[i].bDownOver)
{
перерывПока = ложь;
перерыв;
}
}
если (перерыв во время)
перерыв;
//счет++;
//если(количество>4)
// сайтСтоп();
}
System.err.println("Загрузка файла завершена!");
}
catch(Exception e){e.printStackTrace ();}
}
//Получаем длину файла
общедоступный длинный getFileSize()
{
интервал nFileLength = -1;
пытаться{
URL-адрес URL = новый URL-адрес (siteInfoBean.getSSiteURL());
HttpURLConnection httpConnection = (HttpURLConnection)url.openConnection ();
httpConnection.setRequestProperty("Агент пользователя","NetFox");
int responseCode=httpConnection.getResponseCode();
если (код ответа> = 400)
{
ProcessErrorCode (код ответа);
return -2; //-2 означает, что доступ является ошибкой;
}
Строковый заголовок;
for(int i=1;;i++)
{
//DataInputStream in = новый DataInputStream(httpConnection.getInputStream ());
//Utility.log(in.readLine());
sHeader = httpConnection.getHeaderFieldKey (я);
если (sHeader! = ноль)
{
if(sHeader.equals("Content-Length"))
{
nFileLength = Integer.parseInt(httpConnection.getHeaderField(sHeader));
перерыв;
}
}
еще
перерыв;
}
}
catch(IOException e){e.printStackTrace ();}
catch(Exception e){e.printStackTrace ();}
Utility.log(nFileLength);
вернуть nFileLength;
}
//Сохраняем информацию о загрузке (положение указателя файла)
частная пустота write_nPos()
{
пытаться{
вывод = новый DataOutputStream (новый FileOutputStream (tmpFile));
вывод.writeInt(nStartPos.length);
for(int i=0;i<nStartPos.length;i++)
{
// output.writeLong(nPos[i]);
output.writeLong(fileSplitterFetch[i].nStartPos);
output.writeLong(fileSplitterFetch[i].nEndPos);
}
вывод.закрыть();
}
catch(IOException e){e.printStackTrace ();}
catch(Exception e){e.printStackTrace ();}
}
//Читаем сохраненную информацию о загрузке (положение указателя файла)
частная пустота read_nPos()
{
пытаться{
Вход DataInputStream = новый DataInputStream (новый FileInputStream (tmpFile));
int nCount = input.readInt();
nStartPos = новый длинный [nCount];
nEndPos = новый длинный [nCount];
for(int i=0;i<nStartPos.length;i++)
{
nStartPos[i] = input.readLong();
nEndPos[i] = input.readLong();
}
ввод.закрыть();
}
catch(IOException e){e.printStackTrace ();}
catch(Exception e){e.printStackTrace ();}
}
частный недействительный процессErrorCode (int nErrorCode)
{
System.err.println("Код ошибки: " + nErrorCode);
}
//Остановить загрузку файла
публичный недействительный сайтStop()
{
бСтоп = правда;
for(int i=0;i<nStartPos.length;i++)
fileSplitterFetch[i].splitterStop();
}
}
/*
**FileSplitterFetch.java
*/
пакет NetFox;
импортировать java.io.*;
импортировать java.net.*;
публичный класс FileSplitterFetch расширяет поток {
Строка sURL // URL-адрес файла;
long nStartPos; // Начальная позиция фрагмента файла;
long nEndPos; // Конечная позиция фрагмента файла
int nThreadID //Идентификатор потока
boolean bDownOver = false //Даунинг окончен;
boolean bStop = false //Остановка идентична;
FileAccessI fileAccessI = null //Интерфейс доступа к файлу;
public FileSplitterFetch (String sURL, String sName, long nStart, long nEnd, int id) выдает IOException
{
this.sURL = sURL;
this.nStartPos = nStart;
this.nEndPos = nEnd;
nThreadID = идентификатор;
fileAccessI = новый FileAccessI (sName, nStartPos);
}
публичный недействительный запуск()
{
while(nStartPos < nEndPos && !bStop)
{
пытаться{
URL-адрес = новый URL-адрес (sURL);
HttpURLConnection httpConnection = (HttpURLConnection)url.openConnection ();
httpConnection.setRequestProperty("Агент пользователя","NetFox");
String sProperty = "bytes="+nStartPos+"-";
httpConnection.setRequestProperty("ДИАПАЗОН",sProperty);
Утилита.log(sProperty);
Входной поток ввода = httpConnection.getInputStream();
//logResponseHead(httpConnection);
байт[] b = новый байт[1024];
интервал nRead;
while((nRead=input.read(b,0,1024)) > 0 && nStartPos < nEndPos && !bStop)
{
nStartPos += fileAccessI.write(b,0,nRead);
//если(nThreadID == 1)
// Utility.log("nStartPos = " + nStartPos + ", nEndPos = " + nEndPos);
}
Utility.log("Поток " + nThreadID + " завершен!");
бDownOver = правда;
//nPos = fileAccessI.write(b,0,nRead);
}
catch(Exception e){e.printStackTrace ();}
}
}
//Печать информации заголовка ответа
public void logResponseHead (HttpURLConnection con)
{
for(int i=1;;i++)
{
Строковый заголовок = con.getHeaderFieldKey(i);
если (заголовок! = ноль)
//responseHeaders.put(header,httpConnection.getHeaderField(header));
Utility.log(header+" : "+con.getHeaderField(header));
еще
перерыв;
}
}
публичный недействительный разделительStop()
{
бСтоп = правда;
}
}
/*
**FileAccess.java
*/
пакет NetFox;
импортировать java.io.*;
публичный класс FileAccessI реализует Serializable{
Файл случайного доступа oSavedFile;
длинные nPos;
public FileAccessI() выдает IOException
{
это("",0);
}
public FileAccessI (String sName, long nPos) выдает IOException
{
oSavedFile = новый RandomAccessFile (sName, «rw»);
this.nPos = nPos;
oSavedFile.seek(nPos);
}
общедоступная синхронизированная запись int (byte[] b,int nStart,int nLen)
{
интервал n = -1;
пытаться{
oSavedFile.write(b,nStart,nLen);
п = нЛен;
}
поймать (IOException е)
{
е.printStackTrace();
}
вернуть н;
}
}
/*
**SiteInfoBean.java
*/
пакет NetFox;
общественный класс SiteInfoBean {
частная строка sSiteURL // URL-адрес сайта;
частная строка sFilePath //Путь к сохраненному файлу;
частная строка sFileName // Имя сохраненного файла;
Private int nSplitter //Счетчик разделенных загрузок файла;
общедоступный SiteInfoBean()
{
//значение nSplitter по умолчанию — 5
это("","","",5);
}
public SiteInfoBean (String sURL, String sPath, String sName, int nSpiltter)
{
sSiteURL= sURL;
sFilePath = sPath;
имя_файла = имя_файла;
this.nSplitter = nSpiltter;
}
общедоступная строка getSSiteURL()
{
вернуть сСитеУРЛ;
}
public void setSSiteURL (строковое значение)
{
сСитеУРЛ = значение;
}
публичная строка getSFilePath()
{
вернуть путь к файлу;
}
public void setSFilePath (строковое значение)
{
sFilePath = значение;
}
публичная строка getSFileName()
{
вернуть имя_файла;
}
public void setSFileName (строковое значение)
{
имя_файла = значение;
}
публичный int getNSplitter()
{
вернуть нСплиттер;
}
public void setNSplitter(int nCount)
{
нСплиттер = nCount;
}
}
/*
**Утилита.java
*/
пакет NetFox;
общественный класс Утилита {
общественная утилита()
{
}
public static void Sleep(int nSecond)
{
пытаться{
Thread.sleep(nSecond);
}
поймать (Исключение е)
{
е.printStackTrace();
}
}
публичный статический журнал void (String smsg)
{
System.err.println(sMsg);
}
публичный статический журнал void (int smsg)
{
System.err.println(sMsg);
}
}
/*
**ТестМетод.java
*/
пакет NetFox;
общественный класс TestMethod {
публичный ТестМетод()
{ ///xx/weblogic60b2_win.exe
пытаться{
Компонент SiteInfoBean = новый SiteInfoBean("http://localhost/xx/weblogic60b2_win.exe","L://temp","weblogic60b2_win.exe",5);
// Компонент SiteInfoBean = новый SiteInfoBean("http://localhost:8080/down.zip","L://temp","weblogic60b2_win.exe",5);
SiteFileFetch fileFetch = новый SiteFileFetch (компонент);
fileFetch.start();
}
catch(Exception e){e.printStackTrace ();
}
}
public static void main(String[] args)
{
новый ТестМетод();
}
}