IntentService源码解析 IntentService源码解析

为什么我们需要IntentService ?
Android中的IntentService是继承自Service类的，在我们讨论IntentService之前，我们先想一下Service的特点: Service的回调方法(onCreate、onStartCommand、onBind、onDestroy)都是运行在主线程中的。当我们通过startService启动Service之后，我们就需要在Service的onStartCommand方法中写代码完成工作，但是onStartCommand是运行在主线程中的，如果我们需要在此处完成一些网络请求或IO等耗时操作，这样就会阻塞主线程UI无响应，从而出现ANR现象。为了解决这种问题，最好的办法就是在onStartCommand中创建一个新的线程，并把耗时代码放到这个新线程中执行。由此看来，创建一个带有工作线程的Service是一种很常见的需求（因为工作线程不会阻塞主线程），所以Android为了简化开发带有工作线程的Service，Android额外开发了一个类——–IntentService。
IntentService的特点

独立的线程
onCreate、onStartCommand、onDestroy回调方法都是运行在主线程中的，而onHandleIntent是运行在工作线程IntentService中的。
自动创造一个队列处理事务
当我们通过startService多次启动了IntentService，这会产生多个job，由于IntentService只持有一个工作线程，所以每次onHandleIntent只能处理一个job。面多多个job，IntentService会如何处理？处理方式是one-by-one，也就是一个一个按照先后顺序处理，先将intent1传入onHandleIntent，让其完成job1，然后将intent2传入onHandleIntent，让其完成job2…这样直至所有job完成，所以我们IntentService不能并行的执行多个job，只能一个一个的按照先后顺序完成，当所有job完成的时候IntentService就销毁了，会执行onDestroy回调方法。
当所有的请求处理完之后，自动销毁，不用调用 stopSelf()
自动 onBind 返回 null
只要将需要处理的事务放在onHandleIntent()，Framework会回调其onHandleIntent方法。
在service构造函数要返回super(“ServiceName”);

IntentService的使用
MainActivity

public class MainActivity extends AppCompatActivity { @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); Intent bindIntent = new Intent(this, MyIntentService.class); bindIntent.putExtra("name","task1"); startService(bindIntent); bindIntent.putExtra("name","task2"); startService(bindIntent); bindIntent.putExtra("name","task2"); startService(bindIntent); } }

MyIntentService

public class MyIntentService extends IntentService { String Tag = "MyIntentService"; public MyIntentService() { super("MyIntentService"); Log.i(Tag, "MyIntentService构造函数, Thread: " + Thread.currentThread().getName()); }@Override public void onCreate() { super.onCreate(); Log.i(Tag, "MyIntentService -> onCreate, Thread: " + Thread.currentThread().getName()); }@Override public int onStartCommand(@Nullable Intent intent, int flags, int startId) { Log.i(Tag, "MyIntentService -> onStartCommand, Thread: " + Thread.currentThread().getName() + " , startId: " + startId); return super.onStartCommand(intent, flags, startId); }@Override public void onDestroy() { super.onDestroy(); Log.i(Tag, "MyIntentService -> onDestroy, Thread: " + Thread.currentThread().getName()); }@Override protected void onHandleIntent(@Nullable Intent intent) { String name = intent.getStringExtra("name"); //执行下载任务，无法新开线程； Log.i(Tag, "MyIntentService -> onHandleIntent, Thread: " + Thread.currentThread().getName() + ", 《" + name + "》任务完成"); } }

【IntentService源码解析】结果

06-24 03:18:09.819 27760-27760/? I/MyIntentService: MyIntentService构造函数, Thread: main 06-24 03:18:09.819 27760-27760/? I/MyIntentService: MyIntentService -> onCreate, Thread: main 06-24 03:18:09.819 27760-27760/? I/MyIntentService: MyIntentService -> onStartCommand, Thread: main , startId: 1 06-24 03:18:09.819 27760-27760/? I/MyIntentService: MyIntentService -> onStartCommand, Thread: main , startId: 2 06-24 03:18:09.819 27760-27760/? I/MyIntentService: MyIntentService -> onStartCommand, Thread: main , startId: 3 06-24 03:18:09.820 27760-27781/? I/MyIntentService: MyIntentService -> onHandleIntent, Thread: IntentService[MyIntentService], 《task1》任务完成 06-24 03:18:09.820 27760-27781/? I/MyIntentService: MyIntentService -> onHandleIntent, Thread: IntentService[MyIntentService], 《task2》任务完成 06-24 03:18:09.820 27760-27781/? I/MyIntentService: MyIntentService -> onHandleIntent, Thread: IntentService[MyIntentService], 《task2》任务完成 06-24 03:18:10.166 27760-27760/? I/MyIntentService: MyIntentService -> onDestroy, Thread: main

通过以上的输出结果我们可以发现，MyIntentService的onCreate、onStartCommand、onDestroy回调方法都是运行在主线程main中的，而onHandleIntent是运行在工作线程IntentService[MyIntentService]中的，这验证了我们上面所说的IntentService的第一个和第二个特点。
通过上面的输出结果我们还会发现，在我们连续调用了三次startService(intent)之后，onStartCommand依次被调用了三次，然后依次执行了onHandleIntent三次，这样就依次完成了job，当最后一个job完成，也就是在最后一次onHandleIntent调用完成之后，整个IntentService的工作都完成，执行onDestroy回调方法，IntentService销毁。
IntentService源码分析
intentservice = HandlerThread + Service

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，确保onHandleIntent不会阻塞主线程 onHandleIntent((Intent)msg.obj); //在执行完了onHandleIntent之后，我们需要调用stopSelf(startId)声明某个job完成了 //当所有job完成的时候，Android就会回调onDestroy方法，销毁IntentService stopSelf(msg.arg1); } } public IntentService(String name) { //此处的name将用作线程名称 super(); mName = name; } public void setIntentRedelivery(boolean enabled) { mRedelivery = enabled; } @Override public void onCreate() { super.onCreate(); //创建HandlerThread，利用mName作为线程名称，HandlerThread是IntentService的工作线程 HandlerThread thread = new HandlerThread("IntentService[" + mName + "]"); thread.start(); mServiceLooper = thread.getLooper(); //将创建的HandlerThread所绑定的looper对象传递给ServiceHandler， //这样我们创建的Handler就和HandlerThread通过消息队列绑定在了一起 mServiceHandler = new ServiceHandler(mServiceLooper); } @Override public void onStart(Intent intent, int startId) { //在此方法中创建Message对象，并将intent作为Message的obj参数, //这样Message与Intent就关联起来了 Message msg = mServiceHandler.obtainMessage(); msg.arg1 = startId; msg.obj = intent; //将关联了Intent信息的Message发送给Handler mServiceHandler.sendMessage(msg); } @Override public int onStartCommand(Intent intent, int flags, int startId) { //IntentService重写了onStartCommand回调方法:在内部调用onStart回调方法 //所以我们在继承IntentService时，不应该再覆写该方法，即便覆盖该方法，我们也应该调用super.onStartCommand() onStart(intent, startId); return mRedelivery ? START_REDELIVER_INTENT : START_NOT_STICKY; } @Override public void onDestroy() { //在onDestroy方法中调用了Handler的quit方法，该方法会终止消息循环 mServiceLooper.quit(); } @Override public IBinder onBind(Intent intent) { return null; } protected abstract void onHandleIntent(Intent intent); }