Android進程間的通信之Messenger

Android進程間的通信方式可以通過以下兩種方式完成：

Android接口定義語言（AIDL） 2 使用Messenger綁定服務

本文我們將學習使用Messenger綁定服務的方式進行進程間的通信。

Android AIDL和Messenger區別

使用Messenger是執行進程間通信最簡單的方法，因為Messenger會在單一線程中創建包含所有請求的隊列，這樣您就不必對服務進行線程安全設計。而純粹的AIDL接口會同時向服務發送多個請求，服務隨后必須應對多線程處理。AIDL通常應用在服務被設計到單獨的應用中的場景（即服務端可客戶端不屬於同一個app的情況），而Messenger通常應用在同一app的不同進程的場景中。

Messenger基本思想

服務端（被動方）提供一個Service來處理客戶端（主動方）連接，維護一個Handler（具體來講：是Handler的子類）來創建Messenger，在onBind時返回Messenger的binder（調用Messenger的getBinder()方法，該方法返回一個IBinder對象，客戶端將通過該對象作為參數創建一個Messenger對象用於與服務端進行通信）。

Messenger使用步驟

1、服務端實現一個Handler，由其接收來自客戶端的每個調用的回調 2、使用第1步的Handler的實例作為target創建Messenger對象（即該Messenger持有了對Handler的引用） 3、使用Messenger創建一個IBinder（通過調用Messenger的getBinder()方法）,服務端的onBind()方法中將其返回到客戶端 4、客戶端使用IBinder將Messenger（引用服務端的Handler實例）實例化，然后使用后者將Message對象發送給服務端 5、服務端在其Handler中接收每個Message

這樣，客戶端並沒有調用服務端的“方法”，而客戶端傳遞的消息（Message對象）是服務端在其Handler中接收到的。

如果想讓服務端對客戶端發回響應，則還需要在客戶端中創建一個持有客戶端Handler實現類的Messenger，當客戶端收到onServiceConnected()回調時，在向服務發送的Message時，send()方法的replyTo參數中需包含客戶端的Messenger。這樣，客戶端就可在其Handler實現類中接收到來自服務端的響應消息。

簡單示例

AndroidMainfest.xml

<application
    android:allowBackup="true"
    android:icon="@drawable/ic_launcher"
    android:label="@string/app_name"
    android:theme="@style/AppTheme" >
    <activity
        android:name="yf.exam.client.MainActivity"
        android:label="@string/app_name" >
        <intent-filter>
            <action android:name="android.intent.action.MAIN" />
            <category android:name="android.intent.category.LAUNCHER" />
        </intent-filter>
    </activity>
    <service android:name=".MessengerService" android:process=":custom_process"/>
</application>

 

在上面的配置文件中，service的android:process屬性用於在一個單獨進程中啟動service，看如下圖片：

布局文件很簡單，這里只有一個按鈕，用於向服務端發送消息並顯示服務端響應內容，這里不再給出。

客戶端:MainActivity

public class MainActivity extends Activity {
    private static final int REPLY_MSG_ID = 2;
    private boolean mServiceConnected = false;
    private Button btn = null;
    //用於向Service端發送消息的Messenger
    private Messenger mBoundServiceMessenger = null;
    //用於接收Service發送消息的Messenger
    private final Messenger mReceiveMessenger = new Messenger(new ReceiveMessHandler(this));
    private ServiceConnection conn = new ServiceConnection() {
        @Override
        public void onServiceDisconnected(ComponentName name) {
            mBoundServiceMessenger = null;
            mServiceConnected = false;
        }
        
        @Override
        public void onServiceConnected(ComponentName name, IBinder service) {
            mBoundServiceMessenger = new Messenger(service);
            mServiceConnected = true;
        }
    };
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        btn = (Button)findViewById(R.id.button);
        bindService(new Intent(this, MessengerService.class), conn, Context.BIND_AUTO_CREATE);
        btn.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                if(mServiceConnected){
                    //獲取消息對象
                    Message msg = Message.obtain(null, 1, 0, 0);
                    try{
                        //replyTo參數包含客戶端Messenger
                        msg.replyTo = mReceiveMessenger;
                        //向Service端發送消息
                        mBoundServiceMessenger.send(msg);
                    }catch(RemoteException re){
                        re.printStackTrace();
                    }
                }
            }
        });
    }
    @Override
    protected void onDestroy() {
        super.onDestroy();
        if(mServiceConnected){
            unbindService(conn);
            mServiceConnected = false;
        }
    }
    /**
     * 客戶端實現一個Handler用於接收服務端返回的響應
     * @author Administrator
     *
     */
    static class ReceiveMessHandler extends Handler{
        //持有當前Activity的弱引用，避免內存泄露
        private final WeakReference<MainActivity> mActivity;
        public ReceiveMessHandler(MainActivity activity){
            mActivity = new WeakReference<MainActivity>(activity);
        }
        @Override
        public void handleMessage(Message msg) {
            switch(msg.what){
            case REPLY_MSG_ID:
                Toast.makeText(mActivity.get(), msg.getData().getString("msg"), Toast.LENGTH_SHORT).show();
                break;
            }
        }
    }
}

服務端：MessengerService.java

public class MessengerService extends Service {
    private static final int REPLY_MSG_ID = 2;
    private static final int MSG_ID = 1;
    static class BoundServiceHandler extends Handler{
        private final WeakReference<MessengerService> mService;
        public BoundServiceHandler(MessengerService service){
            mService = new WeakReference<MessengerService>(service);
        }
        @Override
        public void handleMessage(Message msg) {
            switch(msg.what){
            case MSG_ID:
                Messenger replyMessenger = msg.replyTo;
                Message replyMsg = Message.obtain(null, REPLY_MSG_ID);
                //向客戶端響應的消息內容
                Bundle b = new Bundle();
                b.putString("msg", "this is the message reply from service");
                replyMsg.setData(b);
                try{
                    replyMessenger.send(replyMsg);
                }catch(RemoteException re){
                    re.printStackTrace();
                }
                break;
                default:
                    super.handleMessage(msg);
            }
        }
    }
    private final Messenger mMessenger = new Messenger(new BoundServiceHandler(this));
    @Override
    public IBinder onBind(Intent intent) {
        Toast.makeText(getApplicationContext(), "binding", Toast.LENGTH_SHORT).show();
        return mMessenger.getBinder();
    }
}

此外，上述例子中所有的Handler的實現類都被聲明為static並使用Service或Activity的WeakReference。如果不這樣做，編譯器會給出警告信息“This handler class should be static or leaks might occur”。通過使用弱引用的方式，就允許Service或Activity進行垃圾收集了。