优化:
合理利用服务器资源,将资源利用最大化,加快下载速度
一般有两种方式:
线程池里面有N个线程,多线程下载单个文件,将网络路径的文件流切割成多快,每个线程下载一小部分,然后写入到文件里面,组成一个文件 当有很多个文件需要下载的时候,调用某个方法,有个线程池,线程池大小假定是10,当有10个文件过来的时候,每个线程去下载一个文件即可
线程是进程中的一个独立控制单元,线程在控制着进程的执行,一个进程中至少有一个线程。多线程可以更好地利用cpu的资源,线程之
间还能进行数据共享。在Java中,一个线程是指进程中的一个执行流程,一个进程可以运行多个线程,Java中每个线程都有一个调用栈,
即使不在程序中创建任何新的线程,也有一个main()方法运行在一个线程内,称为主线程,一旦创建一个新的线程,就产生一个新的调用
栈。通过该专题课程的系统学习,让大家一次性搞明白Java中的多线程。
源码:
0准备
线程下载需要的数据建立对应的属性(开始位置,结束位置,线程数,并创建构造函数)
//多线程下载需要的信息 private long startIndex; private long endIndex; private int threadId; public DownLoad2(long startIndex, long endIndex, int threadId) { super(); this.startIndex = startIndex; this.endIndex = endIndex; this.threadId = threadId; }
具体的run方法中:
1通过URL和下载资源建立联系
//统一资源管理器,可以直接打开网络地址 URL url = new URL(DownLoadTest2.path); //因为是基于Http请求,获取httpUrlConnection,获取网络连接对象,和服务器建立联系 HttpURLConnection conn = (HttpURLConnection) url.openConnection();
2设置参数,读取的范围
//设置参数 conn.setRequestMethod("GET"); conn.setConnectTimeout(50000);//连接超时 conn.setReadTimeout(50000);//读取超时 conn.addRequestProperty("Range", "bytes="+startIndex+"-"+endIndex);//设置读取范围
3开始进行文件的读取和写入(保护文件读取时的判断(是否读取成功))
if(conn.getResponseCode()==206) {//部分数据ok //取出连接中的数据 InputStream is = conn.getInputStream(); //提供一个接收的地方(本地接收) File file = new File("D:\\upload\\MSangoSetup2.0.0.80.zip"); //输出流,开始写数据,随机读写流 RandomAccessFile raf = new RandomAccessFile(file, "rwd"); raf.seek(startIndex);//跳转到线程开始的位置 //具体的读写操作 byte [] buf= new byte[8192];//字节数组,提高读取速度 int len=0;//字节数组读取的长度 while((len=is.read(buf))!=-1) { raf.write(buf, 0, len); } raf.close(); is.close(); //线程完成下载,完成下载线程数加一 DownLoadTest2.okThread++; //同步代码块,线程下载数量和总线程数量一致时,完成下载线程数量归零 synchronized (DownLoadTest2.path) { System.out.println("线程:"+this.getName()+threadId+"下载完毕... "+DownLoadTest2.okThread); if(DownLoadTest2.okThread==DownLoadTest2.countThread) { DownLoadTest2.okThread=0; } } }
多线下载测试类
准备
static String path = "http://download2.m3guo.com/MSangoSetup1.2.22.51.exe";//资源地址 static int countThread=14;//线程数 static int okThread=0;//和线程数有关,记录线程完成的个数
main方法内容
1通过URL和下载资源建立联系
//统一资源管理器,可以直接打开网络地址 URL url = new URL(DownLoadTest2.path); //因为是基于Http请求,获取httpUrlConnection,获取网络连接对象,和服务器建立联系 HttpURLConnection conn = (HttpURLConnection) url.openConnection();
2设置参数
//设置参数 conn.setRequestMethod("GET"); conn.setConnectTimeout(50000);//连接超时 conn.setReadTimeout(50000);//读取超时
3判断资源链接是否建立成功,成功进行多线程下载分配
if(conn.getResponseCode()==200) {//成功 //获取文件总长度 long count = conn.getContentLengthLong(); //每个线程下载的大小 long size = count/countThread; //开启线程进行下载 for (int i = 0; i < countThread; i++) { long startIndex=size*i;//开始位置 0 102.4 long endIndex=size*(i+1);//结束位置 102.4 204.8 DownLoad2 thread = new DownLoad2(startIndex,endIndex , i); thread.start(); } }