必威体育Betway必威体育官网
当前位置:首页 > IT技术

JAVA代码实现多线程下载

时间:2019-09-10 05:12:10来源:IT技术作者:seo实验室小编阅读:86次「手机版」
 

java多线程

  1. 首先,我们构建一个多线程下载工具类--DownUtil.代码如下:
import java.net.URL;
import java.net.HttpURLConnection; 
import java.io.InputStream ;
import java.io.RandomAccessFile;
public class DownUtil
{
	//定义下载资源路径
	private String path;
	//指定所下载的文件的保存位置
	private String targetFile;
	//定义需要使用多少个线程下载资源
	private int threadNum;
	//定义下载的线程对象
	private DownThread[] threads;
	//定义下载的文件的总大小
	private int fileSize;

	//构造器
	public DownUtil(String path,String targetFile,int threadNum)
	{
		this.path=path;
		this.threadNum=threadNum;
		//初始化threads数组
		threads=new DownThread[threadNum];
		this.targetFile=targetFile;
	}

	public void download() throws Exception
	{
		URL url=new URL(path);
		//1.通过调用URL对象的openConnection()方法来创建URLConnection对象
		HttpURLConnection conn=(HttpURLConnection)url.openConnection();
		//2.设置URLConnection的参数和普通请求属性
		conn.setConnectTimeout(5*1000);
		conn.setrequestMethod("GET");
		conn.setrequestproperty(
			"Accept",
			"image/gif,image/jpeg,image/pjpeg,image/pjpeg,"
			+"APPlication/x-shockwave-flash,application/xaml+xml,"
			+"application/vnd.ms-xpsdocument,application/x-ms-xbap,"
			+"application/x-ms-application,application/vnd.ms-excel,"
			+"application/vnd.ms-powerpoint,application/msword,*/*");
		conn.setRequestProperty("Accept-Language","zh-CN");
		conn.setRequestProperty("Charset","UTF-8");
		conn.setRequestProperty("Connection","Keep-Alive");

		//得到文件大小
		fileSize=conn.getcontentLength();
		conn.disconnect();
		int currentPartSize=fileSize/threadNum+1;
		RandomAccessFile file=new RandomAccessFile(targetFile,"rw");
		//设置本地文件的大小
		file.setLength(fileSize);
		file.close();
		for(int i=0;i<threadNum;i++)
		{
			//计算每个线程下载开始的位置
			int startPos=i*currentPartSize;
			//每个线程使用一个RandomAccessFile进行下载
			RandomAccessFile currentPart=new RandomAccessFile(targetFile,"rw");
			//定位该线程的下载位置
			currentPart.seek(startPos);
			//创建下载线程
			threads[i]=new DownThread(startPos,currentPartSize,currentPart);
			//启动下载线程
			threads[i].start();
		}
	}
	
	//获取下载的完成百分比
	public double getCompleteRate()
	{
		//统计多个线程已经下载的总大小
		int sumSize=0;
		for(int i=0;i<threadNum;i++)
		{
			sumSize+=threads[i].length;
		}
		//返回已经完成的百分比
		return sumSize*1.0/fileSize;
	}

	public class DownThread extends Thread
	{
		//当前线程的下载位置
		private int startPos;
		//定义当前线程负责下载的文件大小
		private int currentPartSize;
		//当前线程需要下载的文件块
		private RandomAccessFile currentPart;
		//定义该线程已下载的字节数
		public int length;

		//构造器
		public DownThread(int startPos,int currentPartSize,RandomAccessFile currentPart)
		{
			this.startPos=startPos;
			this.currentPartSize=currentPartSize;
			this.currentPart=currentPart;
		}
		
