activity和service通信：通过binder

举个我实际项目中的例子：在service中下载更新应用

首先是下载更新apk的service:

public class UpdateVersionService extends Service {    private final String tag = "young";    private Context context = this;    private BaseApplication application;    private DownloadBinder binder;    private String apkUrl;// apk下载地址    private String saveFileName;// 下载安装包路径    private Thread downLoadThread;// 下载apk线程    private int progress;// 进度条    private final int NOTIFY_ID = 0;    private NotificationManager notificationManager;    private Notification notification;// 消息通知    private Builder builder = null;    private boolean canceled;    private boolean serviceIsDestory = false;    private int lastRate = 0;    private Handler handler = new Handler() {        public void handleMessage(android.os.Message msg) {            switch (msg.what) {                case 0:                    //  Log.v(tag, "success---");下载完成并安装                    application.setDownload(false);                    notificationManager.cancel(NOTIFY_ID);                    installApk();                    break;                case 1:                    int rate = msg.arg1;                    //   Log.v(tag, "rate---");刷新进度                    application.setDownload(true);                    if (rate < 100) {                        RemoteViews remoteView = notification.contentView;                        remoteView.setTextViewText(R.id.tv_progress, rate + "%");                        remoteView.setProgressBar(R.id.progressbar, 100, rate,                                false);                    } else {                        //    Log.v(tag, "下载完成");                        notification.flags = Notification.FLAG_AUTO_CANCEL;                        Intent intent = new Intent(context, MainActivity.class);                        PendingIntent contentIntent = PendingIntent.getActivity(                                context, 0, intent,                                PendingIntent.FLAG_UPDATE_CURRENT);                        builder.setContentTitle(getResources().getString(                                R.string.download_finish_title));                        builder.setContentText(getResources().getString(                                R.string.download_finish_text));                        notification.contentIntent = contentIntent;                        serviceIsDestory = true;                        stopSelf();                    }                    notificationManager.notify(NOTIFY_ID, notification);                    break;                case 2:                    // Log.v(tag, "cancel---");取消下载                    application.setDownload(false);                    notificationManager.cancel(NOTIFY_ID);                    break;                case 3:                    // Log.v(tag, "error---");出现异常                    application.setDownload(true);                    notificationManager.cancel(NOTIFY_ID);                    Toast.makeText(context,                            getResources().getString(R.string.download_alter),                            Toast.LENGTH_SHORT).show();                    stopSelf();                    break;            }        };    };    /**     * 安装APK     */    private void installApk() {        File apkfile = new File(saveFileName);        if (!apkfile.exists()) {            ToastUtil.toasts(context,                    getResources().getString(R.string.download_alter));            return;        }        Intent intent = new Intent(Intent.ACTION_VIEW);        intent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK);        intent.setDataAndType(Uri.parse("file://" + apkfile.toString()),                "application/vnd.android.package-archive");        startActivity(intent);    }    @Override    public void onCreate() {        // TODO Auto-generated method stub        super.onCreate();        //  Log.v(tag, "onCreate");        application = (BaseApplication) getApplication();        this.binder = new DownloadBinder();        notificationManager = (NotificationManager) this                .getSystemService(android.content.Context.NOTIFICATION_SERVICE);    }    @Override    public int onStartCommand(Intent intent, int flags, int startId) {        // TODO Auto-generated method stub        //  Log.v(tag, "onStartCommand");        apkUrl = intent.getStringExtra("apkUrl");        if (!StringUtil.isEmpty(apkUrl)) {            saveFileName =  FileUtils.getAppPath(context, apkUrl).getPath();        }        return super.onStartCommand(intent, flags, startId);    }    @Override    public void onDestroy() {        // TODO Auto-generated method stub        super.onDestroy();        //Log.v(tag, "onDestroy");        application.setDownload(false);    }    @Override    public IBinder onBind(Intent intent) {        // Log.v(tag, "onBind");        return binder;    }    @Override    public boolean onUnbind(Intent intent) {        //  Log.v(tag, "onUnbind");        return super.onUnbind(intent);    }    @Override    public void onRebind(Intent intent) {        //  Log.v(tag, "onRebind");        super.onRebind(intent);    }    /**     * 下载binder     *     * @author Administrator     *     */    public class DownloadBinder extends Binder {        public void start() {            if (downLoadThread == null || !downLoadThread.isAlive()) {                setNotification();                canceled = false;                startDownloadApk();            }        }        public void cancel() {            canceled = true;        }        public int getProgress() {            return progress;        }        public boolean getCanceled() {            return canceled;        }        public boolean isDestoryService() {            return serviceIsDestory;        }        public void cancleNotification() {            handler.sendEmptyMessage(2);        }    }    /**     * 下载apk     */    private void startDownloadApk() {        downLoadThread = new Thread(downApkRunnable);        downLoadThread.start();    }    private Runnable downApkRunnable = new Runnable() {        @Override        public void run() {            try {                URL url = new URL(apkUrl);               // Log.v(tag, "apkUrl---" + apkUrl);                HttpURLConnection connection = (HttpURLConnection) url                        .openConnection();                connection.connect();                int length = connection.getContentLength();                InputStream inputStream = connection.getInputStream();                String apkUrls = saveFileName;               // Log.v(tag, "apkUrls---" + apkUrls);                File apkFile = new File(apkUrls);                if(apkFile.exists()){                    Log.v(tag, "true---" + apkFile.getAbsolutePath());                }                FileOutputStream outputStream = new FileOutputStream(apkFile);                int count = 0;                byte[] buffer = new byte[1024];                do {                    int readNum = inputStream.read(buffer);                    count += readNum;                    progress = (int) (((float) count / length) * 100);                    Message msg = new Message();                    msg.what = 1;                    msg.arg1 = progress;                    if (progress > lastRate + 1) {                        handler.sendMessage(msg);                        lastRate = progress;                    }                    if (readNum <= 0) {                        handler.sendEmptyMessage(0);                        canceled = true;                        break;                    }                    outputStream.write(buffer, 0, readNum);                } while (!canceled);                if (outputStream != null) {                    outputStream.close();                }                if (inputStream != null) {                    inputStream.close();                }            } catch (Exception e) {                Log.d("young","Exception...."+ e.toString())  ;                handler.sendEmptyMessage(3);            }        }    };    /**     * 设置下载通知栏     */    private void setNotification() {        // String tickerText = getResources().getString(R.string.download_start);        String tickerText = "开始下载";        long when = System.currentTimeMillis();        builder = new Builder(this);        builder.setSmallIcon(R.drawable.ic_launcher);        builder.setWhen(when);        builder.setTicker(tickerText);        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.JELLY_BEAN) {            notification = builder.build();        }        notification.flags = Notification.FLAG_ONGOING_EVENT;        RemoteViews contentView = new RemoteViews(getPackageName(),                R.layout.download_notification_layout);        contentView.setTextViewText(R.id.tv_name,                getResources().getString(R.string.download_title));        notification.contentView = contentView;        Intent intent = new Intent(this, MainActivity.class);        PendingIntent contentIntent = PendingIntent.getActivity(this, 0,                intent, PendingIntent.FLAG_UPDATE_CURRENT);        notification.contentIntent = contentIntent;        notificationManager.notify(NOTIFY_ID, notification);    }}

 

调用如上service:

声明binder对象:

private UpdateVersionService.DownloadBinder binder;

通过intent绑定service:

Intent intent =new Intent(mContext, UpdateVersionService.class);            intent.putExtra("apkUrl",apk_url);            mContext.startService(intent);            mContext.bindService(intent,conn, Context.BIND_AUTO_CREATE);

ServiceConnection conn = new ServiceConnection() {        @Override        public void onServiceDisconnected(ComponentName name) {            // TODO Auto-generated method stub        }        @Override        public void onServiceConnected(ComponentName name, IBinder service) {            // TODO Auto-generated method stub            binder = (UpdateVersionService.DownloadBinder) service;            // 开始下载            binder.start();        }    };

如上在onserviceConnected中调用binder.start()，也就是调用DownloadBinder的start()方法;

start方法里面调用startDownloadApk()开启下载应用的线程，在线程里面通过hander控制Notifition上面进度显示，下载完成调用安装apk程式。

注意在mainfest文件中注册service:

 

service与activity通信：通过广播

 

public class TestService extends Service {    /**     * 进度条的最大值     */    public static final int MAX_PROGRESS = 100;    /**     * 进度条的进度值     */    private int progress = 0;    private Intent intent = new Intent("com.soyoungboy.communication.RECEIVER");    /**     * 模拟下载任务，每秒钟更新一次     */    public void startDownLoad(){        new Thread(new Runnable() {            @Override            public void run() {                while(progress < MAX_PROGRESS){                    progress += 1;                    //发送Action为com.example.communication.RECEIVER的广播                    intent.putExtra("progress", progress);                    sendBroadcast(intent);                }            }        }).start();    }    @Override    public int onStartCommand(Intent intent, int flags, int startId) {        startDownLoad();        return super.onStartCommand(intent, flags, startId);    }    @Override    public IBinder onBind(Intent intent) {        return null;    }}

 

/** * 广播接收器 * @author len * */public class MsgReceiver extends BroadcastReceiver {    @Override    public void onReceive(Context context, Intent intent) {        //拿到进度，更新UI        int progress = intent.getIntExtra("progress", 0);        Toast.makeText(context,"progress = "+progress,Toast.LENGTH_LONG).show();    }}

mainfest文件：

 当然也可以使用EventBus或者RxJava