Java常用代码和方法

多线程技术下载文件收藏

新一篇:FTP 网络文件传输|旧一篇:(转）tomcat 安装停止在 jvm.dll 的解决

 由于网络传输存在着传输速度,传输路径等问题,将一个文件分为若干块来传送,可以提高传输效

率,JAVA 多线程技术正是将一个任务分为若干个任务来同时完成.  该实例应用 JAVA 多线程技术,将一

个网络文件分为若干块,每一个线程负责一块数据的下载,下载完毕后将其保存在指定的磁盘路径中. 

首先创建继承 Thread 类的传输文件线程类,其 JAVA 文件名为 SiteFileFetch.java,代码如下:

view plaincopy to clipboardprint?

1. importjava.io.*; 

8. 

9. SiteInfoBeansiteInfoBean=null;//创建文件信息实例

10. 

11. long[]nPos;//文件位置指针

12. 

13. long[]nStartPos;//开始位置

14. 

15. long[]nEndPos;//结束位置

16. 

17. FileSplitterFetch[]fileSplitterFetch;//子线程对象

24. 

25. FiletmpFile;//文件传输临时信息

26. 

27. DataOutputStreamoutput;//输出到文件的输出流

28. 

29. publicSiteFileFetch(SiteInfoBeanbean)throwsIOException{ 

30. 

31. siteInfoBean=bean; 

32. 

33. tmpFile=newFile(bean.getSFilePath()

39. read_nPos(); 

40. 

41. } 

42. 

43. else{ 

44. 

45. nStartPos=newlong[bean.getNSplitter()]; 

46. 

47. nEndPos=newlong[bean.getNSplitter()]; 

48. 

55. try{ 

56. 

57. if(bFirst){ 

58. 

59. nFileLength=getFileSize();//获得文件长度

60. 

61. if(nFileLength==-1){ 

62. 

63. System.err.println("FileLengthisnotknown");

64. 

71. System.err.println("Fileisnotaccess!"); 

72. 

73. } 

74. 

75. else{ 

76. 

//分割下载文件

81. } 

82. 

83. for(inti=0;i<nEndPos.length-1;i++){ 

84. 

85. nEndPos[i]=nStartPos[i+1]; 

86. 

87. } 

88. 

89. nEndPos[nEndPos.length-1]=nFileLength; 

90. 

;//创建 FileSplitterFetch 类实例

96. 

97. for(inti=0;i<nStartPos.length;i++){//启

动 FileSplitterFetch 线程

98. 

99. fileSplitterFetch[i]=newFileSplitterFetch(siteInfoBe

an.getSSiteURL(),siteInfoBean.getSFilePath()

+File.separator+siteInfoBean.getSFileName(),nStartPos[i],nEndPos[i],i

); 

100. 

101. Utility.log("Thread"+i+",nStartPos="+nStartPos[i

107. booleanbreakWhile=false; 

108. 

110. 

111. write_nPos(); 

112. 

119. if(!fileSplitterFetch[i].bDownOver){

120. 

121. breakWhile=false; 

122. 

123. break; 

124. 

125. } 

126. 

127. } 

134. 

135. System.out.println("文件传输结束!"); 

136. 

137. } 

138. 

139. catch(Exceptione){ 

140. 

141. e.printStackTrace(); 

142. 

143. } 

150. 

151. intnFileLength=-1; 

152. 

154. 

155. URLurl=newURL(siteInfoBean.getSSiteURL()); 

160. 

161. intresponseCode=httpConnection.getResponseCode(); 

162. 

163. if(responseCode>=400){ 

164. 

165. processErrorCode(responseCode); 

166. 

168. 

169. } 

176. 

177. if(sHeader!=null){ 

178. 

179. if(sHeader.equals("Content-Length")){ 

180. 

181. nFileLength=Integer.parseInt(httpConnecti

on.getHeaderField(sHeader)); 

182. 

183. break; 

184. 

191. break; 

192. 

193. } 

194. 

195. } 