使用ApacheHttpClient实现多线程下载的小例子 thrift client 多线程

原帖：http://zywang.iteye.com/blog/916489

网上类似的文章很多，参考了很多人的，大部分人都是用URLConnection写的。

原理一：HTTP多线程下载原理

1、发送一个含有Rang头的Head请求，如果返回状态码为206，则允许多线程下载

原理二：多线程下载原理

1、使用HttpClient的Head请求获取请求文件的信息

2、发送一个Rang的Head请求判断是否允许多线程下载

3、通过主任务创建多个分段下载线程，分段下载文件，然后用Java的随机读写文件类保存下载的内容

（等有时间了再添加内容吧，先简单写这么多）

调度功能代码片段

2. publicvoidstartDown()throwsException{
3. HttpClienthttpClient=newDefaultHttpClient();
4. try{
5. //获取下载文件信息
6. getDownloadFileInfo(httpClient);
7. //启动多个下载线程
8. startDownloadThread();
9. //开始监视下载数据
10. monitor();
11. }catch(Exceptione){
12. throwe;
13. }finally{
14. httpClient.getConnectionManager().shutdown();
15. }
16. }
19. privatevoidgetDownloadFileInfo(HttpClienthttpClient)throwsIOException,
20. ClientProtocolException,Exception{
21. HttpHeadhttpHead=newHttpHead(url);
22. HttpResponseresponse=httpClient.execute(httpHead);
23. //获取HTTP状态码
24. intstatusCode=response.getStatusLine().getStatusCode();
26. if(statusCode!=200)thrownewException("资源不存在!");
27. if(getDebug()){
28. for(Headerheader:response.getAllHeaders()){
29. System.out.println(header.getName()+":"+header.getValue());
30. }
31. }
33. //Content-Length
34. Header[]headers=response.getHeaders("Content-Length");
35. if(headers.length>0)
36. contentLength=Long.valueOf(headers[0].getValue());
38. httpHead.abort();
40. httpHead=newHttpHead(url);
41. httpHead.addHeader("Range","bytes=0-"+(contentLength-1));
42. response=httpClient.execute(httpHead);
43. if(response.getStatusLine().getStatusCode()==206){
44. acceptRanges=true;
45. }
46. httpHead.abort();
47. }
50. privatevoidstartDownloadThread()throwsIOException,
51. FileNotFoundException{
52. //创建下载文件
53. Filefile=newFile(localPath);
54. file.createNewFile();
55. RandomAccessFileraf=newRandomAccessFile(file,"rw");
56. raf.setLength(contentLength);
57. raf.close();
59. //定义下载线程事件实现类
60. DownloadThreadListenerlistener=newDownloadThreadListener(){
61. publicvoidafterPerDown(DownloadThreadEventevent){
62. //下载完一个片段后追加已下载字节数
63. synchronized(object){
64. DownloadTask.this.receivedCount+=event.getCount();
65. }
66. }
68. publicvoiddownCompleted(DownloadThreadEventevent){
69. //下载线程执行完毕后从主任务中移除
70. threads.remove(event.getTarget());
71. if(getDebug()){
72. System.out.println("剩余线程数："+threads.size());
73. }
74. }
75. };
77. //不支持多线程下载时
78. if(!acceptRanges){
79. if(getDebug()){
80. System.out.println("该地址不支持多线程下载");
81. }
82. //定义普通下载
83. DownloadThreadthread=newDownloadThread(url,0,contentLength,file,false);
84. thread.addDownloadListener(listener);
85. thread.start();
86. threads.add(thread);
87. return;
88. }
90. //每个请求的大小
91. longperThreadLength=contentLength/threadCount+1;
92. longstartPosition=0;
93. longendPosition=perThreadLength;
94. //循环创建多个下载线程
95. do{
96. if(endPosition>=contentLength)
97. endPosition=contentLength-1;
99. DownloadThreadthread=newDownloadThread(url,startPosition,endPosition,file);
100. thread.addDownloadListener(listener);
101. thread.start();
102. threads.add(thread);
104. startPosition=endPosition+1;//此处加1,从结束位置的下一个地方开始请求
105. endPosition+=perThreadLength;
106. }while(startPosition<contentLength);
107. }

分段下载线程代码片段：

爱华网本文地址 » http://www.aihuau.com/a/25101013/153041.html