Android下载进度监听和通知的处理详解
作者:mChenys 发布时间:2022-03-27 08:39:02
标签:Android,下载进度,监听,通知
本文实例为大家分享了Android下载进度监听和通知的具体代码,供大家参考,具体内容如下
下载管理器
关于下载进度的监听,这个比较简单,以apk文件下载为例,需要处理3个回调函数,分别是:
1.下载中
2.下载成功
3.下载失败
因此对应的回调接口就有了:
public interface DownloadCallback {
/**
* 下载成功
* @param file 目标文件
*/
void onComplete(File file);
/**
* 下载失败
* @param e
*/
void onError(Exception e);
/**
* 下载中
* @param count 总大小
* @param current 当前下载的进度
*/
void onLoading(long count, long current);
}
接下来就是线程池的管理了,当然你也可以直接使用Executors工具类中提供的几个静态方法来创建线程池,这里我是手动创建线程池的,代码如下:
public class ThreadManager {
private static ThreadPool mThreadPool;
/**
* 获取线程池
*
* @return
*/
public static ThreadPool getThreadPool() {
if (null == mThreadPool) {
synchronized (ThreadManager.class) {
if (null == mThreadPool) {
// cpu个数
int cpuNum = Runtime.getRuntime().availableProcessors();
//线程个数
int count = cpuNum * 2 + 1;
mThreadPool = new ThreadPool(count, count, 0);
}
}
}
return mThreadPool;
}
public static class ThreadPool {
int corePoolSize;// 核心线程数
int maximumPoolSize;// 最大线程数
long keepAliveTime;// 保持活跃时间(休息时间)
private ThreadPoolExecutor executor;
/**
* 构造方法初始化
*
* @param corePoolSize
* @param maximumPoolSize
* @param keepAliveTime
*/
private ThreadPool(int corePoolSize, int maximumPoolSize, long keepAliveTime) {
this.corePoolSize = corePoolSize;
this.maximumPoolSize = maximumPoolSize;
this.keepAliveTime = keepAliveTime;
}
private static final ThreadFactory sThreadFactory = new ThreadFactory() {
private final AtomicInteger mCount = new AtomicInteger(1);
public Thread newThread(Runnable r) {
return new Thread(r, "ThreadManager #" + mCount.getAndIncrement());
}
};
/**
* 执行线程任务
*
* @param r
*/
public void execute(Runnable r) {
//参1:核心线程数;参2:最大线程数;参3:保持活跃时间(休息时间);参4:活跃时间单位;参5:线程队列;参6:线程工厂;参7:异常处理策略
if (null == executor) {
executor = new ThreadPoolExecutor(corePoolSize,
maximumPoolSize,
keepAliveTime,
TimeUnit.SECONDS,
new LinkedBlockingQueue<Runnable>(),
sThreadFactory/*Executors.defaultThreadFactory()*/,
new ThreadPoolExecutor.AbortPolicy());
}
// 将当前Runnable对象放在线程池中执行
executor.execute(r);
}
/**
* 从线程池的任务队列中移除一个任务
* 如果当前任务已经是运行状态了,那么就表示不在任务队列中了,也就移除失败.
*/
public void cancle(Runnable r) {
if (null != executor && null != r) {
executor.getQueue().remove(r);
}
}
/**
* 是否关闭了线程池
* @return
*/
public boolean isShutdown(){
return executor.isShutdown();
}
/**
* 关闭线程池
*/
public void shutdown() {
executor.shutdown();
}
}
}
接下来就是一个下载管理器的封装了.
public class DownloadManager {
private DownloadCallback callback;
private Context context;
private String url;
private String fileName;
/**
* 初始化
* @param context 上下文
* @param url 目标文件url
* @param fileName 下载保存的文件名
* @param callback 下载回调函数
*/
public DownloadManager(final Context context, final String url, final String fileName, DownloadCallback callback) {
this.context = context;
this.url = url;
this.fileName = fileName;
this.callback = callback;
}
/**
* 开始下载
*/
public void startDownload() {
if (null == callback) return;
ThreadManager.getThreadPool().execute(new Runnable() {
@Override
public void run() {
HttpURLConnection conn = null;
try {
conn = (HttpURLConnection) new URL(url).openConnection();
conn.setRequestMethod("GET");
conn.setReadTimeout(5000);
conn.setConnectTimeout(10000);
long total = conn.getContentLength();
long curr = 0;
File file = new File(PathUtils.getDirectory(context, "apk"), fileName);
if (!file.exists()) {
file.createNewFile();
} else {
file.delete();
}
FileOutputStream fos = new FileOutputStream(file);
if (200 == conn.getResponseCode()) {
InputStream in = conn.getInputStream();
byte[] buff = new byte[1024];
int len = 0;
while ((len = in.read(buff)) != -1) {
fos.write(buff, 0, len);
curr += len;
callback.onLoading(total, curr);
}
in.close();
fos.close();
if (curr == total) {
callback.onComplete(file);
} else {
throw new Exception("curr != total");
}
} else {
throw new Exception("" + conn.getResponseCode());
}
} catch (Exception e) {
e.printStackTrace();
callback.onError(e);
} finally {
if (null != conn) {
conn.disconnect();
}
}
}
});
}
}
涉及的工具类如下:
PathUtils
public class PathUtils {
/**
* 获取cache目录下的rootDir目录
*
* @param context
* @param rootDir
* @return
*/
public static File getDirectory(Context context, String rootDir) {
String cachePath = context.getApplicationContext().getCacheDir().getAbsolutePath();
if (Environment.MEDIA_MOUNTED.equals(Environment.getExternalStorageState())
|| !Environment.isExternalStorageRemovable()) {
if (Build.VERSION.SDK_INT <= 8) {
cachePath = Environment.getExternalStorageDirectory().getAbsolutePath();
} else if (context.getApplicationContext().getExternalCacheDir() != null) {
cachePath = context.getApplicationContext().getExternalCacheDir().getAbsolutePath();
}
}
File rootF = new File(cachePath + File.separator + rootDir);
if (!rootF.exists()) {
rootF.mkdirs();
}
//修改目录权限可读可写可执行
String cmd = "chmod 777 -R " + rootF.getPath();
CmdUtils.execCmd(cmd);
return rootF;
}
}
CmdUtils
public class CmdUtils {
public static void execCmd(String cmd) {
try {
Runtime.getRuntime().exec(cmd);
} catch (IOException e) {
e.printStackTrace();
}
}
}
下载通知服务
同样以apk下载为例,要实现下载通知服务的话,就用到了Notification和Service,Notification用来通知下载进度并显示给用户看,Service用于后台默默的下载文件,这里我用到了IntentService,它的好处在于任务执行完毕后会自动关闭服务.同时程序用如果其他地方还想监听到下载的进度,那么可以在IntentService下载服务中通过发送广播告知进度.
ok,下面的代码可以直接用户实现apk的升级更新的操作.
public class UpdateService extends IntentService {
private File apkFile;
private String url;
private String fileName;
private NotificationCompat.Builder builderNotification;
private NotificationManager updateNotificationManager;
private int appNameID;
private int iconID;
private PendingIntent updatePendingIntent;
private boolean isUpdating;
public static final String ACTION_UPDATE_PROGRESS = "blog.csdn.net.mchenys.mobilesafe.ACTION_UPDATE_PROGRESS";
private Handler updateHandler = new Handler() {
public void handleMessage(Message msg) {
switch (msg.what) {
case 0:
UpdateService.this.onFailNotification();
break;
case 1:
UpdateService.this.downComplete();
break;
}
super.handleMessage(msg);
}
};
public UpdateService() {
super("UpdateService");
}
/**
* 开始更新
*
* @param context
* @param url 更新的url
* @param fileName 下载保存apk的文件名称
*/
public static void startUpdate(Context context, String url, String fileName) {
Intent intent = new Intent(context, UpdateService.class);
intent.putExtra("url", url);
intent.putExtra("fileName", fileName);
context.startService(intent);
}
@Override
protected void onHandleIntent(Intent intent) {
//WorkerThread
if (!this.isUpdating && intent != null) {
initData(intent);
initNotification();
downloadFile(true);
}
}
/**
* 初始数据
*
* @param intent
*/
private void initData(Intent intent) {
this.isUpdating = true;
this.url = intent.getStringExtra("url");
this.fileName = intent.getStringExtra("fileName");
this.apkFile = new File(PathUtils.getDirectory(getApplicationContext(), "mobilesafe"), fileName);
if (!this.apkFile.exists()) {
try {
this.apkFile.createNewFile();
} catch (IOException e) {
e.printStackTrace();
}
} else {
this.apkFile.delete();
}
this.appNameID = R.string.app_name;
this.iconID = R.mipmap.ic_logo;
}
/**
* 初始化通知
*/
private void initNotification() {
Intent updateCompletingIntent = new Intent();
updateCompletingIntent.setFlags(Intent.FLAG_ACTIVITY_SINGLE_TOP);
updateCompletingIntent.setClass(this.getApplication().getApplicationContext(), UpdateService.class);
this.updatePendingIntent = PendingIntent.getActivity(this, this.appNameID, updateCompletingIntent, PendingIntent.FLAG_CANCEL_CURRENT);
this.updateNotificationManager = (NotificationManager) this.getApplicationContext().getSystemService(Context.NOTIFICATION_SERVICE);
this.builderNotification = new NotificationCompat.Builder(this.getApplicationContext());
this.builderNotification.setSmallIcon(this.iconID).
setContentTitle(this.getResources().getString(this.appNameID)).
setContentIntent(updatePendingIntent).
setAutoCancel(true).
setTicker("开始更新").
setDefaults(1).
setProgress(100, 0, false).
setContentText("下载进度").
build();
this.updateNotificationManager.notify(this.iconID, this.builderNotification.build());
}
/**
* 开始下载apk
*
* @param append 是否支持断点续传
*/
private void downloadFile(final boolean append) {
final Message message = updateHandler.obtainMessage();
int currentSize = 0; //上次下载的大小
long readSize = 0L;//已下载的总大小
long contentLength = 0;//服务器返回的数据长度
if (append) {
FileInputStream fis = null;
try {
fis = new FileInputStream(UpdateService.this.apkFile);
currentSize = fis.available();//获取上次下载的大小,断点续传可用
} catch (IOException e) {
e.printStackTrace();
} finally {
if (fis != null) {
try {
fis.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
HttpURLConnection conn = null;
InputStream is = null;
FileOutputStream fos = null;
try {
conn = (HttpURLConnection) new URL(UpdateService.this.url).openConnection();
conn.setRequestProperty("User-Agent", "Android");
if (currentSize > 0) {
conn.setRequestProperty("RANGE", "bytes=" + currentSize + "-");
}
conn.setConnectTimeout(10000);
conn.setReadTimeout(20000);
contentLength = conn.getContentLength();
if (conn.getResponseCode() == 404) {
throw new Exception("Cannot find remote file:" + UpdateService.this.url);
}
is = conn.getInputStream();
fos = new FileOutputStream(UpdateService.this.apkFile, append);
//实时更新通知
UpdateService.this.builderNotification.setSmallIcon(iconID).
setContentTitle(UpdateService.this.getResources().getString(UpdateService.this.appNameID)).
setContentIntent(updatePendingIntent).
setAutoCancel(true).
setTicker("正在更新").
setDefaults(0).
setContentText("下载进度").
build();
byte[] buffer = new byte[8*1024];
int len = 0;
while ((len = is.read(buffer)) != -1) {
fos.write(buffer, 0, len);
readSize += len;//累加已下载的大小
int progress = (int) (readSize * 100 / contentLength);
Log.d("UpdateService", (readSize * 100 / contentLength)+"");
if (progress % 8 == 0) {
UpdateService.this.builderNotification.setProgress(100, progress, false);
UpdateService.this.updateNotificationManager.notify(iconID, UpdateService.this.builderNotification.build());
//发送广播,通知外界下载进度
sendUpdateProgress(progress);
}
}
if (readSize == 0L) {
message.what = 0;
} else if (readSize == contentLength) {
message.what = 1;
sendUpdateProgress(100);
}
} catch (Exception e) {
e.printStackTrace();
message.what = 0;
} finally {
if (conn != null) {
conn.disconnect();
}
IOUtils.close(is);
IOUtils.close(fos);
updateHandler.sendMessage(message);
}
}
/**
* 发送更新进度
*
* @param progress
*/
private void sendUpdateProgress(int progress) {
Intent intent = new Intent(ACTION_UPDATE_PROGRESS);
intent.putExtra("progress", progress);
sendBroadcast(intent);
}
/**
* 下载失败通知用户重新下载
*/
private void onFailNotification() {
this.builderNotification.setSmallIcon(iconID).
setContentTitle("更新失败,请重新下载").
setContentIntent(updatePendingIntent).
setAutoCancel(true).
setTicker("更新失败").
setDefaults(1).
setProgress(100, 0, false).
setContentText("下载进度").
build();
this.updateNotificationManager.notify(iconID, this.builderNotification.build());
}
/**
* 下载完毕,后通知用户点击安装
*/
private void downComplete() {
UpdateService.this.isUpdating = false;
String cmd = "chmod 777 " + this.apkFile.getPath();
CmdUtils.execCmd(cmd);
Uri uri = Uri.fromFile(this.apkFile);
Intent updateCompleteIntent = new Intent("android.intent.action.VIEW");
updateCompleteIntent.addCategory("android.intent.category.DEFAULT");
updateCompleteIntent.setDataAndType(uri, "application/vnd.android.package-archive");
this.updatePendingIntent = PendingIntent.getActivity(this, this.appNameID, updateCompleteIntent, PendingIntent.FLAG_UPDATE_CURRENT);
this.builderNotification.setSmallIcon(this.iconID).
setContentTitle(this.getResources().getString(this.appNameID)).
setContentIntent(this.updatePendingIntent).
setAutoCancel(true).
setTicker("更新完成").
setDefaults(1).
setProgress(0, 0, false).
setContentText("更新完成,点击安装").
build();
this.updateNotificationManager.notify(this.iconID, this.builderNotification.build());
}
}
0
投稿
猜你喜欢
- 1.基本介绍Java自带日期格式化工具DateFormat ,但是DateFormat 的所有实现,包括 SimpleDateFormat
- 废话不多说了,直接给大家贴代码了,具体代码如下所示:package wxapi.WxHelper; import java.io.Buffe
- XML:Extensible Markup Language(可扩展标记语言)的缩写,是用来定义其它语言的一种元语言,其前身是SGML(St
- 最近我尝试使用ViewPager+GridView实现的,看起来一切正常,废话不多说,具体代码如下:如图是效果图 首先分析下思路1
- 背景环境需要设置代理才能够访问外部网络,如果只是运行java程序来访问网络,我们可以通过java -jar test.jar -Dproxy
- 1.MyBatis中map的应用1.1.应用场景假设,实体类,或者数据库中的表,字段或者参数过多,应当考虑使用Map!!!1.2.具体实现/
- 一、饿汉式单例类public class Singleton { privat
- Intellij IDEA 配置Subversion插件实现步骤详解在使用Intellij的过程中,突然发现svn不起效了,在VCS–》Ch
- public/protected/privatepublic表示公开,private表示私有,protected表示保护,什么都不写表示默认
- 本文参考于《深入理解Java虚拟机》内存分配与回收策略Java技术体系的自动内存管理,最根本的目标是自动化地解决两个问题:自动给对象分配内存
- 由于要做一个新项目,所以打算做一个简单的图片验证码。先说说思路吧:在服务端,从一个文件夹里面找出8张图片,再把8张图片合并成一张大图,在8个
- SnackBar是DesignSupportLibrary中的一个重要的控件,用于在界面下面提示一些关键信息,跟Toast不同的地方是Sna
- 前言在Android开发过程中,Bitmap往往会给开发者带来一些困扰,因为对Bitmap操作不慎,就容易造成OOM(Java.lang.O
- C语言运算符及其优先级汇总表口诀圆下箭头一顿号非凡增减富强针地长三乘除,四加减,五移位千万别把鱼忘记,它在盛饭的厨子里小灯大灯灯灯不等爸喂鱼
- MongoDB是介于关系数据库和非关系数据库之间的一种产品,文件的存储格式为BSON(一种JSON的扩展),这里就主要介绍Java通过使用m
- 命名空间提供了一种从逻辑上组织类的方式,防止命名冲突。几种常见语言C++命名空间是可以嵌套的嵌套的命名空间是指定义在其他命名空间中的命名空间
- 在学会了java中io流的使用后,我们对于数组的排序,又多了一种使用方法。大家知道流处理数据的效率是比较理想的,那么在具体操作数组排序上,很
- 如果我们遇到把excel表格中的数据导入到数据库,首先我们要做的是:将excel中的数据先读取出来。因此,今天就给大家分享一个读取Excel
- 一、前言spring cloud大行其道的当下,如果不了解基本原理那么是很纠结的(看见的都是 约定大于配置 ,但是原理呢?为什么要这么做?)
- FastJson是阿里开源的一个高性能的JSON框架,FastJson数据处理速度快,无论序列化(把JavaBean对象转化成Json格式的