Android Service下载文件并自定义通知提示下载

最近要做一个更新sdk,里面用到了service后台下载,自定义通知提示下载进度,下面直接贴上代码.

下面是UpdateUtils.java ,告诉你如何使用

package com.cnziz.updatelib;

import com.cnziz.updatelib.download.DownloadServices;
import com.cnziz.updatelib.utils.Listener.onUpdateListener;

import android.content.Context;
import android.content.Intent;

public class UpdateUtils {

    public static UpdateUtils mUpdateUtils;

    public static UpdateUtils getInstanse(){
        if (null == mUpdateUtils) {
            mUpdateUtils = new UpdateUtils();
        }
        return mUpdateUtils;
    }

    public void update(Context context, String appInfo, onUpdateListener mUpdateListener){
        String url = "https://qd.myapp.com/myapp/qqteam/AndroidQQ/mobileqq_android.apk";
        String filePath = "/sdcard/download";
        download(context, url, filePath, mUpdateListener);
    }
    /** * 下载更新 * @param context * @param url 下载地址 * @param filePath 保存目录 * @param mUpdateListener */
    public void download(Context context, String url, String filePath, onUpdateListener mUpdateListener){
        Intent intent = new Intent(context, DownloadServices.class);
        intent.putExtra("url", url);
        intent.putExtra("file_path", filePath);
        context.startService(intent);
    }
}

DownloadService.java

package com.cnziz.updatelib.download;

import java.io.File;
import java.io.IOException;

import android.app.Notification;
import android.app.PendingIntent;
import android.app.Service;
import android.content.Intent;
import android.net.Uri;
import android.os.Environment;
import android.os.Handler;
import android.os.IBinder;
import android.os.Message;
import android.util.Log;

import com.cnziz.updatelib.R;
import com.cnziz.updatelib.utils.Listener.onUpdateListener;
import com.cnziz.updatelib.utils.LogUtils;

public class DownloadServices extends Service {
    private final static int DOWNLOAD_COMPLETE = -2;
    private final static int DOWNLOAD_FAIL = -1;

    // 自定义通知栏类
    MyNotification myNotification;

    String filePathString; // 下载文件绝对路径(包括文件名)

    // 通知栏跳转Intent
    private Intent updateIntent = null;

    private PendingIntent updatePendingIntent = null;

    DownFileThread downFileThread; // 自定义文件下载线程

    private onUpdateListener mUpdateListener;

    private Handler updateHandler = new Handler() {
        @Override
        public void handleMessage(Message msg) {
            switch (msg.what) {
            case DOWNLOAD_COMPLETE:
                // 点击安装PendingIntent
                Uri uri = Uri.fromFile(downFileThread.getApkFile());
                Intent installIntent = new Intent(Intent.ACTION_VIEW);
                installIntent.setDataAndType(uri,
                        "application/vnd.android.package-archive");
                installIntent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
                startActivity(installIntent);
// updatePendingIntent = PendingIntent.getActivity(
// DownloadServices.this, 0, installIntent, 0);
// myNotification.changeContentIntent(updatePendingIntent);
// myNotification.notification.defaults = Notification.DEFAULT_SOUND;// 铃声提醒
// myNotification.changeNotificationText("下载完成，请点击安装！");

                // 停止服务
                // myNotification.removeNotification();
                stopSelf();
                break;
            case DOWNLOAD_FAIL:
                // 下载失败
                // myNotification.changeProgressStatus(DOWNLOAD_FAIL);
                myNotification.changeNotificationText("文件下载失败！");
                mUpdateListener.downloadFail();
                stopSelf();
                break;
            default: // 下载中
                LogUtils.e("service", "index" + msg.what);
                // myNotification.changeNotificationText(msg.what+"%");
                myNotification.changeProgressStatus(msg.what);
            }
        }
    };

    public DownloadServices() {
        // TODO Auto-generated constructor stub
        // mcontext=context;
        LogUtils.e("service", "DownloadServices1");

    }

    @Override
    public void onCreate() {
        // TODO Auto-generated method stub
        LogUtils.e("service", "onCreate");
        super.onCreate();
    }

