Android IPC機(jī)制(二)——利用Messenger實(shí)現(xiàn)跨進(jìn)程通信

寫作原因:跨進(jìn)程通信的實(shí)現(xiàn)和理解是Android進(jìn)階中重要的一環(huán)。下面博主分享IPC一些相關(guān)知識(shí)、操作及自己在學(xué)習(xí)IPC過(guò)程中的一些理解。這一章使用Messenger實(shí)現(xiàn)跨進(jìn)程通信,其中bindService基礎(chǔ)部分參見(jiàn)Android IPC機(jī)制(一)——綁定Service實(shí)現(xiàn)本地通信

跨進(jìn)程簡(jiǎn)介

在介紹使用Messenger跨進(jìn)程通信之前先要了解以下問(wèn)題:為什么需要跨進(jìn)程通信?只有有了需求才有學(xué)習(xí)的價(jià)值。我個(gè)人將不同進(jìn)程簡(jiǎn)單的理解為不同的應(yīng)用程序(當(dāng)然也有例外,比如可以在同一個(gè)應(yīng)用程序中開(kāi)啟兩個(gè)或多個(gè)進(jìn)程)。由于進(jìn)程之間不能像線程一樣共享內(nèi)存,所以數(shù)據(jù)通信不能像線程一般進(jìn)行。在Android中可以使用bundle,廣播,Messenger,AIDL和Socket進(jìn)行跨進(jìn)程通信。本章利用Messenger分別進(jìn)行單應(yīng)用程序多進(jìn)程單向通信和多應(yīng)用程序多進(jìn)程雙向通信的實(shí)現(xiàn)。

Messenger介紹

Messenger是通過(guò)使用Message來(lái)實(shí)現(xiàn)跨進(jìn)程通信,一次實(shí)現(xiàn)一個(gè)請(qǐng)求的方式,這是它的優(yōu)點(diǎn)也是缺點(diǎn)。其底層實(shí)現(xiàn)為AIDL(下章我將闡述)。Messenger的優(yōu)點(diǎn)是:基于Message,方便使用;支持回調(diào)的方式,也就是服務(wù)端處理完成長(zhǎng)任務(wù)可以和客戶端交互;不需要編寫aidl文件。

Messenger使用流程如下(轉(zhuǎn)載):


Messenger

單應(yīng)用程序多進(jìn)程單向通信

先介紹一下Android中單應(yīng)用程序開(kāi)啟多進(jìn)程的方法,實(shí)際上只要在mainfests中的你想開(kāi)啟新進(jìn)程的組件的XML中添加<android:progress = ":remote(可以自定義)">或者<android:progress = "包.remote(可以自定義)">就行。如:

<service android:name=".CustomService" android:process=":remote"/>

這樣就把Service放在新的線程中運(yùn)行了。

Service實(shí)現(xiàn)

下面是服務(wù)端的代碼實(shí)現(xiàn),具體思路是:創(chuàng)建一個(gè)Handler對(duì)象用來(lái)處理客戶端發(fā)送來(lái)的消息,再創(chuàng)建一個(gè)Messenger對(duì)象將上面的Handler對(duì)象作為參數(shù)傳入,這樣我們就獲得了一個(gè)信使。下面就是通過(guò)getBinder()把這個(gè)信使創(chuàng)建的Binder對(duì)象返回給客戶端(一旦客戶端拿到這個(gè)Binder,又可以將它還原為Messenger)。Handler中處理信息為:當(dāng)?shù)玫降腗essage的what值為MSG_SAY_HELLO時(shí)輸出Toast。

public class CustomService extends Service{
    static final int MSG_SAY_HELLO = 1;
    //實(shí)現(xiàn)一個(gè)能夠處理接收信息的Handler
    class IncomingHandler extends Handler{
        @Override
        public void handleMessage(Message msg) {
            super.handleMessage(msg);
            switch(msg.what){
                case MSG_SAY_HELLO:
                    Toast.makeText(getApplicationContext(),"hello!",Toast.LENGTH_SHORT).show();
                    break;
                default:
                    super.handleMessage(msg);
            }
        }
    }
    //被客戶端接收的Messenger對(duì)象
    final Messenger messenger = new Messenger(new IncomingHandler());
    @Override
    public IBinder onBind(Intent intent) {
        Toast.makeText(getApplicationContext(),"binding!",Toast.LENGTH_SHORT).show();
        return messenger.getBinder();
    }
}

Activity實(shí)現(xiàn)

