IntentService源码解析

前几篇文章带领大家对HandlerThread的用法及原理进行了深入探索,为了巩固大家对HandlerThread的认识,让大家对HandlerThread的理解更上一层台阶,本篇文章将向大家介绍与HandlerThread关系密切的一大神器---IntentService,大家可以带着以下三个问题去看接下来的文章:1.为什么说IntentService和HandlerThread有着密切的关系? 2.为什么IntentService可被称作Android的一大神器,它和传统的Service有何区别? 3. IntentService的底层实现原理是怎样的?

我们知道,Service中的代码是运行在主线程中的,如果在Service中直接进行耗时操作,就很有可能出现ANR(Application Not Responding)。所以,我们想在Service中进行耗时操作,耗时逻辑一定要放在子线程中运行,代码如下:

public class FirstService extends Service {
    @Override
    public IBinder onBind(Intent arg0) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public int onStartCommand(Intent intent,int flags,int startId){
        new Thread(new Runnable(){
            @Override
            public void run(){
                //处理耗时逻辑
            }
        }).start();
        return super.onStartCommand(intent, flags, startId);
    }
}

上面的服务一旦启动后会一直运行,必须调用stopService()或stopSelf()才可以让服务停止,代码如下:

public class SecondService extends Service {

    @Override
    public IBinder onBind(Intent arg0) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public int onStartCommand(Intent intent,int flags,int startId){
        new Thread(new Runnable(){
            @Override
            public void run(){
                //处理耗时逻辑
                stopSelf();
            }
        }).start();
        return super.onStartCommand(intent, flags, startId);
    }
}

上面的写法虽然并不复杂,但是还是会有不少程序员在Service中处理耗时逻辑时忘记开启子线程或者忘记停止Service,Android中为了解决
这两个问题,提升开发人员的效率,引入了IntentService这一神器!

我们先来看一下IntentService在官方文档中的介绍:


文档中讲得很清楚,IntentService继承自Service类,能够用来处理异步的请求,客户端可通过startService(Intent)来发送请求,Service会根据需要被启动,使用一个工作者线程轮流处理每个请求,并且当它处理完所有的请求后会停止它自身。

IntentService中有一个很重要的方法: onHandleIntent,看一下官方文档对它的介绍:



当某个请求需要处理时,这个方法会在工作者线程被调用,一次仅仅会有一个请求被处理,但是处理过程会运行在工作者线程(独立于其他应用程序逻辑运行)。因此,如果某段代码需要执行很长时间,它会阻塞住其他提交到该IntentService的请求,但是不会阻塞住其他任何东西。当所有的请求被处理完成之后,IntentService会停止它自身,因此你不应该手动调用stopSelf()方法。

说了这么多,大家对IntentService的认识可能还是很模糊,下面通过一个具体的例子让大家深入地体会下:
我们模拟一个多张图片下载的场景,点击“Add Download Task”按钮可以增加图片下载任务,下方也会增加一条记录代表新增的下载任务,当下载任务完成时,相应的任务记录也会进行更新,运行效果如下:

DownloadImageService中的代码:

public class DownloadImageService extends IntentService {

    private static final String ACTION_DOWNLOAD_IMAGE="com.example.downloadimage.action.DOWNLOAD_IMAGE";
    public static final String EXTRA_DOWNLOAD_IMAGE="com.example.downloadimage.extra.DOWNLOAD_IMAGE";
    public DownloadImageService() {
        super("DownloadImageService");
    }
    
    public static void startDownload(Context context,String path){
        Intent intent=new Intent(context,DownloadImageService.class);
        intent.setAction(ACTION_DOWNLOAD_IMAGE);
        intent.putExtra(EXTRA_DOWNLOAD_IMAGE,path);
        context.startService(intent);
    }
    
    @Override
    protected void onHandleIntent(Intent intent) {
        if(intent!=null){
            if(intent.getAction().equals(ACTION_DOWNLOAD_IMAGE)){
                String path=intent.getStringExtra(EXTRA_DOWNLOAD_IMAGE);
                handleDownloadTask(path);
            }
        }
    }