    @Override
    public void onDestroy() {
        // TODO Auto-generated method stub
        LogUtils.e("service", "onDestroy");
        if (downFileThread != null)
            downFileThread.interuptThread();
// if (null != myNotification) {
// myNotification.removeNotification();
// }
        stopSelf();
        super.onDestroy();
    }

    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {
        // TODO Auto-generated method stub
        LogUtils.e("service", "onStartCommand");
        String url = intent.getStringExtra("url");
        String filePath = intent.getStringExtra("file_path");
        mUpdateListener = (onUpdateListener) intent.getParcelableExtra("listener");
        // updateIntent = new Intent(this, MainActivity.class);
        // PendingIntent updatePendingIntent = PendingIntent.getActivity(this,
        // 0,
        // updateIntent, 0);
        myNotification = new MyNotification(this, updatePendingIntent, 1);

        // myNotification.showDefaultNotification(R.drawable.ic_launcher, "测试",
        // "开始下载");
        myNotification.showCustomizeNotification(R.drawable.ic_launcher,
                "测试下载", R.layout.notification);
        if (!filePath.endsWith("/")) {
            filePath = filePath +"/";
        }
        File path = new File(filePath);
        if (!path.exists()) {
            path.mkdir();
        }
        String[] s = url.split("/");
        filePathString = filePath + s[s.length-1];
        File file = new File(filePathString);
        if (!file.exists()) {
            try {
                file.createNewFile();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        // 开启一个新的线程下载，如果使用Service同步下载，会导致ANR问题，Service本身也会阻塞
        downFileThread = new DownFileThread(
                updateHandler,
                url,
                filePathString);
        new Thread(downFileThread).start();

        return super.onStartCommand(intent, flags, startId);
    }

    @Override
    @Deprecated
    public void onStart(Intent intent, int startId) {
        // TODO Auto-generated method stub
        LogUtils.e("service", "onStart");
        super.onStart(intent, startId);
    }

    @Override
    public IBinder onBind(Intent arg0) {
        // TODO Auto-generated method stub
        LogUtils.e("service", "onBind");
        return null;
    }

}

下载线程 DownFileThread.java

package com.cnziz.updatelib.download;

import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;

import com.cnziz.updatelib.utils.LogUtils;

import android.annotation.SuppressLint;
import android.os.Environment;
import android.os.Handler;
import android.os.Message;
import android.os.StrictMode;
import android.util.Log;

public class DownFileThread implements Runnable {
    public final static int DOWNLOAD_COMPLETE = -2;
    public final static int DOWNLOAD_FAIL = -1;
    public final static String TAG = "DownFileThread";
    Handler mHandler; // 传入的Handler,用于像Activity或service通知下载进度
    String urlStr; // 下载URL
    File apkFile; // 文件保存路径
    boolean isFinished; // 下载是否完成
    boolean interupted = false; // 是否强制停止下载线程

    public DownFileThread(Handler handler, String urlStr, String filePath) {
        LogUtils.i(TAG, urlStr);
        this.mHandler = handler;
        this.urlStr = urlStr;
        apkFile = new File(filePath);
        isFinished = false;
    }

    public File getApkFile() {
        if (isFinished)
            return apkFile;
        else
            return null;
    }

    public boolean isFinished() {
        return isFinished;
    }

    /** * 强行终止文件下载 */
    public void interuptThread() {
        interupted = true;
    }

    @SuppressLint("NewApi")
    @Override
    public void run() {
        // TODO Auto-generated method stub
        if (Environment.getExternalStorageState().equals(
                Environment.MEDIA_MOUNTED)) {
            java.net.URL url = null;
            HttpURLConnection conn = null;
            InputStream iStream = null;
            // if (DEVELOPER_MODE)
            {
                StrictMode
                        .setThreadPolicy(new StrictMode.ThreadPolicy.Builder()
                                .detectDiskReads().detectDiskWrites()
                                .detectNetwork() // or .detectAll() for all
                                                    // detectable problems
                                .penaltyLog().build());
                StrictMode.setVmPolicy(new StrictMode.VmPolicy.Builder()
                        .detectLeakedSqlLiteObjects()
                        .detectLeakedClosableObjects().penaltyLog()
                        .penaltyDeath().build());
            }
            try {
                url = new java.net.URL(urlStr);
                conn = (HttpURLConnection) url.openConnection();
                conn.setConnectTimeout(5 * 1000);
                conn.setReadTimeout(20 * 1000);
                iStream = conn.getInputStream();
            } catch (MalformedURLException e) {
                LogUtils.e(TAG, "MalformedURLException");
                e.printStackTrace();
            } catch (Exception e) {
                LogUtils.e(TAG, "获得输入流失败");
                e.printStackTrace();
            }
            FileOutputStream fos = null;
            try {
                fos = new FileOutputStream(apkFile);
            } catch (FileNotFoundException e) {
                LogUtils.i(TAG, "获得输出流失败：new FileOutputStream(apkFile);");
                e.printStackTrace();
            }
            BufferedInputStream bis = new BufferedInputStream(iStream);
            byte[] buffer = new byte[1024];
            int len;
            // 获取文件总长度
            int length = conn.getContentLength();
            double rate = (double) 100 / length; // 最大进度转化为100
            int timeLoad = length/100/1024;
            int total = 0;
            int times = 0;// 设置更新频率，频繁操作ＵＩ线程会导致系统奔溃
            try {
                LogUtils.e("threadStatus", "开始下载");
                while (false == interupted && ((len = bis.read(buffer)) != -1)) {
                    fos.write(buffer, 0, len);
                    // 获取已经读取长度
                    total += len;
                    int p = (int) (total * rate);
                    // Log.e("num", rate + "," + total + "," + p);
                    if (times >= timeLoad || p == 100) {
                        /* * 这是防止频繁地更新通知，而导致系统变慢甚至崩溃。 非常重要。。。。。 */
                        LogUtils.e("time", String.valueOf(times));
                        times = 0;
                        Message msg = Message.obtain();
                        msg.what = p;
                        mHandler.sendMessage(msg);
                    }
                    times++;
                }
                fos.close();
                bis.close();
                iStream.close();
                if (total == length) {
                    isFinished = true;
                    mHandler.sendEmptyMessage(DOWNLOAD_COMPLETE);
                    LogUtils.e(TAG, "下载完成结束");
                    return;
                }
                LogUtils.e(TAG, "强制中途结束");
                // mhandler.sendEmptyMessage(4);
            } catch (IOException e) {
                LogUtils.e(TAG, "异常中途结束");
                mHandler.sendEmptyMessage(DOWNLOAD_FAIL);
                e.printStackTrace();
            }
        } else {
            LogUtils.e(TAG, "外部存储卡不存在，下载失败！");
            mHandler.sendEmptyMessage(DOWNLOAD_FAIL);
        }
    }
}

自定义通知 MyNotification.java

package com.cnziz.updatelib.download;

import com.cnziz.updatelib.R;

import android.app.Notification;
import android.app.NotificationManager;
import android.app.PendingIntent;
import android.content.Context;
import android.widget.RemoteViews;

public class MyNotification {
    public final static int DOWNLOAD_COMPLETE = -2;
    public final static int DOWNLOAD_FAIL = -1;
    Context mContext; // Activity或Service上下文
    Notification notification; // notification
    NotificationManager nm;
    String titleStr; // 通知标题
    String contentStr; // 通知内容
    PendingIntent contentIntent; // 点击通知后的动作
    int notificationID; // 通知的唯一标示ID
    int iconID; // 通知栏图标
    long when = System.currentTimeMillis();
    RemoteViews remoteView = null; // 自定义的通知栏视图

    /** * * @param context * Activity或Service上下文 * @param contentIntent * 点击通知后的动作 * @param id * 通知的唯一标示ID */
    public MyNotification(Context context, PendingIntent contentIntent, int id) {
        // TODO Auto-generated constructor stub
        mContext = context;
        notificationID = id;
        this.contentIntent = contentIntent;
        this.nm = (NotificationManager) mContext
                .getSystemService(Context.NOTIFICATION_SERVICE);
    }

    /** * 显示自定义通知 * * @param icoId * 自定义视图中的图片ID * @param titleStr * 通知栏标题 * @param layoutId * 自定义布局文件ID */
    public void showCustomizeNotification(int icoId, String titleStr,
            int layoutId) {
        this.titleStr = titleStr;
        notification = new Notification(R.drawable.ic_launcher, titleStr, when);
        notification.flags = Notification.FLAG_ONLY_ALERT_ONCE;
        notification.flags |= Notification.FLAG_AUTO_CANCEL;
        notification.contentIntent = this.contentIntent;

        // 1、创建一个自定义的消息布局 view.xml
        // 2、在程序代码中使用RemoteViews的方法来定义image和text。然后把RemoteViews对象传到contentView字段
        if (remoteView == null) {
            remoteView = new RemoteViews(mContext.getPackageName(), layoutId);
            remoteView.setImageViewResource(R.id.ivNotification, icoId);
            remoteView.setTextViewText(R.id.tvTitle, titleStr);
            remoteView.setTextViewText(R.id.tvTip, "开始下载");
            remoteView.setProgressBar(R.id.pbNotification, 100, 0, false);
            notification.contentView = remoteView;
        }
        nm.notify(notificationID, notification);
    }

    /** * 更改自定义布局文件中的进度条的值 * * @param p * 进度值(0~100) */
    public void changeProgressStatus(int p) {
        if (notification.contentView != null) {
            if (p == DOWNLOAD_FAIL)
                notification.contentView.setTextViewText(R.id.tvTip, "下载失败！ ");
            else if (p == 100)
                notification.contentView.setTextViewText(R.id.tvTip,
                        "下载完成，请点击安装");
            else
                notification.contentView.setTextViewText(R.id.tvTip, "进度(" + p
                        + "%)");
            notification.contentView.setProgressBar(R.id.pbNotification, 100,
                    p, false);
        }
        nm.notify(notificationID, notification);
    }

    public void changeContentIntent(PendingIntent intent) {
        this.contentIntent = intent;
        notification.contentIntent = intent;
    }

    /** * 显示系统默认格式通知 * * @param iconId * 通知栏图标ID * @param titleText * 通知栏标题 * @param contentStr * 通知栏内容 */
    public void showDefaultNotification(int iconId, String titleText,
            String contentStr) {
        this.titleStr = titleText;
        this.contentStr = contentStr;
        this.iconID = iconId;

        notification = new Notification();
        notification.tickerText = titleStr;
        notification.icon = iconID;
        notification.flags = Notification.FLAG_INSISTENT;
        notification.flags |= Notification.FLAG_AUTO_CANCEL;
        notification.contentIntent = this.contentIntent;

        // 添加声音效果
        // notification.defaults |= Notification.DEFAULT_SOUND;

        // 添加震动,后来得知需要添加震动权限 : Virbate Permission
        // mNotification.defaults |= Notification.DEFAULT_VIBRATE ;

        // 添加状态标志
        // FLAG_AUTO_CANCEL 该通知能被状态栏的清除按钮给清除掉
        // FLAG_NO_CLEAR 该通知能被状态栏的清除按钮给清除掉
        // FLAG_ONGOING_EVENT 通知放置在正在运行
        // FLAG_INSISTENT 通知的音乐效果一直播放
        notification.flags = Notification.FLAG_ONLY_ALERT_ONCE;
        changeNotificationText(contentStr);
    }

    /** * 改变默认通知栏的通知内容 * * @param content */
    public void changeNotificationText(String content) {
        notification.setLatestEventInfo(mContext, titleStr, content,
                contentIntent);

        // 设置setLatestEventInfo方法,如果不设置会App报错异常
        // NotificationManager mNotificationManager = (NotificationManager)
        // getSystemService(Context.NOTIFICATION_SERVICE);
        // 注册此通知
        // 如果该NOTIFICATION_ID的通知已存在，会显示最新通知的相关信息 ，比如tickerText 等
        nm.notify(notificationID, notification);
    }

    /** * 移除通知 */
    public void removeNotification() {
        // 取消的只是当前Context的Notification
        nm.cancel(notificationID);
    }
}

主要代码都在这了,下面是完整的项目链接
https://github.com/yan1348/ServiceDownLoad