كيفية تنفيذ وظيفة استئناف نقطة توقف HTTP في Java

انسخ رمز الكود كما يلي:

RandomAccess oSavedFile = new RandomAccessFile("down.zip"،"rw")؛
طويل nPos = 2000070؛
// حدد موقع مؤشر الملف إلى موضع nPos
oSavedFile.seek(nPos);
بايت[] ب = بايت جديد[1024];
كثافة العمليات ن القراءة؛
// اقرأ دفق البايت من دفق الإدخال واكتبه في الملف
بينما((nRead=input.read(b,0,1024)) > 0)
{
oSavedFile.write(b,0,nRead);
}

انسخ رمز الكود كما يلي:

/*
** SiteFileFetch.java
*/
حزمة نت فوكس؛
استيراد java.io.*;
استيراد java.net.*;
الطبقة العامة SiteFileFetch تمتد الموضوع {
SiteInfoBean siteInfoBean = null; // معلومات الملف Bean
long[] nStartPos;
long[] nEndPos;
FileSplitterFetch[] fileSplitterFetch; // كائن الخيط الفرعي
long nFileLength; // طول الملف
boolean bFirst = true; // ما إذا كان سيتم جلب الملف لأول مرة
boolean bStop = false;
ملف tmpFile; // معلومات مؤقتة لتنزيل الملف
DataOutputStream Output; // دفق الإخراج إلى الملف
يطرح SiteFileFetch العام (SiteInfoBean bean) IOException
{
siteInfoBean = bean;
//tmpFile = File.createTempFile("zhong"،"1111"،new File(bean.getSFilePath()));
tmpFile = new File(bean.getSFilePath()+File.separator + bean.getSFileName()+".info");
إذا (tmpFile.exists ())
{
bFirst = false;
read_nPos();
}
آخر
{
nStartPos = new long[bean.getNSplitter()];
nEndPos = new long[bean.getNSplitter()];
}
}
تشغيل الفراغ العام ()
{
// احصل على طول الملف
// تقسيم الملف
//مثيل FileSplitterFetch
// ابدأ موضوع FileSplitterFetch
// انتظر عودة الخيط الفرعي
يحاول{
إذا (بأولاً)
{
nFileLength = getFileSize();
إذا (nFileLength == -1)
{
System.err.println("طول الملف غير معروف!");
}
وإلا إذا (nFileLength == -2)
{
System.err.println("لا يمكن الوصول إلى الملف!");
}
آخر
{
ل(int i=0;i<nStartPos.length;i++)
{
nStartPos[i] = (long)(i*(nFileLength/nStartPos.length));
}
ل(int i=0;i<nEndPos.length-1;i++)
{
nEndPos[i] = nStartPos[i+1];
}
nEndPos[nEndPos.length-1] = nFileLength;
}
}
// ابدأ موضوع الطفل
fileSplitterFetch = new FileSplitterFetch[nStartPos.length];
ل(int i=0;i<nStartPos.length;i++)
{
fileSplitterFetch[i] = new 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] = new 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؛
// ما إذا كان سيتم إنهاء الحلقة بينما
استراحة منطقية = خطأ؛
بينما (! بستوب)
{
write_nPos();
Utility.sleep(500);
BreakWhile = true;
ل(int i=0;i<nStartPos.length;i++)
{
إذا (!fileSplitterFetch[i].bDownOver)
{
BreakWhile = false;
استراحة؛
}
}
إذا (استراحة)
استراحة؛
//العدد++;
//إذا (العدد>4)
// siteStop();
}
System.err.println("اكتمل تنزيل الملف!");
}
قبض (استثناء ه) {e.printStackTrace ()؛}
}
// احصل على طول الملف
getFileSize () العام الطويل
{
int nFileLength = -1;
يحاول{
URL url = عنوان URL الجديد(siteInfoBean.getSSiteURL());
HttpURLConnection httpConnection = (HttpURLConnection)url.openConnection ();
httpConnection.setRequestProperty("User-Agent"،"NetFox");
int ResponseCode=httpConnection.getResponseCode();
إذا (رمز الاستجابة> = 400)
{
ProcessErrorCode(responseCode);
return -2; //-2 يمثل الوصول إلى الخطأ
}
رأس السلسلة؛
ل(int i=1;;i++)
{
//DataInputStream in = new DataInputStream(httpConnection.getInputStream());
//Utility.log(in.readLine());
sHeader=httpConnection.getHeaderFieldKey(i);
إذا (sHeader!=null)
{
إذا (sHeader.equals("طول المحتوى"))
{
nFileLength = Integer.parseInt(httpConnection.getHeaderField(sHeader));
استراحة؛
}
}
آخر
استراحة؛
}
}
الصيد (IOException e) {e.printStackTrace ()؛}
قبض (استثناء ه) {e.printStackTrace ()؛}
Utility.log(nFileLength);
إرجاع nFileLength؛
}
// حفظ معلومات التنزيل (موضع مؤشر الملف)
write_nPos () الفراغ الخاص
{
يحاول{
Output = new DataOutputStream(new FileOutputStream(tmpFile));
input.writeInt(nStartPos.length);
ل(int i=0;i<nStartPos.length;i++)
{
//output.writeLong(nPos[i]);
input.writeLong(fileSplitterFetch[i].nStartPos);
input.writeLong(fileSplitterFetch[i].nEndPos);
}
الإخراج. إغلاق ()؛
}
الصيد (IOException e) {e.printStackTrace ()؛}
قبض (استثناء ه) {e.printStackTrace ()؛}
}
// اقرأ معلومات التنزيل المحفوظة (موضع مؤشر الملف)
read_nPos () باطلة خاصة
{
يحاول{
DataInputStream input = new DataInputStream(new FileInputStream(tmpFile));
int nCount = input.readInt();
nStartPos = new long[nCount];
nEndPos = new long[nCount];
ل(int i=0;i<nStartPos.length;i++)
{
nStartPos[i] = input.readLong();
nEndPos[i] = input.readLong();
}
input. Close();
}
الصيد (IOException e) {e.printStackTrace ()؛}
قبض (استثناء ه) {e.printStackTrace ()؛}
}
رمز خطأ العملية الخاص (int nErrorCode)
{
System.err.println("رمز الخطأ:" + nErrorCode);
}
// إيقاف تنزيل الملف
موقع الفراغ العامStop()
{
bStop = true;
ل(int i=0;i<nStartPos.length;i++)
fileSplitterFetch[i].splitterStop();
}
}
/*
** FileSplitterFetch.java
*/
حزمة نت فوكس؛
استيراد java.io.*;
استيراد java.net.*;
الطبقة العامة FileSplitterFetch تمتد الموضوع {
سلسلة sURL؛ // عنوان URL للملف
long nStartPos; // موضع بدء مقتطف الملف
long nEndPos; // موضع نهاية مقتطف الملف
int nThreadID; // معرف الموضوع
boolean bDownOver = false;
boolean bStop = false;
FileAccessI fileAccessI = null; // واجهة الوصول إلى الملفات
FileSplitterFetch العام (String sURL، String sName، long nStart، long nEnd، int id) يلقي IOException
{
this.sURL = sURL;
this.nStartPos = nStart;
this.nEndPos = nEnd;
nThreadID = id;
fileAccessI = new FileAccessI(sName,nStartPos);
}
تشغيل الفراغ العام ()
{
بينما (nStartPos < nEndPos && !bStop)
{
يحاول{
عنوان URL = عنوان URL الجديد (sURL)؛
HttpURLConnection httpConnection = (HttpURLConnection)url.openConnection ();
httpConnection.setRequestProperty("User-Agent"،"NetFox");
String sProperty = "bytes="+nStartPos+"-";
httpConnection.setRequestProperty("RANGE",sProperty);
Utility.log(sProperty);
InputStream input = httpConnection.getInputStream();
//logResponseHead(httpConnection);
بايت[] ب = بايت جديد[1024];
كثافة العمليات ن القراءة؛
while((nRead=input.read(b,0,1024)) > 0 && nStartPos < nEndPos && !bStop)
{
nStartPos += fileAccessI.write(b,0,nRead);
//إذا (نثريديد == 1)
// Utility.log("nStartPos = " + nStartPos + ", nEndPos = " + nEndPos);
}
Utility.log("انتهى الموضوع " + nThreadID + "!");
bDownOver = true;
//nPos = fileAccessI.write (b,0,nRead);
}
قبض (استثناء ه) {e.printStackTrace ()؛}
}
}
// طباعة معلومات رأس الاستجابة
logResponseHead العام الفارغ (HttpURLConnection con)
{
ل(int i=1;;i++)
{
String header=con.getHeaderFieldKey(i);
إذا (الرأس!=خالية)
//responseHeaders.put(header,httpConnection.getHeaderField(header));
Utility.log(header+" : "+con.getHeaderField(header));
آخر
استراحة؛
}
}
الفاصل الفراغي العام ()
{
bStop = true;
}
}
/*
** FileAccess.java
*/
حزمة نت فوكس؛
استيراد java.io.*;
الطبقة العامة FileAccessI تنفذ Serializable {
RandomAccessFile oSavedFile;
نقاط البيع الطويلة؛
يقوم FileAccessI() العام بطرح IOException
{
هذا(""،0);
}
FileAccessI العام (String sName، long nPos) يطرح IOException
{
oSavedFile = new RandomAccessFile(sName,"rw");
this.nPos = nPos;
oSavedFile.seek(nPos);
}
كتابة int العامة المتزامنة (byte[] b،int nStart،int nLen)
{
كثافة العمليات ن = -1؛
يحاول{
oSavedFile.write(b,nStart,nLen);
n = nLen;
}
قبض على (IOException ه)
{
printStackTrace();
}
العودة ن؛
}
}
/*
**SiteInfoBean.java
*/
حزمة نت فوكس؛
الطبقة العامة SiteInfoBean {
سلسلة خاصة sSiteURL؛ // عنوان URL للموقع
سلسلة خاصة sFilePath؛ // مسار الملف المحفوظ
سلسلة خاصة sFileName؛ // اسم الملف المحفوظ
Private int nSplitter; // عدد ملفات التنزيل المقسمة
SiteInfoBean العام ()
{
// القيمة الافتراضية لـ nSplitter هي 5
هذا(""،"،"،5)؛
}
SiteInfoBean العام (String sURL، String sPath، String sName، int nSpiltter)
{
sSiteURL= sURL;
sFilePath = sPath;
sFileName = sName;
this.nSplitter = nSpiltter;
}
السلسلة العامة getSSiteURL()
{
إرجاع sSiteURL؛
}
setSSiteURL باطلة عامة (قيمة السلسلة)
{
sSiteURL = value;
}
سلسلة عامة getSFilePath ()
{
إرجاع sFilePath؛
}
مجموعة الفراغ العام (قيمة السلسلة)
{
sFilePath = value;
}
سلسلة عامة getSFileName ()
{
إرجاع sFileName؛
}
setSFileName باطلة عامة (قيمة السلسلة)
{
sFileName = value;
}
int public getNSplitter()
{
إرجاع nSplitter؛
}
مجموعة الفراغ العام NSplitter (int nCount)
{
nSplitter = nCount;
}
}
/*
** فائدة.جافا
*/
حزمة نت فوكس؛
فائدة الطبقة العامة {
المرافق العامة()
{
}
سكون الفراغ الثابت العام (int nSecond)
{
يحاول{
Thread.sleep(nSecond);
}
قبض (استثناء ه)
{
printStackTrace();
}
}
سجل الفراغ الثابت العام (سلسلة sMsg)
{
System.err.println(sMsg);
}
سجل الفراغ الثابت العام (int sMsg)
{
System.err.println(sMsg);
}
}
/*
**TestMethod.java
*/
حزمة نت فوكس؛
طريقة اختبار الطبقة العامة {
طريقة الاختبار العامة ()
{ ///xx/weblogic60b2_win.exe
يحاول{
SiteInfoBean bean = new SiteInfoBean("http://localhost/xx/weblogic60b2_win.exe"،"L://temp"،"weblogic60b2_win.exe"،5);
//SiteInfoBean bean = new SiteInfoBean("http://localhost:8080/down.zip"،L://temp"،"weblogic60b2_win.exe"،5);
SiteFileFetch fileFetch = new SiteFileFetch(bean);
fileFetch.start();
}
Catch(Exception e){e.printStackTrace ();
}
}
الفراغ العام الثابت الرئيسي (String[] args)
{
طريقة الاختبار الجديدة () ؛
}
}