开发必备

iMac配置基于crontab的定时任务 iMac配置支持读取NTFS硬盘 新iMac机器Android开发装机攻略 git常用命令整理(已包括branch、tag等持续更新~) iMac使用过程中的简单故障解决 iMac上RubyGems相关的问题汇总 开发中常用的文档管理、云端笔记等效率工具介绍 开发中常用的一些Chrome插件介绍 iMac(OS X)开发和使用中经验汇总(持续更新) iMac(OS X)日常开发中各种代理设置方法汇总(shell、Android Studio、gem、npm) Markdown格式优化及使用技巧 iMac下制作含透明度图片及判断图片透明度 Linux 下修改mysql的root密码 iMac(OS X)中设置大小写敏感的分区并切换 Linux & MacOS中一些常用命令备忘 Android开发常用命令备忘 在Linux服务器(ubuntu 16)上部署并配置git 在Linux服务器(ubuntu 16)上部署多套PHP环境 iMac(OS X)搭建私有maven仓库,提供Nexus Responsitory镜像 iMac(OS X)El Capitan 更新遇到的那些坑 vi常用命令 iMac(OS X)常用开发工具介绍 iMac(OS X)不可或缺的套件管理器 —— Homebrew 开发环境通用设置 windows中一些常用命令备忘 问题定位之快速模拟请求 Ant中的SVN 使用 开发中一些常用的工具链接(MD5、Timestamp等) markdown语法简介 开发中常用的一些知识检索链接(Markdown、SVN、Git等) SVN 常用命令 前端开发中常用资源收集(网站小图标、css、js 框架等) 开发中常用的一些API链接(天气预报、股票等)

终端开发

iMac上 Xcode 相关设置及常见问题 iOS开发 -- 首次使用Xcode运行iOS项目代码 使用Android Studio开发可独立运行(runnable)混淆过的Jar程序 Android安装包精简系列之资源精简 Android安装包精简系列之图片优化 Android安装包精简系列之为什么要优化精简安装包 Android安装包精简系列(总纲) Android安装包精简系列之图标转字体 gradle相关资料汇总 Android编译常见错误解决 Android编译编译速度提升 终端基于gradle的开源项目运行环境配置指引 制作终端产品演示的gif 一个关于APK Signature Scheme v2签名的神奇bug定位经历 如何随apk一起打包并使用SQLite SDK热更之gradle插件(如何在SDK代码中自动插桩及如何生成补丁包) 关于Android的APK Signature Scheme v2签名相关的资料汇总 封装HttpURLConnection实现的简单的网络请求库 一款基于Java环境的读取应用包名、签名、是否V2签名等基本信息的工具 Android的APK Signature Scheme v2签名及一款基于Java环境的校验工具介绍 如何使用Eclipse开发可执行Jar程序,并生成混淆过的jar程序 Android 相关的学习资料整理(持续更新) macOS(Sierra 10.12)上Android源码(AOSP)的下载、编译与导入到Android Studio Google也看不下去被玩坏的悬浮窗了么? Android开发常用工具资源 SDK热更系列之概述(持续整理编辑中~) SDK热更系列之SDKHotfix待优化点 Android 终端开发相关的一些神图(持续更新) SDK热更系列之Demo项目介绍概述 SDK热更系列之Demo体验方法 SDK热更系列之如何获取应用在当前设备上的so对应的指令集 Gradle Android插件使用的中那些特别注意的点 Experimental Plugin User Guide(From Android Tools Project Site) 基于Android Studio使用gradle构建包含jni以及so的构建实例 基于Instrumentation框架的自动化测试 - Android自动化测试系列(四) Instrumentation框架介绍-Android自动化测试系列(三) 关于终端设备的设备唯一性的那些事之MAC地址 关于终端设备的设备唯一性的那些事之IMEI Android 检查应用是否有root权限 ant常见错误解决方案 Gradle介绍 iMac上Android Studio 相关设置及常见问题 再说adb 再看Android官方文档之分享 再看Android官方文档之Fragment&数据保存 再看Android官方文档之Activity&Intent 再看Android官方文档之ActionBar和兼容性 adb shell input(Android模拟输入)简单总结 再看Android官方文档之建立第一个APP Android开发调试常用工具 ANR(网络资料整理) Java参数引用传递引发的惨案(又一次Java的String的“非对象”特性的踩坑经历) android.view.WindowManager$BadTokenException,Unable to add window Android签名校验机制(数字证书) Robotium二三事-Android自动化测试系列(二) Robotium介绍-Android自动化测试系列(一) Android开发中遇到的那些坑 Eclipse使用中部分经验总结 Android中关于Nativa编译(NDK、JNI)的一些问题 Android简单实现的多线程下载模块 Android内存耗用之VSS/RSS/PSS/USS adb Advanced Command URL编码中的空格(编码以后变为+) Android MD5后 bye数组转化为Hex字符串的坑(记一次为女神排忧解难的经历) Android学习之路 adb Base Command Android Log的那些坑…………