		//下载线程的主函数体
		public void run()
		{
			try
			{
				URL url=new URL(path);
				//1.通过调用URL对象的openConnection()方法来创建URLConnection对象
				HttpURLConnection conn=(HttpURLConnection)url.openConnection();
				//2.设置URLConnection的参数和普通请求属性
				conn.setConnectTimeout(5*1000);
				conn.setRequestMethod("GET");
				conn.setRequestProperty(
					"Accept",
					"image/gif,image/jpeg,image/pjpeg,image/pjpeg,"
					+"application/x-shockwave-flash,application/xaml+xml,"
					+"application/vnd.ms-xpsdocument,application/x-ms-xbap,"
					+"application/x-ms-application,application/vnd.ms-excel,"
					+"application/vnd.ms-powerpoint,application/msword,*/*");
				conn.setRequestProperty("Accept-Language","zh-CN");
				conn.setRequestProperty("Charset","UTF-8");
				//4.远程资源变为可用,程序可以通过输入流读取远程资源的数据
				InputStream inStream=conn.getInputStream();

				//跳过stratPos个字节,表明该线程只下载自己负责的那部分文件
                                //同时每个线程都会在指定的文件区域写入,所以不会因为多线程而出
                                //现资源组合的错乱,从指定位置读取资源,写入到指定位置                  
				inStream.skip(this.startPos);
				byte[] buffer=new byte[1024];//自己设置一个缓冲区
				int hasread=0;

				//-----------------读取网路数据,并写入本地文件------------------- 
				//inStream.read(buffer))==-1 表示读取到文件末尾
				while(length<currentPartSize&&(hasread=inStream.read(buffer))!=-1)
				{ 
					currentPart.write(buffer,0,hasread);
					//累计该线程下载的总大小
					length+=hasread;
					//System.out.println(getName()+" "+hasread);
				}
				//System.out.println(getName()+" length "+length+" currentPartSize "+currentPartSize);
                                //即使length>currentPartSize会是的该线程多写入几个字节,
                                //但是下一个线程会从文件的指定位置写入,就会覆盖掉之前线程多写的一部分内容
				currentPart.close();
				inStream.close();
			}
			catch (Exception e)
			{
				e.printstacktrace();
			}
		}

	}
}

上面代码的大致思路如下:

DownUtils类—启动、实现多线程下载的类;

DownThread—线程下载类,作为DownUtils类的辅助类,主要实现单个线程的下载逻辑。

程序中DownUtils类中的download()方法负责按如下步骤实现多线程下载

  1. 创建URL对象
  2. 获取指定URL对象所指向资源的大小(通过getConnectLength()方法获得),此处,用到了URLConnection类,该类代表Java应用程序和URL之间的通信链接。
  3. 本地磁盘上创建一个与网络资源具有同样大小的空文件
  4. 计算每个线程应该下载网络资源的哪个部分
  5. 依次创建、启动多个线程来下载网络资源的指定部分 

创建一个和URL的连接,并发送请求、读取此URL引用的资源需要如下几个步骤:

  1. 通过调用URL对象的openConnection()方法来创建URLConnection对象;
  2. 设置URLConnection的参数和普通请求属性;
  3. 如果只是发送GET方式请求,则使用connect()方法建立和远程资源之间的实际连接即可;如果需要发送POST方式的请求,则需要获取URLConnection实例对应的输出流来发送请求参数
  4. 远程资源变为可用,程序可以访问远程资源的头字段或通过输入流读取远程资源的数据

测试函数如下:

public class  MultiThreadDown
{
	public static void main(String[] args) 
		throws Exception
	{
		//初始化DownUtil对象
		final DownUtil downUtil=new DownUtil("http://img10.360buyimg.com/n0/jfs"+
		"/t18166/359/202833592/24066/9da49/5a628ffeN32d2b7c8.jpg","iOS.png",4);
		//开始下载
		downUtil.download();
		new Thread(()->
		{
			while(downUtil.getCompleteRate()<1)
			{
				//每隔0.1秒查询一次任务的完成进度
				//GUI程序中可根据该进度来绘制进度条
				System.out.println("已完成:"+downUtil.getCompleteRate());
				try
				{
					Thread.sleep(100);
				}
				catch (Exception ex){}
				
			}
		}).start();
	}
}

相关阅读

java stringbuilder 3种清空方法性能比较

java stringbuilder 清空问题 我也是碰到了这个问题才开始研究的,网上答案偏多,并且时间范围也比较大,各个版本的java 优化也不清楚

java中 new和Clone的区别

https://blog.csdn.net/iblade/article/details/80749148

java环境变量

首先右击【计算机】进入【属性】然后选择其中的【高级系统设置】 点击进入【高级】中的【环境变量】,进入环境变量编辑界面。 在下

java--受保护的访问(protected)

java中用于控制可见性的4个访问修饰符 private————仅对本类可见 public————对该项目中所有类可见 protected————对

java项目中设置 System.getProperty(“XXX”)自定义变量

经测试,本方法在windows环境下安装的tomcat是起作用的。在java项目中设置自定义变量的方法有很多种,如果你项目中使用 System.getP

分享到:

栏目导航

推荐阅读

热门阅读