304.htm

unix高级编程原吗

output = new DataOutputStream(new FileOutputStream(tmpFile)); <br>
output.writeInt(nStartPos.length); <br>
for(int i=0;i<nStartPos.length;i++) <br>
{ <br>
// output.writeLong(nPos[i]); <br>
output.writeLong(fileSplitterFetch[i].nStartPos); <br>
output.writeLong(fileSplitterFetch[i].nEndPos); <br>
} <br>
output.close(); <br>
} <br>
catch(IOException e){e.printStackTrace ();} <br>
catch(Exception e){e.printStackTrace ();} <br>
} <br>
} <br>
//读取保存的下载信息（文件指针位置） <br>
private void read_nPos() <br>
{ <br>
try{ <br>
DataInputStream input = new DataInputStream(new FileInputStream(tmpFile)); <br>
int nCount = input.readInt(); <br>
nStartPos = new long[nCount]; <br>
nEndPos = new long[nCount]; <br>
for(int i=0;i<nStartPos.length;i++) <br>
{ <br>
nStartPos[i] = input.readLong(); <br>
nEndPos[i] = input.readLong(); <br>
} <br>
input.close(); <br>
} <br>
catch(IOException e){e.printStackTrace ();} <br>
catch(Exception e){e.printStackTrace ();} <br>
} <br>
private void processErrorCode(int nErrorCode) <br>
{ <br>
System.err.println("Error Code : " + nErrorCode); <br>
} <br>
} <br>
//停止文件下载 <br>
public void siteStop() <br>
{ <br>
bStop = true; <br>
for(int i=0;i<nStartPos.length;i++) <br>
fileSplitterFetch[i].splitterStop(); <br>
} <br>
} <br>
/* <br>
**FileSplitterFetch.java <br>
*/ <br>
package NetFox; <br>
import java.io.*; <br>
import java.net.*; <br>
public class FileSplitterFetch extends Thread { <br>
String sURL; //File URL <br>
long nStartPos; //File Snippet Start Position <br>
long nEndPos; //File Snippet End Position <br>
int nThreadID; //Thread's ID <br>
boolean bDownOver = false; //Downing is over <br>
boolean bStop = false; //Stop identical <br>
FileAccessI fileAccessI = null; //File Access interface <br>

public FileSplitterFetch(String sURL,String sName,long nStart,long nEnd,int <br>
id) throws IOException <br>
{ <br>
this.sURL = sURL; <br>
this.nStartPos = nStart; <br>
this.nEndPos = nEnd; <br>
nThreadID = id; <br>
fileAccessI = new FileAccessI(sName,nStartPos); <br>
} <br>
public void run() <br>
{ <br>
while(nStartPos < nEndPos && !bStop) <br>
{ <br>
try{ <br>
URL url = new URL(sURL); <br>
HttpURLConnection httpConnection = (HttpURLConnection)url.openConnection (); <br>
  <br>
httpConnection.setRequestProperty("User-Agent","NetFox"); <br>
String sProperty = "bytes="+nStartPos+"-"; <br>
httpConnection.setRequestProperty("RANGE",sProperty); <br>
Utility.log(sProperty); <br>
InputStream input = httpConnection.getInputStream(); <br>

//logResponseHead(httpConnection); <br>
byte[] b = new byte[1024]; <br>
int nRead; <br>
while((nRead=input.read(b,0,1024)) > 0 && nStartPos < nEndPos && !bStop) <br>
{ <br>
nStartPos += fileAccessI.write(b,0,nRead); <br>
//if(nThreadID == 1) <br>
// Utility.log("nStartPos = " + nStartPos + ", nEndPos = " + nEndPos); <br>
} <br>
Utility.log("Thread " + nThreadID + " is over!"); <br>
bDownOver = true; <br>
//nPos = fileAccessI.write (b,0,nRead); <br>
} <br>
catch(Exception e){e.printStackTrace ();} <br>
} <br>
} <br>
//打印回应的头信息 <br>
public void logResponseHead(HttpURLConnection con) <br>
{ <br>
for(int i=1;;i++) <br>
{ <br>
String header=con.getHeaderFieldKey(i); <br>

if(header!=null) <br>
//responseHeaders.put(header,httpConnection.getHeaderField(header)); <br>
Utility.log(header+" : "+con.getHeaderField(header)); <br>
else <br>
break; <br>
} <br>
} <br>
public void splitterStop() <br>
{ <br>
bStop = true; <br>
} <br>
} <br>
/* <br>
**FileAccess.java <br>
*/ <br>
package NetFox; <br>
import java.io.*; <br>
public class FileAccessI implements Serializable{ <br>
RandomAccessFile oSavedFile; <br>
long nPos; <br>
public FileAccessI() throws IOException <br>
{ <br>
{ <br>
this("",0); <br>
} <br>
public FileAccessI(String sName,long nPos) throws IOException <br>
{ <br>
oSavedFile = new RandomAccessFile(sName,"rw"); <br>
this.nPos = nPos; <br>
oSavedFile.seek(nPos); <br>
} <br>
public synchronized int write(byte[] b,int nStart,int nLen) <br>
{ <br>
int n = -1; <br>
try{ <br>
oSavedFile.write(b,nStart,nLen); <br>
n = nLen; <br>
} <br>
catch(IOException e) <br>
{ <br>
e.printStackTrace (); <br>
} <br>
return n; <br>
} <br>
} <br>
} <br>
/* <br>
**SiteInfoBean.java <br>
*/ <br>
package NetFox; <br>
public class SiteInfoBean { <br>
private String sSiteURL; //Site's URL <br>
private String sFilePath; //Saved File's Path <br>
private String sFileName; //Saved File's Name <br>
private int nSplitter; //Count of Splited Downloading File <br>
public SiteInfoBean() <br>
{ <br>
//default value of nSplitter is 5 <br>
this("","","",5); <br>
} <br>
public SiteInfoBean(String sURL,String sPath,String sName,int nSpiltter) <br>
{ <br>
sSiteURL= sURL; <br>
sFilePath = sPath; <br>
sFileName = sName; <br>
this.nSplitter = nSpiltter; <br>
} <br>
public String getSSiteURL() <br>

{ <br>
return sSiteURL; <br>
} <br>
public void setSSiteURL(String value) <br>
{ <br>
sSiteURL = value; <br>
} <br>
public String getSFilePath() <br>
{ <br>
return sFilePath; <br>
} <br>
public void setSFilePath(String value) <br>
{ <br>
sFilePath = value; <br>
} <br>
public String getSFileName() <br>
{ <br>
return sFileName; <br>
} <br>
public void setSFileName(String value) <br>
{ <br>
sFileName = value; <br>

} <br>
public int getNSplitter() <br>
{ <br>
return nSplitter; <br>
} <br>
public void setNSplitter(int nCount) <br>
{ <br>
nSplitter = nCount; <br>
} <br>
} <br>
/* <br>
**Utility.java <br>
*/ <br>
package NetFox; <br>
public class Utility { <br>
public Utility() <br>
{ <br>
} <br>
public static void sleep(int nSecond) <br>
{ <br>
try{ <br>
Thread.sleep(nSecond); <br>

} <br>
catch(Exception e) <br>
{ <br>
e.printStackTrace (); <br>
} <br>
} <br>
public static void log(String sMsg) <br>
{ <br>
System.err.println(sMsg); <br>
} <br>
public static void log(int sMsg) <br>
{ <br>
System.err.println(sMsg); <br>
} <br>
} <br>
/* <br>
**TestMethod.java <br>
*/ <br>
package NetFox; <br>
public class TestMethod { <br>
public TestMethod() <br>
{ ///xx/weblogic60b2_win.exe <br>

try{ <br>
SiteInfoBean bean = new SiteInfoBean("http://localhost/xx/weblogic60b2_win.e <br>
xe","L:\\temp","weblogic60b2_win.exe",5); <br>
//SiteInfoBean bean = new SiteInfoBean("http://localhost:8080/down.zip","L:\ <br>
\temp","weblogic60b2_win.exe",5); <br>
SiteFileFetch fileFetch = new SiteFileFetch(bean); <br>
fileFetch.start(); <br>
} <br>
catch(Exception e){e.printStackTrace ();} <br>
} <br>
public static void main(String[] args) <br>
{ <br>
new TestMethod(); <br>
} <br>
} <br>
  <br>
-- <br>
我后来发现背叛其实没有罪 相爱的游戏里需要包容和妥协 <br>
于是所有的虚伪成为一种防备 掩饰著在你走后剩余的岁月 <br>
你追逐著你想要的美 我守候在你忽略的周围 <br>
你恣意的飞翔 不怕危险 我等待著你的疲惫 做你最后的依归 <br>
  <br>

  <br>
-- <br>
※ 来源:·UNIX编程 www.tiaozhan.com/unixbbs/·[FROM: 211.69.197.81] <br>
</small><hr>
<p align="center">[<a href="index.htm">回到开始</a>][<a href="195.htm">上一层</a>][<a href="305.htm">下一篇</a>]
<p align="center"><a href="http://cterm.163.net">欢迎访问Cterm主页</a></p>
</table>
</body>
</html>