终端开发

使用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

赞赏

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