
平台论坛博客文库

› 论坛 › 操作系统 › 移动操作系统 › Android 消息机制

Android 消息机制 [复制链接]

凝望长空

家境小康

论坛徽章:: 0

电梯直达

1楼 [收藏(0)] [报告]

发表于 2012-01-19 23:53 |只看该作者 |倒序浏览

Android 消息机制

在 Android 开发中，有时会需要进行一个耗时的操作，例如：联网从远程读取数据，或者读取本地较大的一个文件的时候，这样的操作会引起系统长时间的等待，这时用户不能操作其它动作。长时间的等待给人假死的感觉，用户体验不好。究其原因，因为这样的操作都是在一个线程中完成。解决的办法可以采用类似 AJAX 的异步操作，把这类耗时的操作都放在另一个线程中处理。

线程内部或者线程之间需要进行信息的交互，那这个交互如何来实现的呢， Android 为我们提供了以下几个类进行线程间的信息交互。

1.Message

消息对象，顾名思义就是记录消息信息的载体类。这个类有几个比较重要的字段：

arg1 和 arg2 ：我们可以使用两个字段用来存放我们需要传递的整型值，在 Service 中，我们可以用来存放 Service 的 ID 。
obj ：该字段是 Object 类型，我们可以让该字段传递某个多项到消息的接受者中。
what ：这个字段可以说是消息的标志，在消息处理中，我们可以根据这个字段的不同的值进行不同的处理，类似于我们在处理 Button 事件时，通过 switch(v.getId()) 判断是点击了哪个按钮。
在使用 Message 时，我们可以通过 new Message() 创建一个 Message 实例，但是 Android 更推荐我们通过 Message.obtain() 或者 Handler.obtainMessage() 获取 Message 对象。这并不一定是直接创建一个新的实例，而是先从消息池中看有没有可用的 Message 实例，存在则直接取出并返回这个实例。反之如果消息池中没有可用的 Message 实例，则根据给定的参数 new 一个新 Message 对象。通过分析源码可得知， Android 系统默认情况下在消息池中实例化 10 个 Message 对象。

2.MessageQueue

消息队列，用来存放 Message 对象的数据结构，按照 “ 先进先出 ” 的原则存放消息。存放并非实际意义的保存，而是将 Message 对象以链表的方式串联起来的。 MessageQueue 对象不需要我们自己创建，而是有 Looper 对象对其进行管理，一个线程最多只可以拥有一个 MessageQueue 。我们可以通过 Looper.myQueue() 获取当前线程中的 MessageQueue 。

3.Looper

MessageQueue 的管理者，在一个线程中，如果存在 Looper 对象，则必定存在 MessageQueue 对象，并且只存在一个 Looper 对象和一个 MessageQueue 对象。

在 Android 系统中，除了主线程有默认的 Looper 对象，其它线程默认是没有 Looper 对象。如果想让我们新创建的线程拥有 Looper 对象时，我们首先需要调用 Looper.prepare() 来给线程创建一个消息循环，然后调用 Looper.loop() 来使消息循环起作用，从消息队列里取消息，处理消息。典型的用法如下：

Java代码

class LooperThread extends Thread
{
public Handler mHandler;
public void run()
{
Looper.prepare();
//其它需要处理的操作
Looper.loop();
}
}
class LooperThread extends Thread
{
public Handler mHandler;
public void run()
{
Looper.prepare();
//其它需要处理的操作
Looper.loop();
}
}

复制代码

4.Handler

消息的处理者。通过 Handler 对象我们可以封装 Message 对象，然后通过 sendMessage(msg) 把 Message 对象添加到 MessageQueue 中；当 MessageQueue 循环到该 Message 时，就会调用该 Message 对象对应的 handler 对象的 handleMessage() 方法对其进行处理。由于是在 handleMessage() 方法中处理消息，因此我们应该编写一个类继承自 Handler ，然后在 handleMessage() 处理我们需要的操作。

Java代码