标签

android 46

Android编译常见错误解决 一个关于APK Signature Scheme v2签名的神奇bug定位经历 关于Android的APK Signature Scheme v2签名相关的资料汇总 封装HttpURLConnection实现的简单的网络请求库 一款基于Java环境的读取应用包名、签名、是否V2签名等基本信息的工具 Android的APK Signature Scheme v2签名及一款基于Java环境的校验工具介绍 如何使用Eclipse开发可执行Jar程序,并生成混淆过的jar程序 Android 相关的学习资料整理(持续更新) macOS(Sierra 10.12)上Android源码(AOSP)的下载、编译与导入到Android Studio Android开发常用命令备忘 Google也看不下去被玩坏的悬浮窗了么? Android开发常用工具资源 Android 终端开发相关的一些神图(持续更新) Gradle Android插件使用的中那些特别注意的点 Experimental Plugin User Guide(From Android Tools Project Site) iMac(OS X)搭建私有maven仓库,提供Nexus Responsitory镜像 基于Android Studio使用gradle构建包含jni以及so的构建实例 基于Instrumentation框架的自动化测试 - Android自动化测试系列(四) Instrumentation框架介绍-Android自动化测试系列(三) 关于终端设备的设备唯一性的那些事之MAC地址 关于终端设备的设备唯一性的那些事之IMEI Android 检查应用是否有root权限 iMac(OS X)El Capitan 更新遇到的那些坑 ant常见错误解决方案 Gradle介绍 iMac上Android Studio 相关设置及常见问题 再说adb 再看Android官方文档之分享 再看Android官方文档之Fragment&数据保存 再看Android官方文档之Activity&Intent 再看Android官方文档之ActionBar和兼容性 adb shell input(Android模拟输入)简单总结 再看Android官方文档之建立第一个APP Android开发调试常用工具 ANR(网络资料整理) Java参数引用传递引发的惨案(又一次Java的String的“非对象”特性的踩坑经历) android.view.WindowManager$BadTokenException,Unable to add window Android签名校验机制(数字证书) Eclipse使用中部分经验总结 Android内存耗用之VSS/RSS/PSS/USS adb Advanced Command URL编码中的空格(编码以后变为+) Android MD5后 bye数组转化为Hex字符串的坑(记一次为女神排忧解难的经历) Android学习之路 adb Base Command Android Log的那些坑…………

Android简单实现的多线程下载模块

2014年11月26日

在项目开发中遇到一个从服务器下载图片的需求。使用一些开源的库也能解决问题,但是对于这个简单的需求又有点重,因为项目对包大小的要求更高。 在四处浏览和自己努力下,最终写了一个可以满足以下需求的简单的工具类:

  • 多线程下载
  • 可以获取到下载进度
  • 所有下载结束以后有通知
  • 可以校验下载图片是否正确

github 地址:https://github.com/bihe0832/MyDemo/tree/master/Download

具体如下:

1. 下载对象类

class DownloadItem{
	// 文件的下载进度
	public float mPercent = 0;
	// 文件URL,需要是下载路径
	public URL mFileUrl;
	// 要下载文件的hash值,用于校验下载是否完整
	public String mHashValue;
	// 要下载的文件大小
	public long mFileLength;
	// 文件下载后的保存路径,需要是完整路径,包括文件名
	public String mLocalFilePath;
	public DownloadItem(URL url, String filePath,String hashValue) {
		this.mFileUrl = url;
		this.mLocalFilePath = filePath;
		this.mHashValue = hashValue;
	}
	public DownloadItem() {
	}
}

