Android開發(fā)藝術(shù)探索-IPC機制

什么是IPC

Inter-Process Comminication 進程間通信

各平臺進程間如何通信

  • Windows
    剪切板、管道和油槽
  • Linux
    命名管道、共享內(nèi)容和信號量
  • Android
    基于Linux，常用Binder和Socket

Android應(yīng)用如何開啟多進程

  • 通過給四大組件指定android:process
  • 通過JNI在native層fork一個新的進程 不推薦

指定android:processs

  • 系統(tǒng)將為每個進程名生成一個進程，進程名相同將運行在同一進程中
樣式 實際進程名
:remote ${packageName}:remote
com.a.b.remote com.a.b.remote

同程序多進程的危害

情況 原因
靜態(tài)成員和單例失效 在不同的虛擬機中
線程同步機制完全失效 鎖無法保證同步，因為在不同的虛擬機中
線程同步機制完全失效 鎖無法保證同步，因為在不同的虛擬機中
SharedPreferences數(shù)據(jù)丟失 多個進程對同一個文件進行讀寫引起
Application多次創(chuàng)建 每個虛擬機都會創(chuàng)建一次3

對象序列化

  • Serializable : 常用于存儲和網(wǎng)絡(luò)通信
  • Parcelable ： 常用于內(nèi)存通信，由于在內(nèi)存中序列化，效率更高
  • Bundle

ipc方式的優(yōu)缺點和適用場景

名稱 優(yōu)點 缺點 設(shè)用場景
Bundle 簡單易用 只能傳輸Bundle支持的數(shù)據(jù)類型 四大組件間的進程通信
文件共享 簡單易用 不適合高并發(fā)的情況，并且無法做到進程間的即時通訊 無并發(fā)訪問情況下，交換簡單的數(shù)據(jù)實時性不高的情況
AIDL 功能強大,支持一對多并發(fā)通信，支持實時通訊 需要處理好線程同步 一對多通信且有Rpc需求
Messager 支持一對多串行通信，支持實時通訊 不能很好處理高并發(fā)情況，不支持Rpc，數(shù)據(jù)通過Message進行傳輸，因此只能傳輸Bundle支持的數(shù)據(jù)類型 低并發(fā)的一對多即時通信,無Rpc需求，或者無需返回結(jié)果的Rpc需求
ContentProvider 在數(shù)據(jù)源訪問方面功能強大,支持一對多并發(fā)數(shù)據(jù)共享，可通過call方法擴展其他操作 主要提供數(shù)據(jù)源的Crud 一對多的進程間數(shù)據(jù)共享
Socket 功能強大,可以通過網(wǎng)絡(luò)傳輸字節(jié)流，支持一對多并發(fā)實時通訊 實現(xiàn)細(xì)節(jié)有點繁瑣，不支持直接的Rpc 網(wǎng)絡(luò)數(shù)據(jù)交換

Binder各角度理解

  • IPC 是一種跨進程通信方式，也可理解為虛擬的物理設(shè)備/dev/binder
  • Android Framework 是ServiceManager連接各種Mangager的橋梁
  • 應(yīng)用層 是客戶端和服務(wù)端進行通信的媒介AIDL

AIDL使用解析

文件共享

  • 適合在數(shù)據(jù)同步要求不高的進程之間進行通信
  • SharedPreference也是文件共享，但由于Android對他有一層內(nèi)存緩存，所以多進程操作很容易丟失數(shù)據(jù)。

使用Messenger

  • 是輕量級IPC方案，頂層使用AIDL實現(xiàn)
  • 串行(Handler)處理請求，大量并發(fā)請求狀況不適用
public class MessengerService extends Service {
    private static class MessengerHandler extends Handler {
        @Override
        public void handleMessage(Message msg) {
            //  回數(shù)據(jù)
            switch (msg.what) {
                case 0:
                    System.out.println(msg.getData().getString("request"));
                    Messenger client = msg.replyTo;
                    Message replyMsg = Message.obtain(null, 1);
                    Bundle data = new Bundle();
                    data.putString("result", "i've received you request");
                    replyMsg.setData(data);
                    try {
                        client.send(replyMsg);
                        break;
                    } catch (RemoteException e) {
                        e.printStackTrace();
                    }
                default:
                    super.handleMessage(msg);
            }
        }
    }

    private final Messenger mMessenger = new Messenger(new MessengerHandler());

    @Nullable
    @Override
    public IBinder onBind(Intent intent) {
        return mMessenger.getBinder();
    }
}

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

public class MainActivity extends AppCompatActivity {
    private Messenger mMessenger;

    private Messenger mGetReplyMessenger = new Messenger(new ClientMsgHandler());

