วิธีการใช้ฟังก์ชัน HTTP เบรกพอยต์ดำเนินการต่อใน Java

คัดลอกรหัสรหัส ดังต่อไปนี้:

RandomAccess oSavedFile = new RandomAccessFile("down.zip", "rw");
nPos ยาว = 2000070;
//ค้นหาตำแหน่งตัวชี้ไฟล์ไปยังตำแหน่ง nPos
oSavedFile.seek(nPos);
ไบต์ [] b = ไบต์ใหม่ [1024];
int nRead;
//อ่านไบต์สตรีมจากอินพุตสตรีมและเขียนลงในไฟล์
ในขณะที่((nRead=input.read(b,0,1024)) > 0)
-
oSavedFile.write(b,0,nอ่าน);
-

คัดลอกรหัสรหัส ดังต่อไปนี้:

-
**SiteFileFetch.java
-
แพ็คเกจ NetFox;
นำเข้า java.io.*;
นำเข้า java.net.*;
SiteFileFetch ระดับสาธารณะขยายเธรด {
SiteInfoBean siteInfoBean = null; // ข้อมูลไฟล์ Bean
ยาว [] nStartPos; // ตำแหน่งเริ่มต้น
long[] nEndPos; //ตำแหน่งสิ้นสุด
FileSplitterFetch[] fileSplitterFetch; //วัตถุเธรดย่อย
long nFileLength; // ความยาวไฟล์
boolean bFirst = true; // ว่าจะดึงไฟล์เป็นครั้งแรกหรือไม่
บูลีน bStop = false; //เครื่องหมายหยุด
ไฟล์ tmpFile; //ข้อมูลชั่วคราวสำหรับการดาวน์โหลดไฟล์
DataOutputStream เอาท์พุต; //เอาท์พุตสตรีมไปยังไฟล์
SiteFileFetch สาธารณะ (SiteInfoBean bean) พ่น IOException
-
siteInfoBean = ถั่ว;
//tmpFile = File.createTempFile ("zhong", "1111",ไฟล์ใหม่(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("ไฟล์ไม่สามารถเข้าถึงได้!");
-
อื่น
-
สำหรับ(int i=0;i<nStartPos.length;i++)
-
nStartPos[i] = (ยาว)(i*(nFileLength/nStartPos.length));
-
สำหรับ(int i=0;i<nEndPos.length-1;i++)
-
nEndPos[i] = nStartPos[i+1];
-
nEndPos[nEndPos.length-1] = nFileLength;
-
-
//เริ่มเธรดย่อย
fileSplitterFetch = FileSplitterFetch ใหม่ [nStartPos.length];
สำหรับ(int i=0;i<nStartPos.length;i++)
-
fileSplitterFetch[i] = FileSplitterFetch ใหม่ (siteInfoBean.getSSiteURL(),
siteInfoBean.getSFilePath() + File.separator + siteInfoBean.getSFileName()
nStartPos[i],nEndPos[i],ฉัน);
Utility.log("เธรด " + i + " , nStartPos = " + nStartPos[i] + ", nEndPos = " + nEndPos[i]);
fileSplitterFetch[i].เริ่มต้น();
-
// 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();
//รอให้เธรดย่อยสิ้นสุด
//จำนวน int = 0;
//ว่าจะจบ while loop หรือไม่
บูลีน breakWhile = false;
ในขณะที่(!bStop)
-
write_nPos();
Utility.sleep (500);
แบ่งขณะ = จริง;
สำหรับ(int i=0;i<nStartPos.length;i++)
-
ถ้า(!fileSplitterFetch[i].bDownOver)
-
breakWhile = เท็จ;
หยุดพัก;
-
-
ถ้า (breakWhile)
หยุดพัก;
//นับ++;
//ถ้า(นับ>4)
// siteStop();
-
System.err.println("ดาวน์โหลดไฟล์เสร็จสิ้น!");
-
catch (ข้อยกเว้น e) {e.printStackTrace ();}
-
//รับความยาวไฟล์
getFileSize ยาวสาธารณะ ()
-
int nFileLength = -1;
พยายาม{
URL url = URL ใหม่ (siteInfoBean.getSSiteURL());
HttpURLConnection httpConnection = (การเชื่อมต่อ HttpURL)url.openConnection ();
httpConnection.setRequestProperty("ตัวแทนผู้ใช้", "NetFox");
int responseCode=httpConnection.getResponseCode();
ถ้า(รหัสตอบกลับ>=400)
-
กระบวนการรหัสข้อผิดพลาด (รหัสตอบกลับ);
return -2; //-2 หมายถึงการเข้าถึงมีข้อผิดพลาด
-
สตริง sHeader;
สำหรับ (int i = 1;; i ++)
-
//DataInputStream ใน = DataInputStream ใหม่ (httpConnection.getInputStream ());
//Utility.log(in.readLine());
sHeader=httpConnection.getHeaderFieldKey(i);
ถ้า(sHeader!=null)
-
if(sHeader.equals("เนื้อหาความยาว"))
-
nFileLength = Integer.parseInt(httpConnection.getHeaderField(sHeader));
หยุดพัก;
-
-
อื่น
หยุดพัก;
-
-
จับ (IOException e) {e.printStackTrace ();}
catch (ข้อยกเว้น e) {e.printStackTrace ();}
Utility.log(nFileLength);
กลับ nFileLength;
-
//บันทึกข้อมูลการดาวน์โหลด (ตำแหน่งตัวชี้ไฟล์)
โมฆะส่วนตัว write_nPos ()
-
พยายาม{
เอาท์พุท = DataOutputStream ใหม่ (FileOutputStream ใหม่ (tmpFile));
output.writeInt(nStartPos.ความยาว);
สำหรับ(int i=0;i<nStartPos.length;i++)
-
// output.writeLong(nPos[i]);
output.writeLong(fileSplitterFetch[i].nStartPos);
output.writeLong(fileSplitterFetch[i].nEndPos);
-
เอาท์พุท.ปิด();
-
จับ (IOException e) {e.printStackTrace ();}
catch (ข้อยกเว้น e) {e.printStackTrace ();}
-
//อ่านข้อมูลการดาวน์โหลดที่บันทึกไว้ (ตำแหน่งตัวชี้ไฟล์)
โมฆะส่วนตัว read_nPos()
-
พยายาม{
อินพุต DataInputStream = DataInputStream ใหม่ (FileInputStream ใหม่ (tmpFile));
int nCount = input.readInt();
nStartPos = ใหม่ยาว[nCount];
nEndPos = ใหม่ยาว[nCount];
สำหรับ(int i=0;i<nStartPos.length;i++)
-
nStartPos[i] = input.readLong();
nEndPos[i] = input.readLong();
-
อินพุต.ปิด();
-
จับ (IOException e) {e.printStackTrace ();}
catch (ข้อยกเว้น e) {e.printStackTrace ();}
-
กระบวนการโมฆะส่วนตัวErrorCode (int nErrorCode)
-
System.err.println("รหัสข้อผิดพลาด : " + nErrorCode);
-
//หยุดดาวน์โหลดไฟล์
โมฆะสาธารณะ siteStop()
-
bStop = จริง;
สำหรับ(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; // ID ของเธรด
boolean bDownOver = false; // Downing จบลงแล้ว
บูลีน bStop = false; //หยุดเหมือนกัน
FileAccessI fileAccessI = null; // อินเทอร์เฟซการเข้าถึงไฟล์
FileSplitterFetch สาธารณะ (String sURL, String sName, nStart แบบยาว, nEnd แบบยาว, int id) พ่น IOException
-
นี้.sURL = sURL;
this.nStartPos = nStart;
this.nEndPos = nEnd;
nThreadID = รหัส;
fileAccessI = FileAccessI ใหม่ (sName, nStartPos);
-
การรันโมฆะสาธารณะ ()
-
ในขณะที่(nStartPos < nEndPos && !bStop)
-
พยายาม{
URL URL = URL ใหม่(sURL);
HttpURLConnection httpConnection = (การเชื่อมต่อ HttpURL)url.openConnection ();
httpConnection.setRequestProperty("ตัวแทนผู้ใช้", "NetFox");
สตริง sProperty = "bytes="+nStartPos+"-";
httpConnection.setRequestProperty("RANGE",sProperty);
Utility.log(sคุณสมบัติ);
อินพุต InputStream = httpConnection.getInputStream();
//logResponseHead(httpการเชื่อมต่อ);
ไบต์ [] b = ไบต์ใหม่ [1024];
int nRead;
ในขณะที่((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("Thread " + nThreadID + " จบแล้ว!");
bDownOver = จริง;
//nPos = fileAccessI.write (b,0,nRead);
-
catch (ข้อยกเว้น e) {e.printStackTrace ();}
-
-
//พิมพ์ข้อมูลส่วนหัวของคำตอบ
โมฆะสาธารณะ logResponseHead (HttpURLConnection con)
-
สำหรับ (int i = 1;; i ++)
-
ส่วนหัวของสตริง=con.getHeaderFieldKey(i);
ถ้า(ส่วนหัว!=null)
//responseHeaders.put(ส่วนหัว,httpConnection.getHeaderField(ส่วนหัว));
Utility.log(header+" : "+con.getHeaderField(ส่วนหัว));
อื่น
หยุดพัก;
-
-
โมฆะสาธารณะ splitterStop()
-
bStop = จริง;
-
-
-
**FileAccess.java
-
แพ็คเกจ NetFox;
นำเข้า java.io.*;
FileAccessI คลาสสาธารณะใช้ Serializable {
RandomAccessFile oSavedFile;
nPos ยาว;
FileAccessI() สาธารณะพ่น IOException
-
นี้("",0);
-
FileAccessI สาธารณะ (ชื่อสตริง, nPos แบบยาว) พ่น IOException
-
oSavedFile = RandomAccessFile ใหม่ (sName, "rw");
นี่.nPos = nPos;
oSavedFile.seek(nPos);
-
การซิงโครไนซ์สาธารณะ int write (ไบต์ [] b, int nStart, int nLen)
-
อินท์ n = -1;
พยายาม{
oSavedFile.write(b,nStart,nLen);
n = nเลน;
-
จับ (IOException e)
-
e.printStackTrace();
-
กลับ n;
-
-
-
**SiteInfoBean.java
-
แพ็คเกจ NetFox;
SiteInfoBean ระดับสาธารณะ {
สตริงส่วนตัว sSiteURL; //URL ของไซต์
สตริงส่วนตัว sFilePath; //เส้นทางของไฟล์ที่บันทึกไว้
สตริงส่วนตัว sFileName; //ชื่อไฟล์ที่บันทึกไว้
private int nSplitter; // จำนวนไฟล์ที่ดาวน์โหลดแบบแยกส่วน
SiteInfoBean สาธารณะ ()
-
//ค่าเริ่มต้นของ nSplitter คือ 5
นี้("", "",5);
-
SiteInfoBean สาธารณะ (สตริง sURL, สตริง sPath, สตริง sName, int nSpiltter)
-
sSiteURL= sURL;
sFilePath = สพาธ;
sFileName = sName;
this.nSplitter = nSpiltter;
-
สตริงสาธารณะ getSSiteURL()
-
ส่งคืน sSiteURL;
-
โมฆะสาธารณะ setSSiteURL (ค่าสตริง)
-
sSiteURL = ค่า;
-
สตริงสาธารณะ getSFilePath()
-
กลับ sFilePath;
-
โมฆะสาธารณะ setSFilePath (ค่าสตริง)
-
sFilePath = ค่า;
-
สตริงสาธารณะ getSFileName()
-
กลับ sFileName;
-
โมฆะสาธารณะ setSFileName (ค่าสตริง)
-
sFileName = ค่า;
-
สาธารณะ int getNSplitter()
-
กลับ nSplitter;
-
โมฆะสาธารณะ setNSplitter (int nCount)
-
nSplitter = nนับ;
-
-
-
**ยูทิลิตี้.java
-
แพ็คเกจ NetFox;
ยูทิลิตี้คลาสสาธารณะ {
สาธารณูปโภค()
-
-
การนอนหลับเป็นโมฆะสาธารณะแบบคงที่ (int nSecond)
-
พยายาม{
Thread.sleep (nวินาที);
-
จับ (ยกเว้น e)
-
e.printStackTrace();
-
-
บันทึกโมฆะคงที่สาธารณะ (String sMsg)
-
System.err.println(sMsg);
-
บันทึกโมฆะคงที่สาธารณะ (int sMsg)
-
System.err.println(sMsg);
-
-
-
**TestMethod.java
-
แพ็คเกจ NetFox;
วิธีทดสอบคลาสสาธารณะ {
วิธีทดสอบสาธารณะ ()
{ ///xx/weblogic60b2_win.exe
พยายาม{
SiteInfoBean bean = SiteInfoBean ใหม่ ("http://localhost/xx/weblogic60b2_win.exe", L://temp ", weblogic60b2_win.exe", 5);
//SiteInfoBean bean = SiteInfoBean ใหม่("http://localhost:8080/down.zip","L://temp","weblogic60b2_win.exe",5);
SiteFileFetch fileFetch = ใหม่ SiteFileFetch(bean);
fileFetch.start();
-
จับ (ข้อยกเว้น e) {e.printStackTrace ();
-
-
โมฆะสาธารณะคง main (String [] args)
-
วิธีทดสอบใหม่ ();
-
-