2. 具体的实现

public class DownloadThread extends Thread {
	// 开始下载
	public final static int THREAD_BEGIN = 1;
	// 下载结束,图片正确
	public final static int THREAD_FINISHED_SUCC = 2;
	// 下载结束,图片错误
	public final static int THREAD_FINISHED_FAIL = 3;
	// 线程锁
	private static Lock sLock = new ReentrantLock();
	// 是否已经下载完成
	private static boolean sIsFinished = false;
	// 任务集合
	private static Queue<DownloadItem> needDownloadLists = new LinkedList<DownloadItem>();
	// 正在进行中的下载列表
	private static Queue<DownloadItem> downloadList = new LinkedList<DownloadItem>();
	public static final String LOG_TAG = "Download";
	//当前的下载线程已启动
	private boolean mIsStarted = false;
	//当前的下载线程下载的图片
	private DownloadItem mDownloadItem = null;
	
	public DownloadThread(DownloadItem tempDownloadItem) {
		mDownloadItem = tempDownloadItem;
	}

	public static void addToDownloadQueue(URL url, String filePath,String hashValue) {
		if(null == url || T.ckIsEmpty(filePath) || T.ckIsEmpty(hashValue)){
			Logger.w("url or filePath or hashValue is null");
			return ;
		}
		sLock.lock();
		try {
			DownloadItem tempDownloadThread = new DownloadItem(url,filePath,hashValue);
		    if(!needDownloadLists.contains(tempDownloadThread)){
		        needDownloadLists.add(tempDownloadThread);
		    }
		    DownloadThread.setFinished(false);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            sLock.unlock();
        }
		Message message = new Message();
		message.what = DownloadThread.THREAD_BEGIN;
		myHandler.sendMessage(message);
	}