在客戶端中我們應(yīng)該做的是:拿到服務(wù)端傳來(lái)的Messenger對(duì)象(在ServiceConnection中取得,具體參見(jiàn)上一篇文章),然后創(chuàng)建一個(gè)Message對(duì)象,為Message寫入數(shù)據(jù),注意Message中的what要與服務(wù)端中Handler對(duì)象中的what一致。使用該Messenger通過(guò)send()將Message發(fā)送給服務(wù)端,這樣就可以實(shí)現(xiàn)客戶端與服務(wù)端的單向通信了。具體代碼如下:

public class MainActivity extends AppCompatActivity {
    private Button mBtStart;
    private Messenger messenger = null;
    private boolean mBound;
    private TextView mTvMsg;
    private ServiceConnection serviceConnection = new ServiceConnection() {
        @Override
        public void onServiceConnected(ComponentName name, IBinder service) {
            messenger = new Messenger(service);
            mBound = true;
        }

        @Override
        public void onServiceDisconnected(ComponentName name) {
            messenger = null;
            mBound = false;
        }
    };
    public void sayHello(View v){
        if(!mBound) return;
        Message msg = Message.obtain(null,CustomService.MSG_SAY_HELLO,0,0);
        try{
            messenger.send(msg);
        }catch (RemoteException e){
            e.printStackTrace();
        }
    }
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        mBtStart = (Button) findViewById(R.id.bt_start);
        mTvMsg = (TextView) findViewById(R.id.tv_msg);
        mBtStart.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                Intent intent = new Intent(MainActivity.this,CustomService.class);
                bindService(new Intent(MainActivity.this,CustomService.class),serviceConnection, Context.BIND_AUTO_CREATE);
            }
        });
    }
    @Override
    protected void onStop() {
        super.onStop();
        // Unbind from the service
        if (mBound) {
            unbindService(serviceConnection);
            mBound = false;
        }
    }
}

以上過(guò)程一開(kāi)始理解可能會(huì)有些抽象,多動(dòng)手才能加深理解。

多應(yīng)用程序多進(jìn)程雙向通信

仍然以Activity和Service通信為例,不過(guò)這次我們需要新建兩個(gè)Module(ClientApp和ServiceApp),ClientApp中就一個(gè)Activity,ServiceApp中一個(gè)Service(關(guān)于沒(méi)有Activity的App的啟動(dòng)方式自行百度)。這樣就是兩個(gè)應(yīng)用程序兩個(gè)進(jìn)程的情況了。下面開(kāi)始分析這種情況下的Messenger的用法:

Service實(shí)現(xiàn)

依然是先從Service開(kāi)始。大致思路與上面的Service的創(chuàng)建類似,但又一點(diǎn)不同的是,這次我們需要新建一個(gè)clientMessenger來(lái)實(shí)現(xiàn)Service向客戶端發(fā)送Message操作。在Service的Handler中有這樣一段代碼,

clientMessenger = msg.replyTo;//這個(gè)Message是在客戶端中創(chuàng)建的
                if(clientMessenger!=null){
                    Message msgToClient = Message.obtain();
                    msgToClient.what = SEND_MESSAGE_CODE;
                    Bundle bundle = new Bundle();
                    bundle.putString("msg","客戶端,我接收到你的消息了,這是我回應(yīng)給你的,看到了嗎?");
                    msgToClient.setData(bundle);
                    try {
                        clientMessenger.send(msgToClient);
                    } catch (RemoteException e) {
                        e.printStackTrace();
                    }
                }

上面代碼用來(lái)接收到客戶端發(fā)送來(lái)的數(shù)據(jù)后向客戶端發(fā)送數(shù)據(jù)作出回應(yīng)。注意這里的clientMessenger = msg.replyTo;,是指從客戶端中取出與msg一道捆綁過(guò)來(lái)的clientMessenger對(duì)象。利用clientMessenger就可以實(shí)現(xiàn)向Activity中返回?cái)?shù)據(jù)了。

詳細(xì)代碼如下:

public class MyService extends Service {
    private static final int RECEIVE_MESSAGE_CODE = 0x0001;
    private static final int SEND_MESSAGE_CODE = 0x0002;

    private Messenger clientMessenger = null;
    private Messenger serviceMessenger = new Messenger(new ServiceHandler());
    @Override
    public IBinder onBind(Intent intent) {
        return serviceMessenger.getBinder();
    }

    @Override
    public void onCreate() {
        super.onCreate();
    }

    @Override
    public void onDestroy() {
        super.onDestroy();
        clientMessenger = null;
    }