/**
*
* @author coolszy
* @blog http://blog.csdn.net/coolszy
*
*/
public class MessageService extends Service
{
private static final String TAG = "MessageService";
private static final int KUKA = 0;
private Looper looper;
private ServiceHandler handler;
/**
* 由于处理消息是在Handler的handleMessage()方法中，因此我们需要自己编写类
* 继承自Handler类，然后在handleMessage()中编写我们所需要的功能代码
* @author coolszy
*
*/
private final class ServiceHandler extends Handler
{
public ServiceHandler(Looper looper)
{
super(looper);
}
@Override
public void handleMessage(Message msg)
{
// 根据what字段判断是哪个消息
switch (msg.what)
{
case KUKA:
//获取msg的obj字段。我们可在此编写我们所需要的功能代码
Log.i(TAG, "The obj field of msg:" + msg.obj);
break;
// other cases
default:
break;
}
// 如果我们Service已完成任务，则停止Service
stopSelf(msg.arg1);
}
}
@Override
public void onCreate()
{
Log.i(TAG, "MessageService-->onCreate()");
// 默认情况下Service是运行在主线程中，而服务一般又十分耗费时间，如果
// 放在主线程中，将会影响程序与用户的交互，因此把Service
// 放在一个单独的线程中执行
HandlerThread thread = new HandlerThread("MessageDemoThread", Process.THREAD_PRIORITY_BACKGROUND);
thread.start();
// 获取当前线程中的looper对象
looper = thread.getLooper();
//创建Handler对象，把looper传递过来使得handler、
//looper和messageQueue三者建立联系
handler = new ServiceHandler(looper);
}
@Override
public int onStartCommand(Intent intent, int flags, int startId)
{
Log.i(TAG, "MessageService-->onStartCommand()");
//从消息池中获取一个Message实例
Message msg = handler.obtainMessage();
// arg1保存线程的ID，在handleMessage()方法中
// 我们可以通过stopSelf(startId)方法，停止服务
msg.arg1 = startId;
// msg的标志
msg.what = KUKA;
// 在这里我创建一个date对象，赋值给obj字段
// 在实际中我们可以通过obj传递我们需要处理的对象
Date date = new Date();
msg.obj = date;
// 把msg添加到MessageQueue中
handler.sendMessage(msg);
return START_STICKY;
}
@Override
public void onDestroy()
{
Log.i(TAG, "MessageService-->onDestroy()");
}
@Override
public IBinder onBind(Intent intent)
{
return null;
}
}
/**
*
* @author coolszy
* @blog http://blog.csdn.net/coolszy
*
*/
public class MessageService extends Service
{
private static final String TAG = "MessageService";
private static final int KUKA = 0;
private Looper looper;
private ServiceHandler handler;
/**
* 由于处理消息是在Handler的handleMessage()方法中，因此我们需要自己编写类
* 继承自Handler类，然后在handleMessage()中编写我们所需要的功能代码
* @author coolszy
*
*/
private final class ServiceHandler extends Handler
{
public ServiceHandler(Looper looper)
{
super(looper);
}
@Override
public void handleMessage(Message msg)
{
// 根据what字段判断是哪个消息
switch (msg.what)
{
case KUKA:
//获取msg的obj字段。我们可在此编写我们所需要的功能代码
Log.i(TAG, "The obj field of msg:" + msg.obj);
break;
// other cases
default:
break;
}
// 如果我们Service已完成任务，则停止Service
stopSelf(msg.arg1);
}
}
@Override
public void onCreate()
{
Log.i(TAG, "MessageService-->onCreate()");
// 默认情况下Service是运行在主线程中，而服务一般又十分耗费时间，如果
// 放在主线程中，将会影响程序与用户的交互，因此把Service
// 放在一个单独的线程中执行
HandlerThread thread = new HandlerThread("MessageDemoThread", Process.THREAD_PRIORITY_BACKGROUND);
thread.start();
// 获取当前线程中的looper对象
looper = thread.getLooper();
//创建Handler对象，把looper传递过来使得handler、
//looper和messageQueue三者建立联系
handler = new ServiceHandler(looper);
}
@Override
public int onStartCommand(Intent intent, int flags, int startId)
{
Log.i(TAG, "MessageService-->onStartCommand()");
//从消息池中获取一个Message实例
Message msg = handler.obtainMessage();
// arg1保存线程的ID，在handleMessage()方法中
// 我们可以通过stopSelf(startId)方法，停止服务
msg.arg1 = startId;
// msg的标志
msg.what = KUKA;
// 在这里我创建一个date对象，赋值给obj字段
// 在实际中我们可以通过obj传递我们需要处理的对象
Date date = new Date();
msg.obj = date;
// 把msg添加到MessageQueue中
handler.sendMessage(msg);
return START_STICKY;
}
@Override
public void onDestroy()
{
Log.i(TAG, "MessageService-->onDestroy()");
}
@Override
public IBinder onBind(Intent intent)
{
return null;
}
}

复制代码

注：在测试代码中我们使用了 HandlerThread 类，该类是 Thread 的子类，该类运行时将会创建 looper 对象，使用该类省去了我们自己编写 Thread 子类并且创建 Looper 的麻烦。

下面我们分析下程序的运行过程：

1.onCreate()

首先启动服务时将会调用onCreate()方法，在该方法中我们new了一个HandlerThread对象，提供了线程的名字和优先级。

紧接着我们调用了start()方法，执行该方法将会调用HandlerThread对象的run()方法：

Java代码