java实现大文件下载(http方式)

java实现大文件下载，基于http方式，控件神马的就不说了。
思路：下载文件无非要读取文件然后写文件，主要这两个步骤，主要难点：
1.读文件，就是硬盘到内存的过程，由于jdk内存限制，不能读的太大。
2.写文件，就是响应到浏览器端的过程，http协议是短链接，如果写文件太慢，时间过久，会造成浏览器死掉。

知识点：

1.org.apache.http.impl.client.CloseableHttpClient  模拟httpClient客户端发送http请求，可以控制到请求文件的字节位置。
2.BufferedInputStream都熟悉，用它接受请求来的流信息缓存。
3.RandomAccessFile文件随机类，可以向文件写入指定位置的流信息。

• 1
• 2
• 3

基于以上信息，我的实现思路就是首先判断下载文件大小，配合多线程分割定制http请求数量和请求内容，响应到写入到RandomAccessFile指定位置中。在俗点就是大的http分割成一个个小的http请求，相当于每次请求一个网页。

废话不说，上代码。

DownLoadManagerTest类：

package xxxx;

import java.io.File;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.concurrent.CountDownLatch;
import org.apache.commons.lang.exception.ExceptionUtils;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.task.TaskExecutor;
import org.springframework.test.context.ActiveProfiles;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.AbstractTransactionalJUnit4SpringContextTests;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

/**
 * 
 * 文件下载管理类
 */
@RunWith(SpringJUnit4ClassRunner.class)
@ActiveProfiles("test")
@ContextConfiguration(locations={"classpath:test/applicationContext.xml"})
public class DownLoadManagerTest extends AbstractTransactionalJUnit4SpringContextTests{
	
	private static final Logger LOGGER = LoggerFactory.getLogger(DownLoadManagerTest.class);

	/**
	 * 
	 * 每个线程下载的字节数
	 */
	private long unitSize = 1000 * 1024;
	
	@Autowired
	private TaskExecutor taskExecutor;
	
	private CloseableHttpClient httpClient;
	
	private Long starttimes;
	
	private Long endtimes;
    
    @Before
    public void setUp() throws Exception{
    	starttimes = System.currentTimeMillis();
        System.out.println("测试开始....");
    }
    
    @After
    public void tearDown() throws Exception{
    	endtimes = System.currentTimeMillis();
        System.out.println("测试结束!!");
        System.out.println("********************");
        System.out.println("下载总耗时:"+(endtimes-starttimes)/1000+"s");
        System.out.println("********************");
    }

	public DownLoadManagerTest