    private ServiceConnection mServiceConnection = new ServiceConnection() {
        @Override
        public void onServiceConnected(ComponentName name, IBinder service) {
            //  發(fā)數(shù)據(jù)
            mMessenger = new Messenger(service);
            Message msg = Message.obtain(null, 0);
            Bundle data = new Bundle();
            data.putString("request", "i'm client, send a msg");
            msg.setData(data);
            msg.replyTo = mGetReplyMessenger;
            try {
                mMessenger.send(msg);
            } catch (RemoteException e) {
                e.printStackTrace();
            }
        }

        @Override
        public void onServiceDisconnected(ComponentName name) {
        }
    };

    static class ClientMsgHandler extends Handler {
        @Override
        public void handleMessage(Message msg) {
            switch (msg.what) {
                case 1:
                    Bundle data = msg.getData();
                    System.out.println(data.getString("result"));
                    break;
                default:
                    super.handleMessage(msg);
            }
        }
    }

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        Intent intent = new Intent(MainActivity.this, MessengerService.class);
        bindService(intent, mServiceConnection, Context.BIND_AUTO_CREATE);
    }

    @Override
    protected void onDestroy() {
        unbindService(mServiceConnection);
        super.onDestroy();
    }
}

AIDL跨進程回調(diào)

  • 封裝一個集合存儲回調(diào)

  • 由于跨進程對象會經(jīng)過序列化和反序列化（普通集合移除時傳入對象和集合中對象不同），所以需要使用RemoteCallbackList來避免回調(diào)對象移除失敗

  • RemoteCallbackList : 內(nèi)部有個ArrayMap結(jié)構(gòu)專門用來保存AIDL回調(diào)，這個Map的key是Ibinder類型，value是CallBack類型。其中CallBack中封裝了真正的Listener遠(yuǎn)程對象

  • 服務(wù)端

// IOnChangeListener.aidl  回調(diào)接口
package com.rtfsc.passwordinputview;
interface IOnChangeListener {
    void onChange(String aString);
}

// IMyAidlInterface.aidl 遠(yuǎn)程服務(wù)接口
package com.rtfsc.passwordinputview;
import com.rtfsc.passwordinputview.IOnChangeListener;
interface IMyAidlInterface {
    void doSomething(String str);
    void registerListener(IOnChangeListener listener);
    void unregisterListener(IOnChangeListener listener);
}

// AidlService.java 遠(yuǎn)程服務(wù)Service
public class AidlService extends Service {
    private RemoteCallbackList<IOnChangeListener> mCallbackList = new RemoteCallbackList<>();

    private Binder mBinder = new IMyAidlInterface.Stub() {

        @Override
        public void doSomething(String str) throws RemoteException {
            System.out.println("AidlService.doSomething@" + str);
        }

        @Override
        public void registerListener(IOnChangeListener listener) throws RemoteException {
            listener.onChange("call back register");
            System.out.println("AidlService.registerListener@" + mCallbackList.register(listener));

        }

        @Override
        public void unregisterListener(IOnChangeListener listener) throws RemoteException {
            listener.onChange("call back unregister");
            System.out.println("AidlService.unregisterListener@" + mCallbackList.unregister(listener));
        }
    };

    @Nullable
    @Override
    public IBinder onBind(Intent intent) {
        return mBinder;
    }
}

// AndroidManifest.xml
<service    
  android:name=".AidlService"    
  android:process=":remote"/>
  • 客戶端
public class MainActivity extends AppCompatActivity {
    IMyAidlInterface iMyAidlInterface;
    private ServiceConnection mServiceConnection = new ServiceConnection() {
        @Override
        public void onServiceConnected(ComponentName name, IBinder service) {
            iMyAidlInterface = IMyAidlInterface.Stub.asInterface(service);
            try {
                iMyAidlInterface.registerListener(mListener);
            } catch (RemoteException e) {
                e.printStackTrace();
            }
        }

        @Override
        public void onServiceDisconnected(ComponentName name) {

        }
    };

    private IOnChangeListener mListener = new IOnChangeListener.Stub() {
        @Override
        public void onChange(String aString) throws RemoteException {
            System.out.println(aString);
        }
    };

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        Intent intent = new Intent(MainActivity.this, AidlService.class);
        bindService(intent, mServiceConnection, Context.BIND_AUTO_CREATE);
    }

    @Override
    protected void onDestroy() {
        try {
            if (iMyAidlInterface != null) {
                iMyAidlInterface.unregisterListener(mListener);
            }
        } catch (RemoteException e) {
            e.printStackTrace();
        }
        unbindService(mServiceConnection);
        super.onDestroy();
    }
}
  • Log
07-28 18:04:24.017 6844-6844/com.rtfsc.passwordinputview I/System.out: call back register
07-28 18:04:24.017 6873-6890/com.rtfsc.passwordinputview:remote I/System.out: AidlService.registerListener@true
07-28 18:04:29.027 6844-6844/com.rtfsc.passwordinputview I/System.out: call back unregister
07-28 18:04:29.027 6873-6890/com.rtfsc.passwordinputview:remote I/System.out: AidlService.unregisterListener@true
最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務(wù)。

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

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