    private void handleDownloadTask(String path) {
        //模拟耗时操作
        try{
            Thread.sleep(3*1000);
        }catch(InterruptedException e){
            e.printStackTrace();
        }
        //利用广播通知主界面更新
        Intent intent=new Intent(MainActivity.RESULT_DOWNLOAD_IMAGE);
        intent.putExtra(EXTRA_DOWNLOAD_IMAGE,path);
        sendBroadcast(intent);
    }
    
    @Override
    public void onCreate(){
        super.onCreate();
    }
    
    @Override
    public void onDestroy(){
        super.onDestroy();
    }
}

MainActivity中的代码:

public class MainActivity extends ActionBarActivity {
    
    public static final String RESULT_DOWNLOAD_IMAGE="com.example.downloadimage.result.DOWNLOAD_IMAGE";
    private Button addTaskBtn;
    private LinearLayout layoutContainer;
    private int i=0;
    private BroadcastReceiver resultReceiver=new BroadcastReceiver(){
        @Override
        public void onReceive(Context context, Intent intent) {
            if(intent!=null){
                if(intent.getAction().equals(RESULT_DOWNLOAD_IMAGE)){
                    String path=intent.getStringExtra(DownloadImageService.EXTRA_DOWNLOAD_IMAGE);
                    TextView tv=(TextView)layoutContainer.findViewWithTag(path);
                    tv.setText(path+" successfully downloaded");
                }
            }
        }
        
    };
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        addTaskBtn=(Button)findViewById(R.id.addTaskBtn);
        layoutContainer=(LinearLayout)findViewById(R.id.layoutContainer);
        addTaskBtn.setOnClickListener(new OnClickListener(){
            @Override
            public void onClick(View arg0) {
                String path="www.lemon.com/imgs/img"+(++i)+".png";
                DownloadImageService.startDownload(MainActivity.this,path);
                TextView tv=new TextView(MainActivity.this);
                tv.setText(path+" is downloading");
                tv.setTag(path);
                layoutContainer.addView(tv);
            }
        });
        registerReceiver(resultReceiver);
    }
    
    private void registerReceiver(BroadcastReceiver receiver) {
        IntentFilter intentFilter=new IntentFilter(RESULT_DOWNLOAD_IMAGE);
        registerReceiver(receiver,intentFilter);
    }
    
    @Override
    protected void onDestroy(){
        super.onDestroy();
        unregisterReceiver(resultReceiver);
    }

}

主布局文件的代码:

<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:tools="http://schemas.android.com/tools"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:orientation="vertical"
    android:id="@+id/layoutContainer"
    tools:context="com.example.downloadimage.MainActivity" >

   <Button
      android:id="@+id/addTaskBtn"
      android:layout_width="wrap_content"
      android:layout_height="wrap_content"
      android:text="Add Download Task"
       />

</LinearLayout>

其实,逻辑还是相当简单的,每当点击“Add Download Task”按钮时,会去调用DownloadImageService的startDownload方法,在startDownload中,会调用startService方法去启动我们的DownloadImageService,startService方法的参数是一个intent,该intent中封装了我们这回要执行的任务类型(action)以及执行任务所需的参数(Extra),之后会执行到onHandleIntent方法,此时的onHandleIntent方法是运行在子线程中的,在onHandleIntent方法中,会去执行图片下载的具体任务,下载完成后,会发送一个广播通知主界面相关任务记录进行更新。
讲到这里,大家对IntentService的基本用法应该有一个大致的了解了吧,但是目前的理解层次还不能完全回答之前提出的三个问题,看来,只能让源码君帮帮我们了_

IntentService的源码如下:

/*
 * Copyright (C) 2008 The Android Open Source Project
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package android.app;

import android.content.Intent;
import android.os.Handler;
import android.os.HandlerThread;
import android.os.IBinder;
import android.os.Looper;
import android.os.Message;


public abstract class IntentService extends Service {
    private volatile Looper mServiceLooper;
    private volatile ServiceHandler mServiceHandler;
    private String mName;
    private boolean mRedelivery;

    private final class ServiceHandler extends Handler {
        public ServiceHandler(Looper looper) {
            super(looper);
        }

        @Override
        public void handleMessage(Message msg) {
            onHandleIntent((Intent)msg.obj);
            stopSelf(msg.arg1);
        }
    }


    public IntentService(String name) {
        super();
        mName = name;
    }


    public void setIntentRedelivery(boolean enabled) {
        mRedelivery = enabled;
    }

    @Override
    public void onCreate() {
                super.onCreate();
        HandlerThread thread = new HandlerThread("IntentService[" + mName + "]");
        thread.start();

        mServiceLooper = thread.getLooper();
        mServiceHandler = new ServiceHandler(mServiceLooper);
    }

    @Override
    public void onStart(Intent intent, int startId) {
        Message msg = mServiceHandler.obtainMessage();
        msg.arg1 = startId;
        msg.obj = intent;
        mServiceHandler.sendMessage(msg);
    }


    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {
        onStart(intent, startId);
        return mRedelivery ? START_REDELIVER_INTENT : START_NOT_STICKY;
    }

    @Override
    public void onDestroy() {
        mServiceLooper.quit();
    }


    @Override
    public IBinder onBind(Intent intent) {
        return null;
    }


    protected abstract void onHandleIntent(Intent intent);
}

IntentService中有两个成员变量较为重要,一个是Looper类型的mServiceLooper,还有一个是ServiceHandler类型的mServiceHandler。这个ServiceHandler是个啥东东呢?我们看一下它的源码,ServiceHandler继承自Handler,内部提供了一个以Looper为参数的构造函数,也就是说,如果我们传入的Looper是子线程的Looper,ServiceHandler的handleMessage方法就会运行在子线程中。我们再去看一下ServiceHandler的handleMessage方法中有些什么,原来是依次调用了onHandleIntent,stopSelf方法,看到这里,对异步消息处理机制及HandlerThread掌握较牢固的朋友应该都能猜到接下来的源码了,不要激动,咱们继续往下看_

接下来看到IntentService的onCreate方法,在onCreate中,先去创建并启动了HandlerThread,然后用该HandlerThread的Looper去初始化我们的ServiceHandler,这样ServiceHandler就用的是子线程的Looper,其handleMessage方法自然是运行在子线程中的,所以handleMessage中的onHandleIntent和stopSelf方法自然也是运行在子线程中的。

当我们调用startService方法启动服务时,首先会去调用onStartCommand方法,在onStartCommand方法中,会再去调用onStart方法,并将intent和startId传入,我们重点看一下onStart方法。在onStart方法中,会先去通过ServiceHandler对象去获取一条消息,之后将消息的arg1字段设置为startId,obj字段设置为intent,最后用ServiceHandler对象将我们这条消息发送出去。

之后消息便会辗转到handleMessage方法中了,注意,此时handleMessage是运行在子线程中的,在handleMessage方法中,会将消息的obj字段取出强转为Intent并作为参数传入onHandleIntent方法中,之后将消息的arg1字段取出并作为参数传入stopSelf中。

当请求全部执行完成后,会销毁我们的Service。销毁Service时会回调onDestroy方法,在onDestroy方法中会调用mServiceLooper.quit()来释放我们的Looper。

好了,到这里IntentService的源码就基本分析完毕了,大家对IntentService的理解是不是又更上一层楼了呢_

参考:《第一行代码 Android》
http://blog.csdn.net/lmj623565791/article/details/47143563

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,324评论 5 476
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,303评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,192评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,555评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,569评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,566评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,927评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,583评论 0 257
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,827评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,590评论 2 320
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,669评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,365评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,941评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,928评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,159评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,880评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,399评论 2 342

推荐阅读更多精彩内容