	// 开始下载任务
	@Override
	public void run() {
		this.mIsStarted = true;
		BufferedInputStream bis = null;
		BufferedOutputStream bos = null;
		try {
			HttpURLConnection conn = (HttpURLConnection) this.mDownloadItem.mFileUrl
					.openConnection(); // 建立一个远程连接句柄,此时尚未真正连接
			conn.setConnectTimeout(5 * 1000); // 设置连接超时时间为5秒
			conn.setRequestMethod("GET"); // 设置请求方式为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("Charset", "UTF-8"); // 设置客户端编码
			conn.setRequestProperty(
					"User-Agent",
					"Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 5.2; Trident/4.0; .NET CLR 1.1.4322; .NET CLR 2.0.50727; .NET CLR 3.0.04506.30; .NET CLR 3.0.4506.2152; .NET CLR 3.5.30729)"); // 设置用户代理
			conn.setRequestProperty("Connection", "Keep-Alive"); // 设置Connection的方式
			conn.connect(); // 和远程资源建立真正的连接,但尚无返回的数据流

			this.mDownloadItem.mFileLength = conn.getContentLength();
			byte[] buffer = new byte[4096]; // 下载的缓冲池为4KB
			bis = new BufferedInputStream(conn.getInputStream()); 
			File tempPic = new File(this.mDownloadItem.mLocalFilePath+"_temp");
			// 后续可以修改这部分内容,即可实现断点续传
			if (tempPic.exists()) {
				delFileByPath(this.mDownloadItem.mLocalFilePath+"_temp");
			}
			bos = new BufferedOutputStream(new FileOutputStream(tempPic));
			long downloadLength = 0;// 当前已下载的文件大小
			int bufferLength = 0;
			MessageDigest md5 = MessageDigest.getInstance("MD5");
			String picMd5 = "";
			while ((bufferLength = bis.read(buffer)) != -1) {
				bos.write(buffer, 0, bufferLength);
				md5.update(buffer, 0, bufferLength);
				bos.flush();
				// 计算当前下载进度
				downloadLength += bufferLength;
				this.mDownloadItem.mPercent = downloadLength / this.mDownloadItem.mFileLength;
			}
			byte[] bs = md5.digest();
			picMd5 = HexUtil.bytes2HexStr(bs).toLowerCase(Locale.CHINA);
			//下载完成,对比md5
			Message msg = new Message();
			msg.obj = this.mDownloadItem;
			if(picMd5.equalsIgnoreCase(this.mDownloadItem.mHashValue)){
				File localFile = new File(this.mDownloadItem.mLocalFilePath);
				if (localFile.exists()) {
					delFileByPath(this.mDownloadItem.mLocalFilePath);
				}
				boolean flag = tempPic.renameTo(localFile);
				if(flag){
					msg.what = THREAD_FINISHED_SUCC;
					Logger.d("rename pic succ:"+this.mDownloadItem.mLocalFilePath);
				}else{
					msg.what = THREAD_FINISHED_FAIL;
					Logger.d("rename pic failed:"+this.mDownloadItem.mLocalFilePath);
				}
			}else{
				msg.what = THREAD_FINISHED_FAIL;
				Logger.w("picMd5:"+picMd5+";hashValue:"+this.mDownloadItem.mHashValue);
				delFileByPath(this.mDownloadItem.mLocalFilePath);
			}
			// 发送下载完毕的消息
			DownloadThread.myHandler.sendMessage(msg);
		} catch (Exception e) {
			e.printStackTrace();
			// 这里处理下载失败(建议发送下载失败的消息)
		} finally {
			try {
				if (bis != null) {
					bis.close();
				}
				if (bos != null) {
					bos.close();
				}
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
	
	private static boolean isFinished() {
		return sIsFinished;
	}
	
	private static void setFinished(boolean isFinished) {
		sIsFinished = isFinished;
	}

	private boolean isStarted() {
		return mIsStarted;
	}

	public static void delFileByPath(String filePath){
		if(T.ckIsEmpty(filePath)){
			return ;
		}
		File tempPicFile = new File(filePath);
		if(null != tempPicFile){
			tempPicFile.delete();
		}
	}

	private static Handler myHandler = new Handler() {

		@Override
		public void handleMessage(Message msg) {
			Message message = new Message();
			DownloadItem tempDownloadItem = new DownloadItem();
			switch (msg.what) {
			case DownloadThread.THREAD_BEGIN:
				sLock.lock();
				if (!needDownloadLists.isEmpty()) {
					do{
						tempDownloadItem = needDownloadLists.poll();
						if(!downloadList.contains(tempDownloadItem)){
							DownloadThread tempDownloadThread = new DownloadThread(tempDownloadItem);
							if (!tempDownloadThread.isStarted()) {
								tempDownloadThread.start();
							}
							downloadList.add(tempDownloadItem);
						}
					}while(!downloadList.contains(tempDownloadItem));
					
				} else {
					if(!downloadList.isEmpty()){
						//没有新的要下载图片了
						Logger.d("no new task");
					}else{
						// 下载已经完成了
						if(DownloadThread.isFinished()){
							//下载结束不重复通知
							Logger.d("all task finished have been notified");
						}else{
							DownloadThread.setFinished(true);
							Logger.d("all task finished");
						}
					}
				}
				sLock.unlock();
				break;
			case DownloadThread.THREAD_FINISHED_SUCC:
				sLock.lock();
				tempDownloadItem = (DownloadItem) msg.obj;
				if(downloadList.contains(tempDownloadItem)){
					//移除
					downloadList.remove(tempDownloadItem);
				}
				message.what = DownloadThread.THREAD_BEGIN;
				sendMessage(message);
				sLock.unlock();
				break;
			case DownloadThread.THREAD_FINISHED_FAIL:
				sLock.lock();
				tempDownloadItem = (DownloadItem) msg.obj;
				if(downloadList.contains(tempDownloadItem)){
					//移除
					downloadList.remove(tempDownloadItem);
				}
				message.what = DownloadThread.THREAD_BEGIN;
				sendMessage(message);
				sLock.unlock();
				break;
			}
		}

	};
	// 具体的功能测试和调用方法
	public static void main(String[] args)
    {
		//TODO 找个MSDK的日志
		addToDownloadQueue(null, null, null);
		addToDownloadQueue(null, null, null);
		addToDownloadQueue(null, null, null);
		addToDownloadQueue(null, null, null);
        
    }
}


PS:我的博客即将搬运同步至腾讯云+社区,邀请大家一同入驻:https://cloud.tencent.com/developer/support-plan?invite_code=10zhijuy24v4f

赞赏

取消
微信扫一扫,赞赏子勰
扫码支持
屌丝程序猿,鸡血攻城狮!努力学技术,潜心做精品!