前面我們介紹了Serializable和Parcelable的基礎(chǔ)知識(shí)，以及Binder的相關(guān)內(nèi)容。本篇糕韧，開始分析各種跨進(jìn)程通信的方式枫振，Intent中附加extra信息，共享文件萤彩，Binder粪滤。另外ContentProvider天生就是支持跨進(jìn)程訪問的。此外雀扶，網(wǎng)絡(luò)通信也是跟進(jìn)程無關(guān)杖小，所以Socket也可以實(shí)現(xiàn)IPC。
ipc的BookSevice和MainActivity
Bundle
Android中四大組件中的三個(gè)組件（Activity愚墓、Service予权、Receiver）都是支持在Intent中傳遞數(shù)據(jù)的，Intent和Bunlde都實(shí)現(xiàn)了Parcelable接口浪册，都支持跨進(jìn)程通信扫腺，因?yàn)镮ntent.putExtra內(nèi)部就是用Bundle實(shí)現(xiàn)的。
public Intent putExtra(String name, String value) {
if (mExtras == null) {
mExtras = new Bundle();
}
mExtras.putString(name, value);
return this;
}
這個(gè)跟平時(shí)一個(gè)進(jìn)程中的寫法都一樣村象，可以說無感覺切換O(∩_∩)O
例子可見Bundle跨進(jìn)程
文件共享
文章共享可參考前面關(guān)于serializable和Parcelable時(shí)的內(nèi)容笆环。可以實(shí)現(xiàn)進(jìn)程間通信煞肾，因?yàn)楫吘故俏募种M(jìn)程無關(guān)，可是在處理并發(fā)時(shí)問題很嚴(yán)重籍救，比如习绢，一個(gè)進(jìn)程寫了一半兒，另一個(gè)進(jìn)程讀取了蝙昙；或者一個(gè)進(jìn)程寫闪萄，另一個(gè)也寫，那你說奇颠，同一個(gè)文件出來的是個(gè)啥败去？啥也不是！
Android中的SharedPreferences是個(gè)特例烈拒，雖然最終是在xml文件中圆裕，可是內(nèi)部還有內(nèi)存級(jí)的緩存，所以多進(jìn)程模式下荆几，數(shù)據(jù)極不可靠吓妆。不建議多進(jìn)程使用。
Messenger
Messenger的底層其實(shí)也是AIDL吨铸。一次處理一個(gè)請(qǐng)求行拢，所以不用考慮同步。
public Messenger(Handler target) {
mTarget = target.getIMessenger();
}
public Messenger(IBinder target) {
mTarget = IMessenger.Stub.asInterface(target);
}
簡(jiǎn)單實(shí)用方式如下:
Service
public class MessengerService extends Service {
private final static String TAG = "MessengerService";
private Handler serverHanlder = new Handler(){
@Override
public void handleMessage(Message msg) {
super.handleMessage(msg);
switch (msg.what) {
case MyConstants.MSG_FROM_CLIENT:
Log.d(TAG, "handleMessage: receive msg "+msg.getData().getString("msg"));
Messenger clientMessenger = msg.replyTo;
Message obtain = Message.obtain(null, MyConstants.MSG_FROM_SERVER);
Bundle bundle = new Bundle();
bundle.putString("msg","Hi,This is from server.");
obtain.setData(bundle);
try {
clientMessenger.send(obtain);
} catch (RemoteException e) {
e.printStackTrace();
}
break;
}
}
};
private Messenger serverMessenger = new Messenger(serverHanlder);
@Nullable
@Override
public IBinder onBind(Intent intent) {
return serverMessenger.getBinder();
}
}
Activity
public class MessengerActivity extends AppCompatActivity {
private static final String TAG = "MessengerActivity";
private Handler clientHandler = new Handler() {
@Override
public void handleMessage(Message msg) {
super.handleMessage(msg);
switch (msg.what) {
case MyConstants.MSG_FROM_SERVER:
Log.d(TAG, "handleMessage: receive msg "+msg.getData().getString("msg"));
break;
}
}
};
private Messenger clientMessenger = new Messenger(clientHandler);
private ServiceConnection mServiceConnection = new ServiceConnection() {
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
Messenger serviceMessenger = new Messenger(service);
Message message = Message.obtain(null, MyConstants.MSG_FROM_CLIENT);
Bundle bundle = new Bundle();
bundle.putString("msg", "Hello,This is client.");
message.setData(bundle);
message.replyTo = clientMessenger;
try {
serviceMessenger.send(message);
} catch (RemoteException e) {
e.printStackTrace();
}
}
@Override
public void onServiceDisconnected(ComponentName name) {
}
};
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_messenger);
bindService(new Intent(this, MessengerService.class), mServiceConnection, Context.BIND_AUTO_CREATE);
}
@Override
protected void onDestroy() {
unbindService(mServiceConnection);
super.onDestroy();
}
}
Messenger使用message傳輸數(shù)據(jù)诞吱，Message的what舟奠、arg1竭缝、arg2、obj沼瘫、Bundle以及replyTo都可以充當(dāng)數(shù)據(jù)載體抬纸。有人就說了，你看你晕鹊，有那么多簡(jiǎn)單的不用松却，非用一個(gè)Bundle，別急溅话，咱們來仔細(xì)看一下晓锻。
- what 就不說了，主要是區(qū)分不同消息
- arg1飞几、arg2 如果是int類型時(shí)的簡(jiǎn)寫形式
- obj 只能是Framework中的Parcelable類型的參數(shù)砚哆，自定義的不行
- replyTo 針對(duì)Messenger
- Bundle 所以你看，還能怎么辦屑墨，有用的就不錯(cuò)了躁锁，走起來吧
借用下開發(fā)藝術(shù)探索的原理圖
AIDL
AIDL的簡(jiǎn)單使用前面已經(jīng)說過（Binder章節(jié)中），代碼也有卵史，可以先大概熟悉下寫法战转。
接著以前的內(nèi)容說
AIDL支持的數(shù)據(jù)類型
- 基本數(shù)據(jù)類型
- String、CharSequence
- Parcelable：所有實(shí)現(xiàn)了Parcelable的接口的對(duì)象
- List：只支持ArrayList以躯，里面的每個(gè)元素需要支持AIDL
- Map：只支持HashMap槐秧，里面的每個(gè)元素都必須被AIDL支持，包括key和value
- AIDL：所有的AIDL接口本身也可以在AIDL中使用
- Parcelable對(duì)象和AIDL必須顯式的import進(jìn)來忧设。
- 使用都自定義的Parcelable對(duì)象時(shí)刁标，必須新建一個(gè)同名的AIDL文件，并且聲明為Parcelable類型址晕，如:
// Book.aidl
package com.breezehan.ipc;
parcelable Book;
- AIDL接口方法中膀懈，參數(shù)如果不是基礎(chǔ)類型，都需要標(biāo)上方向：in谨垃、out启搂、或者inout，in表示輸入型參數(shù)刘陶，out表示輸出型參數(shù)狐血，inout表示輸入輸出型參數(shù)。你真的理解AIDL中的in易核，out，inout么浪默？
我們改造下之前的AIDL寫法牡直，BookSevice中有個(gè)List缀匕，改造如下
public class BookService extends Service{
CopyOnWriteArrayList<Book> mBookList = new CopyOnWriteArrayList<>();
private IBinder binder = new IBookManager.Stub() {
@Override
public List<Book> getBookList() throws RemoteException {
return mBookList;
}
@Override
public void addBook(Book book) throws RemoteException {
mBookList.add(book);
}
};
@Override
public void onCreate() {
super.onCreate();
mBookList.add(new Book(1, "三體"));
mBookList.add(new Book(2, "Android"));
}
@Nullable
@Override
public IBinder onBind(Intent intent) {
return binder;
}
}
可是前面不是說List只能是ArrayList嗎
AIDL是運(yùn)行在Binder線程池中的，可以多個(gè)客戶端同時(shí)連接碰逸，會(huì)存在多個(gè)線程同時(shí)訪問的情況乡小，而CopyOnWriteArrayList支持并發(fā)的讀寫
AIDL中支持抽象的List，雖然服務(wù)端返回的是CopyOnWriteArrayList饵史，但是Binder中會(huì)按照List的規(guī)范訪問數(shù)據(jù)并最終形成一個(gè)ArrayList給客戶端满钟。類似的還有ConcurrentHashMap。
代碼參考
改進(jìn)型AIDL
有種情況胳喷，假如Service相當(dāng)于圖書館湃番，客戶端不想輪詢查詢有什么書，圖書館加入新書吭露，直接通知我一下就好了吠撮，也可以取消提醒，這就是常說的觀察者模式讲竿。
首先泥兰，我們需要有個(gè)監(jiān)聽接口，客戶端實(shí)現(xiàn)题禀。這里只能是AIDL接口IOnNewBookArrivedListener.aidl
// IOnNewBookArrivedListener.aidl
package com.breezehan.ipc;
import com.breezehan.ipc.Book;
interface IOnNewBookArrivedListener {
void onNewBookArrived(in Book book);
}
IBookManager也需要改造
// IBookManager.aidl
package com.breezehan.ipc;
import com.breezehan.ipc.Book;
import com.breezehan.ipc.IOnNewBookArrivedListener;
interface IBookManager {
List<Book> getBookList();
void addBook(in Book book);
void registerListener(IOnNewBookArrivedListener listener);
void unRegisterListener(IOnNewBookArrivedListener listener);
}
Service和Activity見github代碼鞋诗。
運(yùn)行結(jié)果如下
com.breezehan.ipc進(jìn)程中
com.breezehan.ipc:remote進(jìn)程中
哈哈，你看迈嘹，多進(jìn)程的觀察者模式成功了削彬。
不過，等會(huì)兒再高興江锨，本來我們?cè)贏ctivity中的onDestroy中設(shè)置了
@Override
protected void onDestroy() {
if (iBookManager != null && iBookManager.asBinder().isBinderAlive()) {
Log.d(TAG, "onDestroy: unregister listener "+mOnNewBookArrivedListener);
try {
iBookManager.unRegisterListener(mOnNewBookArrivedListener);
} catch (RemoteException e) {
e.printStackTrace();
}
}
unbindService(mServiceConnection);
super.onDestroy();
}
真正推出Activity時(shí)吃警，打印會(huì)出現(xiàn)
嘛意思，not found,can not unregister.
為什么呢啄育？為什么會(huì)解注冊(cè)失敗呢酌心。
我們要知道，Binder傳輸?shù)牡膶?duì)象挑豌，整個(gè)是一個(gè)序列化安券、反序列化的過程，Binder會(huì)把客戶端傳過來的對(duì)象反序列化成一個(gè)新對(duì)象氓英，不是一個(gè)對(duì)象侯勉，怎么能remote掉呢！
進(jìn)階化改進(jìn)型AIDL
這里我們要使用到RemoteCallbackList铝阐。使系統(tǒng)提供的專門用于刪除跨進(jìn)程listener的接口址貌，看它的定義，接收extend IInterface的參數(shù)，即所有的AIDL都可以支持练对。
public class RemoteCallbackList<E extends IInterface>
它的內(nèi)部有個(gè)ArrayMap用戶保存AIDL的listener遍蟋，Map中的key時(shí)IBInder類型，value是Callback類型
ArrayMap<IBinder, Callback> mCallbacks
= new ArrayMap<IBinder, Callback>();
看register(E callback)詳細(xì)代碼螟凭，我們知道虚青，雖然每次客戶端傳輸過去的listener，最終都被binder生成一個(gè)個(gè)不同的對(duì)象（內(nèi)部相同）螺男，但是底層的Binder對(duì)象只是一個(gè)棒厘。
public boolean register(E callback, Object cookie) {
synchronized (mCallbacks) {
if (mKilled) {
return false;
}
IBinder binder = callback.asBinder();
try {
Callback cb = new Callback(callback, cookie);
binder.linkToDeath(cb, 0);
mCallbacks.put(binder, cb);//使用binder作為key，同一個(gè)binder只有一個(gè)對(duì)象下隧。
return true;
} catch (RemoteException e) {
return false;
}
}
}
使用RemoteCallbackList改進(jìn)的Service如下：
@Override
public void registerListener(IOnNewBookArrivedListener listener) throws RemoteException {
mArrivedListeners.register(listener);
}
@Override
public void unRegisterListener(IOnNewBookArrivedListener listener) throws RemoteException {
mArrivedListeners.unregister(listener);
}
private void onNewBookArrived(Book newBook) throws RemoteException {
mBookList.add(newBook);
int N = mArrivedListeners.beginBroadcast();
for(int i=0;i<N;i++) {
IOnNewBookArrivedListener broadcastItem = mArrivedListeners.getBroadcastItem(i);
if (broadcastItem != null) {
broadcastItem.onNewBookArrived(newBook);
}
}
mArrivedListeners.finishBroadcast();
}
AIDL服務(wù)端 有時(shí)不想任何人都可以連接奢人，必須加入驗(yàn)證服務(wù)，驗(yàn)證內(nèi)容再次就不做探索了（我可不說是因?yàn)闆]用過）汪拥。
使用ContentProvider
ContentProvider跟Messenger一樣达传，底層都是Binder實(shí)現(xiàn)。但是ContentProvider是Android中提供的專門用于不同應(yīng)用間進(jìn)行數(shù)據(jù)共享的方式迫筑，天生就適合進(jìn)程間通信宪赶。封裝的很好，比AIDL簡(jiǎn)單很多脯燃。
像通訊錄搂妻、日歷等，都實(shí)現(xiàn)了ContentProvider辕棚，我們只需要通過ContentResolver的query欲主、update、insert逝嚎、delete方法即可扁瓢。
Provider，雖然沒有具體內(nèi)容补君，但是不耽誤使用引几。對(duì)象代碼provider示例代碼
public class BookProvider extends ContentProvider {
private static final String TAG = "BookProvider";
@Override
public boolean onCreate() {
Log.d(TAG, "onCreate,current Thread: "+Thread.currentThread().getName());
return false;
}
@Nullable
@Override
public Cursor query(@NonNull Uri uri, @Nullable String[] projection, @Nullable String selection, @Nullable String[] selectionArgs, @Nullable String sortOrder) {
Log.d(TAG, "onCreate,current Thread: "+Thread.currentThread().getName());
return null;
}
@Nullable
@Override
public String getType(@NonNull Uri uri) {
Log.d(TAG, "getType");
return null;
}
@Nullable
@Override
public Uri insert(@NonNull Uri uri, @Nullable ContentValues values) {
Log.d(TAG, "insert");
return null;
}
@Override
public int delete(@NonNull Uri uri, @Nullable String selection, @Nullable String[] selectionArgs) {
Log.d(TAG, "delete");
return 0;
}
@Override
public int update(@NonNull Uri uri, @Nullable ContentValues values, @Nullable String selection, @Nullable String[] selectionArgs) {
Log.d(TAG, "update");
return 0;
}
}
ProviderActivity
public class ProviderActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_provider);
Uri uri = Uri.parse("content://com.breezehan.ipc.book.provider");
getContentResolver().query(uri, null, null, null, null);
getContentResolver().query(uri, null, null, null, null);
getContentResolver().query(uri, null, null, null, null);
}
清單文件配置，provider中android:authorities需要時(shí)唯一的挽铁，android:permission="com.breezehan.PROVIDER"表示權(quán)限伟桅，其他app想使用這個(gè)provider，必須聲明權(quán)限叽掘；process就不說了楣铁，不想弄兩個(gè)應(yīng)用，開個(gè)進(jìn)程更扁。
<provider
android:name=".provider.BookProvider"
android:authorities="com.breezehan.ipc.book.provider"
android:permission="com.breezehan.PROVIDER"
android:process=":provider" />
<activity android:name=".provider.ProviderActivity">
<intent-filter>
<action android:name="android.intent.action.MAIN" />
<category android:name="android.intent.category.LAUNCHER" />
</intent-filter>
</activity>
運(yùn)行結(jié)果如下
看到了吧盖腕，Binder線程池赫冬。onCreate是UI線程，三次query可能會(huì)在不同線程赊堪。
我們用Sqlite簡(jiǎn)單實(shí)現(xiàn)邏輯內(nèi)容面殖，其實(shí)ContenProvider內(nèi)部想怎么實(shí)現(xiàn)都行。
DbOpenHelper
public class DbOpenHelper extends SQLiteOpenHelper {
private static final String DB_NAME = "bookprovider.db";
private static final int DB_VERSION = 1;
public static final String BOOK_TABLE_NAME = "book";
public static final String USER_TABLE_NAME = "user";
public static final String CREATE_BOOK_TABLE = "CREATE TABLE IF NOT EXISTS " + BOOK_TABLE_NAME + "( _id INTEGER PRIMARY KEY, name TEXT)";
public static final String CREATE_USER_TABLE = "CREATE TABLE IF NOT EXISTS " + USER_TABLE_NAME + " (_id INTEGER PRIMARY KEY, name TEXT,sex INT)";
public DbOpenHelper(Context context) {
super(context, DB_NAME, null, DB_VERSION);
}
@Override
public void onCreate(SQLiteDatabase db) {
db.execSQL(CREATE_BOOK_TABLE);
db.execSQL(CREATE_USER_TABLE);
}
@Override
public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
}
}
BookProvider改造
public class BookProvider extends ContentProvider {
private static final String TAG = "BookProvider";
public static final String AUTHRORITY = "com.breezehan.ipc.book.provider";
public static final Uri BOOK_CONTENT_URI = Uri.parse("content://" + AUTHRORITY + "/book");
public static final Uri USER_CONTENT_URI = Uri.parse("content://" + AUTHRORITY + "/user");
public static final int BOOK_URI_CODE = 0;
public static final int USER_URI_CODE = 1;
private static final UriMatcher sUriMatcher = new UriMatcher(UriMatcher.NO_MATCH);
static {
sUriMatcher.addURI(AUTHRORITY, "book", BOOK_URI_CODE);//將uri和uricode關(guān)聯(lián)起來
sUriMatcher.addURI(AUTHRORITY,"user",USER_URI_CODE);
}
private Context mContext;
private SQLiteDatabase sqLiteDatabase;
@Override
public boolean onCreate() {
Log.d(TAG, "onCreate,current Thread: "+Thread.currentThread().getName());
mContext =getContext();
//初始化數(shù)據(jù)庫哭廉，真正使用不能這樣寫，MainThread
initProviderData();
return true;
}
private void initProviderData() {
sqLiteDatabase = new DbOpenHelper(mContext).getWritableDatabase();
sqLiteDatabase.execSQL("delete from "+DbOpenHelper.BOOK_TABLE_NAME);
sqLiteDatabase.execSQL("delete from "+DbOpenHelper.USER_TABLE_NAME);
sqLiteDatabase.execSQL("insert into book values(3,'Android');");
sqLiteDatabase.execSQL("insert into book values(4,'Ios');");
sqLiteDatabase.execSQL("insert into book values(5,'Html5');");
sqLiteDatabase.execSQL("insert into user values(1,'jake',1);");
sqLiteDatabase.execSQL("insert into user values(5,'Html5',0);");
}
@Nullable
@Override
public Cursor query(@NonNull Uri uri, @Nullable String[] projection, @Nullable String selection, @Nullable String[] selectionArgs, @Nullable String sortOrder) {
Log.d(TAG, "query,current Thread: "+Thread.currentThread().getName());
String tableName = getTableName(uri);
if (tableName == null) {
throw new IllegalArgumentException("Unsupported URI:" + uri);
}
return sqLiteDatabase.query(tableName,projection,selection,selectionArgs,null,null,sortOrder,null);
}
@Nullable
@Override
public String getType(@NonNull Uri uri) {
Log.d(TAG, "getType");
return null;
}
@Nullable
@Override
public Uri insert(@NonNull Uri uri, @Nullable ContentValues values) {
Log.d(TAG, "insert");
String table = getTableName(uri);
if (table == null) {
throw new IllegalArgumentException("Unsupported URI:" + uri);
}
sqLiteDatabase.insert(table, null, values);
mContext.getContentResolver().notifyChange(uri,null);//通知外界相叁，ContentProvider的數(shù)據(jù)已經(jīng)改變
return uri;
}
@Override
public int delete(@NonNull Uri uri, @Nullable String selection, @Nullable String[] selectionArgs) {
Log.d(TAG, "delete");
String table = getTableName(uri);
if (table == null) {
throw new IllegalArgumentException("Unsupported URI:" + uri);
}
int count = sqLiteDatabase.delete(table, selection, selectionArgs);
if (count > 0) {
mContext.getContentResolver().notifyChange(uri,null);
}
return count;
}
@Override
public int update(@NonNull Uri uri, @Nullable ContentValues values, @Nullable String selection, @Nullable String[] selectionArgs) {
Log.d(TAG, "update");
String table = getTableName(uri);
if (table == null) {
throw new IllegalArgumentException("Unsupported URI:" + uri);
}
int row = sqLiteDatabase.update(table, values, selection, selectionArgs);
if (row > 0) {
mContext.getContentResolver().notifyChange(uri,null);
}
return row;
}
private String getTableName(Uri uri) {
String tableName = null;
switch (sUriMatcher.match(uri)) {
case BOOK_URI_CODE:
tableName = DbOpenHelper.BOOK_TABLE_NAME;
break;
case USER_URI_CODE:
tableName = DbOpenHelper.USER_TABLE_NAME;
break;
}
return tableName;
}
}
ProviderActivity中
public class ProviderActivity extends AppCompatActivity {
private static final String TAG = "ProviderActivity";
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_provider);
Uri bookUri = Uri.parse("content://com.breezehan.ipc.book.provider/book");//BOOK_CONTENT_URI
ContentValues values = new ContentValues();
values.put("_id", "6");
values.put("name","程序設(shè)計(jì)的藝術(shù)");
getContentResolver().insert(bookUri, values);
Cursor bookCursor = getContentResolver().query(bookUri, new String[]{"_id", "name"}, null, null, null);
while (bookCursor.moveToNext()) {
Book book = new Book(bookCursor.getInt(0),bookCursor.getString(1));
Log.d(TAG, "query book:"+book.toString());
}
bookCursor.close();
}
}
運(yùn)行結(jié)果如下
上面只是簡(jiǎn)單介紹ContentProvider的基本使用方法遵绰，深入使用還有很多知識(shí)。
使用Socket
內(nèi)容略