    private class ServiceHandler extends Handler{
        @Override
        public void handleMessage(Message msg) {
            super.handleMessage(msg);
            if(msg.what == RECEIVE_MESSAGE_CODE){
                Bundle data = msg.getData();
                if(data != null){
                    String str = data.getString("msg");
                    Toast.makeText(getApplicationContext(),"Service:I received the message:"+str,Toast.LENGTH_SHORT).show();
                }
                clientMessenger = msg.replyTo;//這個(gè)Message是在客戶端中創(chuàng)建的
                if(clientMessenger!=null){
                    Message msgToClient = Message.obtain();
                    msgToClient.what = SEND_MESSAGE_CODE;
                    Bundle bundle = new Bundle();
                    bundle.putString("msg","客戶端,我接收到你的消息了,這是我回應(yīng)給你的,看到了嗎?");
                    msgToClient.setData(bundle);
                    try {
                        clientMessenger.send(msgToClient);
                    } catch (RemoteException e) {
                        e.printStackTrace();
                    }
                }
            }

        }
    }
}

Activity實(shí)現(xiàn):

Activity中主要是實(shí)現(xiàn)綁定發(fā)送數(shù)據(jù)和解除綁定兩大塊功能。綁定先發(fā)送顯式Intent(5.0以上不支持隱式啟動(dòng)Service,具體操作見(jiàn)下面的啟動(dòng)過(guò)程)綁定Service,當(dāng)綁定成功后獲取Messenger對(duì)象并使用該對(duì)象發(fā)送Message對(duì)象msg給Service,具體操作與上面的一樣。這里有一點(diǎn)不一樣的是,為了能夠使得Service能獲得clientMessenger,我們必須手動(dòng)將msg與clientMessenger關(guān)聯(lián),即:msg.replyTo = clientMessenger;。這樣Service在獲得Activity發(fā)送過(guò)來(lái)的Message的同時(shí)也可以取到clientMessenger。而clientMessenger必須先創(chuàng)建出來(lái),方法與單向獲取時(shí)一致。

詳細(xì)代碼如下:

public class MainActivity extends AppCompatActivity{
    private Button mBtBind;
    private Button mBtUnBind;
    private TextView mTvMsg;

    private static final int SEND_MESSAGE_CODE = 0x0001;
    private static final int RECEIVE_MESSAGE_CODE = 0x0002;
    private boolean isBound = false;

    private String SERVICE_ACTION = "com.example.serviceapp.MyService";

    private Messenger serviceMessenger = null;

    private Messenger clientMessenger = new Messenger(new ClientHandler());
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        mBtBind = (Button) findViewById(R.id.bt_bind);
        mBtUnBind = (Button) findViewById(R.id.bt_unbind);
        mTvMsg = (TextView) findViewById(R.id.tv_msg);
        mBtUnBind.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                if(isBound){
                    unbindService(serviceConnection);
                }
            }
        });
        mBtBind.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                if(!isBound){
                    Intent intent = new Intent();
                    intent.setAction(SERVICE_ACTION);
                    intent.addCategory(Intent.CATEGORY_DEFAULT);
                    PackageManager pm = getPackageManager();
                    ResolveInfo info = pm.resolveService(intent,0);
                    if(info != null){
                        String packageName = info.serviceInfo.packageName;
                        String serviceName = info.serviceInfo.name;
                        ComponentName componentName = new ComponentName(packageName,serviceName);
                        intent.setComponent(componentName);
                        bindService(intent,serviceConnection,BIND_AUTO_CREATE);
                    }
                }
            }
        });
    }
    private ServiceConnection serviceConnection = new ServiceConnection() {
        @Override
        public void onServiceConnected(ComponentName name, IBinder service) {
            serviceMessenger = new Messenger(service);
            isBound = true;
            Message msg = Message.obtain();
            msg.what = SEND_MESSAGE_CODE;
            Bundle data = new Bundle();
            data.putString("msg","你好,MyService,我是客戶端");
            msg.setData(data);
            msg.replyTo = clientMessenger;
            try {
                serviceMessenger.send(msg);
            } catch (RemoteException e) {
                e.printStackTrace();
            }
        }

        @Override
        public void onServiceDisconnected(ComponentName name) {
            serviceMessenger = null;
            isBound = false;
        }
    };
    private class ClientHandler extends Handler{
        @Override
        public void handleMessage(Message msg) {
            super.handleMessage(msg);
            if(msg.what == RECEIVE_MESSAGE_CODE){
                Bundle data = msg.getData();
                if(data != null){
                    String str = data.getString("msg");
                    mTvMsg.setText(str);
                }
            }
        }
    }
}

總結(jié)

這一塊理解起來(lái)可能比較吃力,所以希望讀者多加嘗試,為后面的AIDL跨通信方式學(xué)習(xí)做準(zhǔn)備。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容