概覽 * Message：消息。消息里面可包含簡單數據、Object和Bundle，還可以包含一個Runnable（實際上可看做回調）。 * MessageQueue：消息隊列，供Looper線程消費消息。 * Looper：用于循環處理Message，一個Thread結合一個Looper來實現消息循環處理。Android App的主線程包含了Looper。 * Handler：負責向當前Looper線程發送Message，并實現如何處理消息的回調，回調可放到Callback接口的實現中，也可以放在傳遞進去的Runnable中的run中。 消息處理流程 1. MainThread（一個Looper Thread）正在運行，線程中有MessageQueue可交互，并循環處理MessageQueue中的Message。 2. 在MainThread中創建一個Handler，handler與當前線程Looper的MessageQueue綁定。 3. 通過handler.sendMessage(Message msg)向MessageQueue發送消息，等候執行；通過handler.post(Runnable r)向MessageQueue發送一個空消息，該空消息附加了Runnable，等候執行。 4. MainThread輪詢MessageQueue的Message，拋給Message對應的Handler執行。

---

Message * 最好通過Message.obtain()來創建Message對象，從消息池里創建Message更高效。 源碼分析 public final class Message implements Parcelable { public int what; // 用戶定義的標識碼 public int arg1; // 用來存儲簡單的數據，這樣可以不使用Object/Bundle來做消息。 public int arg2; public Object obj; // 對象型數據。 public Messenger replyTo;? Bundle data; // 復雜型消息數據 // Message的最終處理分兩種情況： Handler target; // 1)通過Message的target（Handler）處理消息，具體是Handelr實現handleMessage()。 Runnable callback; // 2)通過空消息的callback（Runnable）處理消息，具體是丟棄Message，然后直接調用run()。 private static final Object sPoolSync = new Object(); // 消息池用到的鎖 private static Message sPool ; // 從消息池中取出的可用的消息對象。每取一次，這里就放置一個可用的。 private static int sPoolSize = 0; // 當前可用的消息對象數量 private static final int MAX_POOL_SIZE = 50 ; ?// 池存放最大量 Message next; // 實現鏈表式消息池 // 從消息池中取一個可用的消息對象 public static Message obtain() { synchronized (sPoolSync) { if (sPool != null) { Message m = sPool; sPool = m.next; m.next = null;? sPoolSize--; return m; } } return new Message(); } // 從現有Message復制并返回 public static Message obtain(Message orig) { Message m = obtain(); m.what = orig.what; m.arg1 = orig.arg1; m.arg2 = orig.arg2; m.obj = orig.obj; m.replyTo = orig.replyTo; if (orig.data != null) { m.data = new Bundle(orig.data); } m.target = orig.target; m.callback = orig.callback; return m; } // 發送消息? public void sendToTarget() { target.sendMessage(this); //?調用的是 handler 的 sendMessage() } // 消息回收 public void recycle() { clearForRecycle(); // 清除Message對象的所有信息 synchronized (sPoolSync) { if(sPoolSize < MAX_POOL_SIZE){ next = sPool; // 下一個可用Message是當前sPool（可用） sPool = this ; // 當前可用的Message為正在釋放清除的Message對象 sPoolSize++; // 可用對象數量遞增 } } } } MessageQueue *?holding the list of messages to be dispatched by a?Looper。 * 不能直接向Looper的MessageQueue添加Message，需要通過Handler。 * 可通過 Looper.myQueue()獲取到當前線程的MessageQueue。

---

Handler * 創建一個Handler就會綁定到當前Thread/MessageQueue，之后，Handler可以向MessageQueue發送Message和Runnable，等候輪詢執行。 * 發送一個Message：sendMessage(Message m)。 * 發送一個Runnable：post(Runnable r) 。 public class Handler { // 自定義的Handler必須實現該方法，用于處理消息 public void?handleMessage(Message msg){} // 或者指定一個實現了Callback接口的類 public interface Callback { public boolean?handleMessage(Message msg); } // 構造函數 // 默認情況下，handler會關聯到當前Thread的Looper，如果沒有Looper，拋異常 public Handler(Looper looper,Callback callback/*相當于指定了handleMessage()函數*/,boolean async){? mLooper=looper; mQueue=looper.mQueue; mCallback =callback;mAsynchronous = async; } public final Message obtainMessage(){ return Message.obtain(this); } // 直接調用的Message的obtain // --------------------------------------------------------------- //?發送消息到MessageQueue // handler.sendXXX均調用此方法 public boolean sendMessageAtTime(Message msg,long uptimeMillis) { MessageQueue queue = mQueue; return enqueueMessage(queue,msg,uptimeMillis); } private boolean enqueueMessage(MessageQueue queue, Message msg, long uptimeMillis) { msg.target = this; if (mAsynchronous) {msg.setAsynchronous(true);} return queue.enqueueMessage(msg, uptimeMillis); } //?--------------------------------------------------------------- //?發送Runnable到MessageQueue // 原理是把Runnable附加到一個空消息的callback上，當執行消息時，如果發現有callback，則執行callback。 public final boolean post(Runnable r) { return?sendMessageDelayed(getPostMessage(r),0); } private static getPostMessage(Runnable r,Object token) { Message m = Message.obtain(); m.obj = token; m.callback = r;?// 指定Message的callback為r。通過sendMessage的消息沒有callback，包含callback的Message將會被其callback執行。 return m; } //?--------------------------------------------------------------- //?處理消息 // 消息在Looper中是通過調用這個函數來實現處理消息的 public void dispatchMessage(Message msg) { if(msg.callback!=null){?handleCallback(msg); } // 在Runnable中處理 else { handleMessage(msg); // 調用Handler處理消息的函數 } } private static void?handleCallback(Message message) {? message.callback.run(); //消息被丟棄，并且直接調用run()，而不是新開線程。 } }// end handler()

---

Looper ? * 默認線程并沒有包含可以循環處理消息的功能，Looper類可以幫助線程實現消息循環。 ? public final class Looper { static final ThreadLocal<Looper> sThreadLocal = new ThreadLocal<Looper>(); // 線程本地變量，每個線程一個Looper。 final Message mQueue; final Thread mThread; private Looper(boolean quitAllowed){ mQueue = new MessageQueue(quitAllowed); mThread = Thread.currentThread(); } // -------------------------------------------------------------------- // 準備。為當前線程創建一個Looper對象 static void prepare(boolean quitAllowed/*MessageQueue是否可退出*/) { if(sThreadLocal.get()!=null){/*Exception，當前線程的Looper已存在，一個線程一個Looper*/} sThreadLocal.set(new Looper(quitAllowed)); } // -------------------------------------------------------------------- // 開始循環 public static void loop() { final Looper me = myLooper();// 當前線程的Looper實例 final MessageQueue queue = me.mQueue; for(;;){ Message msg = queue.next(); if(msg == null) {?return;} msg.target.dispatchMessage(msg); // 由Handler處理該消息 msg.recycle(); // 清理該消息，清空后返回消息池。 }//end for }// end loop() // -------------------------------------------------------------------- public void quit() { mQueue.quit(false); } public boolean isIdling(){ return mQueue.isIdling();} } // class end.

---

Demo

Demo#1 發送消息
class SomeActivity
{
　　@Override
　　public void onCreate(...){
　　testMessage();
}

void testMessage(){
　　MyHandler handler = new MyHandler();
　　// or
　　handler = new Handler(/*this.getMainLooper(),*/ new Handler.Callback(){ /*...*/ });

　　// 發送Message
　　Message m1 = new Message();
　　m.setTarget(h);
　　m.sendToTarget();

　　// 發送Runnable（內部其實是發送了一個Message+Runnable）
　　handler.post(new Runnable(){
　　　　@Override
　　　　public void run(){
　　　　　　// 在主線程中運行
　　　　}
　　});
}

class MyHandler extends Handler{
　　@Override
　　public void handleMessage(Message msg){ /*...*/ }
}

Demo#2 自定義Looper線程
public static void testLooper()
{
　　Thread tLooper = new Thread(new Runnable(){

　　@Override
　　public void run() {
　　　　Looper.prepare();

　　　　MyHandler h = new MyHandler();
　　　　// 發送消息
　　　　h.sendEmptyMessage(0);
　　　　// 發送Runnable
　　　　h.post(new Runnable(){
　　　　　　@Override
　　　　　　public void run() {
　　　　　　Log.i("test","[in post runnable]threadid:"+Thread.currentThread().getId()); // tLooper線程ID
　　　　}});

　　　　Looper.loop(); // 一直循環。即使沒有消息
　　}});
　　tLooper.start();
}

---

references http://developer.android.com/reference/android/os/MessageQueue.html? http://developer.android.com/reference/android/os/Looper.html

總結

以上是生活随笔為你收集整理的Android的消息机制: Message/MessageQueue/Handler/Looper的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。