Android多進程之手動編寫Binder類
Android多進程系列
- Android 多進程通訊之幾個基本問題
- Android多進程之Binder的使用
- Android多進程之Binder解綁監聽的問題
- Android多進程之Binder的意外死亡及權限校驗
- Android 多進程之Messenger的使用
分析系統生成的Binder類
package com.xxq2dream.aidl;
public interface IBookManager extends android.os.IInterface {
/**
* Local-side IPC implementation stub class.
*/
public static abstract class Stub extends android.os.Binder implements com.xxq2dream.aidl.IBookManager {
private static final java.lang.String DESCRIPTOR = "com.xxq2dream.aidl.IBookManager";
/**
* Construct the stub at attach it to the interface.
*/
public Stub() {
this.attachInterface(this, DESCRIPTOR);
}
/**
* 用於將服務端的Binder對象轉換成客戶端所須要的AIDL接口類型的對象
*/
public static com.xxq2dream.aidl.IBookManager asInterface(android.os.IBinder obj) {
if ((obj == null)) {
return null;
}
android.os.IInterface iin = obj.queryLocalInterface(DESCRIPTOR);
//這裏經過instanceof方法判斷是不是跨進程，若是客戶端和服務端位於同一進程，則返回的是服務端的Stub對象自己，不會調用跨進程的transact方法
if (((iin != null) && (iin instanceof com.xxq2dream.aidl.IBookManager))) {
return ((com.xxq2dream.aidl.IBookManager) iin);
}
//若是客戶端和服務端不在同一個進程中，那麼返回的是系統封裝好的Stub.Proxy代理對象，客戶端調用會走transact方法發起跨進程請求
return new com.xxq2dream.aidl.IBookManager.Stub.Proxy(obj);
}
//返回當前Binder對象
@Override
public android.os.IBinder asBinder() {
return this;
}
/**
* 運行在服務端的Binder線程池中
*
* @param code 要運行的方法標識
* @param data 客戶端傳遞過來的參數
* @param reply 回傳給客戶端的數據
* @param flags
* @return true 表示執行成功；false，執行失敗，客戶端的請求失敗
* @throws RemoteException
*/
@Override
public boolean onTransact(int code, android.os.Parcel data, android.os.Parcel reply, int flags) throws android.os.RemoteException {
switch (code) {
case INTERFACE_TRANSACTION: {
reply.writeString(DESCRIPTOR);
return true;
}
case TRANSACTION_getBookList: {
data.enforceInterface(DESCRIPTOR);
java.util.List<com.xxq2dream.aidl.Book> _result = this.getBookList();
reply.writeNoException();
//將結果寫入reply返回
reply.writeTypedList(_result);
return true;
}
case TRANSACTION_addBook: {
data.enforceInterface(DESCRIPTOR);
com.xxq2dream.aidl.Book _arg0;
if ((0 != data.readInt())) {
_arg0 = com.xxq2dream.aidl.Book.CREATOR.createFromParcel(data);
} else {
_arg0 = null;
}
this.addBook(_arg0);
reply.writeNoException();
return true;
}
}
return super.onTransact(code, data, reply, flags);
}
private static class Proxy implements com.xxq2dream.aidl.IBookManager {
private android.os.IBinder mRemote;
Proxy(android.os.IBinder remote) {
mRemote = remote;
}
@Override
public android.os.IBinder asBinder() {
return mRemote;
}
public java.lang.String getInterfaceDescriptor() {
return DESCRIPTOR;
}
/**
* 運行在客戶端的Binder線程池中
* 當客戶端和服務端不在同一個進程中時，經過上面的asInterface方法返回的就是這個Proxy對象
* 調用服務端的方法就是調用這裏對應的方法，最終走的是transact方法發起遠程過程調用
*
* @return
* @throws RemoteException
*/
@Override
public java.util.List<com.xxq2dream.aidl.Book> getBookList() throws android.os.RemoteException {
//用於向服務端傳遞參數
android.os.Parcel _data = android.os.Parcel.obtain();
//用於接收服務端傳回來的結果
android.os.Parcel _reply = android.os.Parcel.obtain();
java.util.List<com.xxq2dream.aidl.Book> _result;
try {
_data.writeInterfaceToken(DESCRIPTOR);
//發起遠程過程調用請求，同時當前線程掛起，服務端的onTransact方法會被調用
mRemote.transact(Stub.TRANSACTION_getBookList, _data, _reply, 0);
//上述調用過程返回後，當前線程繼續執行，從reply中取出結果返回
_reply.readException();
_result = _reply.createTypedArrayList(com.xxq2dream.aidl.Book.CREATOR);
} finally {
_reply.recycle();
_data.recycle();
}
return _result;
}
@Override
public void addBook(com.xxq2dream.aidl.Book book) throws android.os.RemoteException {
android.os.Parcel _data = android.os.Parcel.obtain();
android.os.Parcel _reply = android.os.Parcel.obtain();
try {
_data.writeInterfaceToken(DESCRIPTOR);
if ((book != null)) {
_data.writeInt(1);
book.writeToParcel(_data, 0);
} else {
_data.writeInt(0);
}
mRemote.transact(Stub.TRANSACTION_addBook, _data, _reply, 0);
_reply.readException();
} finally {
_reply.recycle();
_data.recycle();
}
}
}
//接口的標識
static final int TRANSACTION_getBookList = (android.os.IBinder.FIRST_CALL_TRANSACTION + 0);
static final int TRANSACTION_addBook = (android.os.IBinder.FIRST_CALL_TRANSACTION + 1);
}
//提供的接口
public java.util.List<com.xxq2dream.aidl.Book> getBookList() throws android.os.RemoteException;
public void addBook(com.xxq2dream.aidl.Book book) throws android.os.RemoteException;
}
複製代碼
動手編寫Binder類
- 從上面的分析能夠看出Binder類主要能夠分爲2個部分，一個是Stub類，也就是真正的Binder類；另外一個就是AIDL接口
抽取出AIDL接口
public interface IBookManager extends IInterface {
static final String DESCRIPTOR = "com.xxq2dream.manualbinder.IBookManager";
static final int TRANSACTION_getBookList = IBinder.FIRST_CALL_TRANSACTION + 0;
static final int TRANSACTION_addBook = IBinder.FIRST_CALL_TRANSACTION + 1;
<!--註釋1-->
<!--static final int TRANSACTION_registerListener= IBinder.FIRST_CALL_TRANSACTION + 2;-->
<!--static final int TRANSACTION_unRegisterListener= IBinder.FIRST_CALL_TRANSACTION + 3;-->
public List<Book> getBookList() throws RemoteException;
public void addBook(Book book) throws RemoteException;
<!--註釋2-->
<!--void registerListener(IOnNewBookArrivedListener listener) throws RemoteException;-->
<!--void unRegisterListener(IOnNewBookArrivedListener listener) throws RemoteException;-->
}
複製代碼
實現Stub類和Stub類的代理類
- 這個和上面自動生成的代碼大部分都是同樣的
public class BookManagerImpl extends Binder implements IBookManager {
private static final String TAG = "BookManagerImpl";
public BookManagerImpl() {
Log.e(TAG, "attachInterface-->"+ System.currentTimeMillis());
this.attachInterface(this,DESCRIPTOR);
}
/**
* Cast an IBinder object into an com.xxq2dream.IBookManager interface,
* generating a proxy if needed.
*/
public static IBookManager asInterface(IBinder obj) {
if ((obj == null)) {
return null;
}
android.os.IInterface iin = obj.queryLocalInterface(DESCRIPTOR);
if (((iin != null) && (iin instanceof IBookManager))) {
Log.e(TAG, "asInterface");
return ((IBookManager) iin);
}
Log.e(TAG, "asInterface Proxy-->"+ System.currentTimeMillis());
return new BookManagerImpl.Proxy(obj);
}
/**
* 運行在服務端的Binder線程池中
*
* @param code 要運行的方法標識
* @param data 客戶端傳遞過來的參數
* @param reply 回傳給客戶端的數據
* @param flags
* @return true 表示執行成功；false，執行失敗，客戶端的請求失敗
* @throws RemoteException
*/
@Override
public boolean onTransact(int code, Parcel data, Parcel reply, int flags) throws RemoteException {
Log.e(TAG, "onTransact-->"+System.currentTimeMillis());
switch (code) {
case INTERFACE_TRANSACTION: {
Log.e(TAG, "INTERFACE_TRANSACTION-->"+ System.currentTimeMillis());
reply.writeString(DESCRIPTOR);
return true;
}
case TRANSACTION_getBookList: {
Log.e(TAG, "TRANSACTION_getBookList-->"+ System.currentTimeMillis());
data.enforceInterface(DESCRIPTOR);
List<Book> result = this.getBookList();
reply.writeNoException();
reply.writeTypedList(result);
return true;
}
case TRANSACTION_addBook: {
Log.e(TAG, "TRANSACTION_addBook-->"+ System.currentTimeMillis());
data.enforceInterface(DESCRIPTOR);
Book arg0;
if (0 != data.readInt()) {
arg0 = Book.CREATOR.createFromParcel(data);
}else {
arg0 = null;
}
this.addBook(arg0);
reply.writeNoException();
return true;
}
<!--註釋6-->
<!--case TRANSACTION_registerListener: {-->
<!-- Log.e(TAG, "TRANSACTION_registerListener-->" +System.currentTimeMillis());-->
<!-- data.enforceInterface(DESCRIPTOR);-->
<!-- IOnNewBookArrivedListener arg0;-->
<!-- arg0 = OnNewBookArrivedListenerImpl.asInterface(data.readStrongBinder());-->
<!-- this.registerListener(arg0);-->
<!-- reply.writeNoException();-->
<!-- return true;-->
<!--}-->
<!--case TRANSACTION_unRegisterListener: {-->
<!-- Log.e(TAG, "TRANSACTION_unRegisterListener-->" +System.currentTimeMillis());-->
<!-- data.enforceInterface(DESCRIPTOR);-->
<!-- IOnNewBookArrivedListener arg0;-->
<!-- arg0 = OnNewBookArrivedListenerImpl.asInterface(data.readStrongBinder());-->
<!-- this.unRegisterListener(arg0);-->
<!-- reply.writeNoException();-->
<!-- return true;-->
<!--}-->
}
return super.onTransact(code, data, reply, flags);
}
@Override
public List<Book> getBookList() throws RemoteException {
return null;
}
@Override
public void addBook(Book book) throws RemoteException {
}
<!--註釋5-->
<!--@Override-->
<!--public void registerListener(IOnNewBookArrivedListener listener) {-->
<!--}-->
<!--@Override-->
<!--public void unRegisterListener(IOnNewBookArrivedListener listener) {-->
<!--}-->
/**
* Retrieve the Binder object associated with this interface.
* You must use this instead of a plain cast, so that proxy objects
* can return the correct result.
*/
@Override
public IBinder asBinder() {
Log.e(TAG, "asBinder-->"+ System.currentTimeMillis());
return this;
}
private static class Proxy implements IBookManager {
private IBinder mRemote;
Proxy(IBinder remote) {
mRemote = remote;
}
public String getInterfaceDescriptor() {
return DESCRIPTOR;
}
/**
* 運行在客戶端的Binder線程池中
*
* @return
* @throws RemoteException
*/
@Override
public List<Book> getBookList() throws RemoteException {
Log.e(TAG, "Proxy-->getBookList-->"+ System.currentTimeMillis());
//用於向服務端傳遞參數
Parcel data = Parcel.obtain();
//用於接收服務端傳回來的結果
Parcel reply = Parcel.obtain();
List<Book> result;
try {
data.writeInterfaceToken(DESCRIPTOR);
//發起遠程過程調用請求，同時當前線程掛起，服務端的onTransact方法會被調用
mRemote.transact(TRANSACTION_getBookList, data, reply, 0);
//上述調用過程返回後，當前線程繼續執行，從reply中取出結果返回
reply.readException();
result = reply.createTypedArrayList(Book.CREATOR);
} finally {
reply.recycle();
data.recycle();
}
return result;
}
@Override
public void addBook(Book book) throws RemoteException {
Log.e(TAG, "Proxy-->addBook-->"+ System.currentTimeMillis());
//用於向服務端傳遞參數
Parcel data = Parcel.obtain();
//用於接收服務端傳回來的結果
Parcel reply = Parcel.obtain();
try {
data.writeInterfaceToken(DESCRIPTOR);
if (book != null) {
data.writeInt(1);
book.writeToParcel(data,0);
}else {
data.writeInt(0);
}
mRemote.transact(TRANSACTION_addBook, data, reply, 0);
reply.readException();
}finally {
reply.recycle();
data.recycle();
}
}
<!--註釋3-->
<!--@Override-->
<!--public void registerListener(IOnNewBookArrivedListener listener) throws RemoteException{-->
<!-- Log.e(TAG, "Proxy-->registerListener-->"+ System.currentTimeMillis());-->
<!-- //用於向服務端傳遞參數-->
<!-- Parcel data = Parcel.obtain();-->
<!-- //用於接收服務端傳回來的結果-->
<!-- Parcel reply = Parcel.obtain();-->
<!-- try {-->
<!-- data.writeInterfaceToken(DESCRIPTOR);-->
<!-- data.writeStrongBinder((listener != null)?(listener.asBinder()) : (null));-->
<!-- mRemote.transact(TRANSACTION_registerListener, data, reply, 0);-->
<!-- reply.readException();-->
<!-- }finally {-->
<!-- reply.recycle();-->
<!-- data.recycle();-->
<!-- }-->
<!--}-->
<!--註釋4-->
<!--@Override-->
<!--public void unRegisterListener(IOnNewBookArrivedListener listener) throws RemoteException{-->
<!-- Log.e(TAG, "Proxy-->unRegisterListener-->"+ System.currentTimeMillis());-->
<!-- //用於向服務端傳遞參數-->
<!-- Parcel data = Parcel.obtain();-->
<!-- //用於接收服務端傳回來的結果-->
<!-- Parcel reply = Parcel.obtain();-->
<!-- try {-->
<!-- data.writeInterfaceToken(DESCRIPTOR);-->
<!-- data.writeStrongBinder((listener != null)?(listener.asBinder()) : (null));-->
<!-- mRemote.transact(TRANSACTION_unRegisterListener, data, reply, 0);-->
<!-- reply.readException();-->
<!-- }finally {-->
<!-- reply.recycle();-->
<!-- data.recycle();-->
<!-- }-->
<!--}-->
/**
* Retrieve the Binder object associated with this interface.
* You must use this instead of a plain cast, so that proxy objects
* can return the correct result.
*/
@Override
public IBinder asBinder() {
Log.e(TAG, "Proxy-->asBinder-->"+ System.currentTimeMillis());
return mRemote;
}
}
}
複製代碼
- 以上就是咱們本身動手寫的Binder類，沒有使用系統的方法，也不用編寫AIDL文件
擴展咱們的Binder類
- 好比咱們要實現當服務端有新書時就通知客戶端，也就是觀察者模式。咱們須要在客戶端綁定服務端後綁定監聽的接口，還要提供解綁的接口，上面的代碼中標記的註釋1-6就是擴展Binder類的步驟
- 固然，因爲AIDL中不支持普通的接口，只支持AIDL接口，咱們要增長服務端的AIDL接口服務，像上面的代碼裏那樣傳遞的接口確定就是AIDL實現的接口，也就是
- 因此咱們還得增長AIDL接口，一樣的咱們能夠經過編寫AIDL文件而後由系統自動生成，也能夠手動編寫。這裏咱們仍是以手動的方式編寫
- AIDL接口IOnNewBookArrivedListener
public interface IOnNewBookArrivedListener extends IInterface {
static final String DESCRIPTOR = "com.xxq2dream.aidl.IOnNewBookArrivedListener";
static final int TRANSACTION_onNewBookArrived = IBinder.FIRST_CALL_TRANSACTION + 0;
void onNewBookArrived(Book book) throws RemoteException;
}
複製代碼
- 對應的Binder類
public class OnNewBookArrivedListenerImpl extends Binder implements IOnNewBookArrivedListener {
private static final String TAG = "NewBookArrivedListener";
public OnNewBookArrivedListenerImpl() {
Log.e(TAG, "attachInterface-->"+ System.currentTimeMillis());
this.attachInterface(this,DESCRIPTOR);
}
public static IOnNewBookArrivedListener asInterface (IBinder obj) {
if ((obj == null)) {
return null;
}
android.os.IInterface iin = obj.queryLocalInterface(DESCRIPTOR);
if (((iin != null) && (iin instanceof IOnNewBookArrivedListener))) {
Log.e(TAG, "asInterface");
return ((IOnNewBookArrivedListener) iin);
}
Log.e(TAG, "asInterface Proxy-->"+ System.currentTimeMillis());
return new OnNewBookArrivedListenerImpl.Proxy(obj);
}
/**
* 運行在服務端的Binder線程池中
*
* @param code 要運行的方法標識
* @param data 客戶端傳遞過來的參數
* @param reply 回傳給客戶端的數據
* @param flags
* @return true 表示執行成功；false，執行失敗，客戶端的請求失敗
* @throws RemoteException
*/
@Override
public boolean onTransact(int code, Parcel data, Parcel reply, int flags) throws RemoteException {
Log.e(TAG, "onTransact-->"+System.currentTimeMillis());
switch (code) {
case INTERFACE_TRANSACTION: {
Log.e(TAG, "INTERFACE_TRANSACTION-->"+ System.currentTimeMillis());
reply.writeString(DESCRIPTOR);
return true;
}
case TRANSACTION_onNewBookArrived: {
Log.e(TAG, "TRANSACTION_onNewBookArrived-->"+ System.currentTimeMillis());
data.enforceInterface(DESCRIPTOR);
Book _arg0;
if ((0 != data.readInt())) {
_arg0 = Book.CREATOR.createFromParcel(data);
} else {
_arg0 = null;
}
this.onNewBookArrived(_arg0);
reply.writeNoException();
return true;
}
}
return super.onTransact(code, data, reply, flags);
}
@Override
public void onNewBookArrived(Book book) {
}
/**
* Retrieve the Binder object associated with this interface.
* You must use this instead of a plain cast, so that proxy objects
* can return the correct result.
*/
@Override
public IBinder asBinder() {
return this;
}
private static class Proxy implements IOnNewBookArrivedListener {
private IBinder mRemote;
Proxy(IBinder remote) {
mRemote = remote;
}
public String getInterfaceDescriptor() {
return DESCRIPTOR;
}
/**
* Retrieve the Binder object associated with this interface.
* You must use this instead of a plain cast, so that proxy objects
* can return the correct result.
*/
@Override
public IBinder asBinder() {
Log.e(TAG, "Proxy-->asBinder-->"+ System.currentTimeMillis());
return mRemote;
}
@Override
public void onNewBookArrived(Book newBook) throws RemoteException{
Log.e(TAG, "onNewBookArrived-->" + System.currentTimeMillis());
android.os.Parcel _data = android.os.Parcel.obtain();
android.os.Parcel _reply = android.os.Parcel.obtain();
try {
_data.writeInterfaceToken(DESCRIPTOR);
if ((newBook != null)) {
_data.writeInt(1);
newBook.writeToParcel(_data, 0);
} else {
_data.writeInt(0);
}
mRemote.transact(TRANSACTION_onNewBookArrived, _data, _reply, 0);
_reply.readException();
} finally {
_reply.recycle();
_data.recycle();
}
}
}
}
複製代碼
Binder傳遞AIDL接口
- 經過上面的代碼咱們能夠看到，和傳遞普通的Parcelable序列化對象不一樣的是，在Proxy類中要經過writeStrongBinder方法將AIDL接口加入到參數中去
- 在服務端的onTransact方法中要經過對應的Binder類的asInterface方法得到傳遞過來的接口參數
IOnNewBookArrivedListener arg0;
arg0 = OnNewBookArrivedListenerImpl.asInterface(data.readStrongBinder());
複製代碼
結語
- 經過手動編寫Binder類，可讓咱們更好地理解Binder的工做機制
- 擴展了Binder類之後，下一步咱們還須要相應的改造客戶端和服務端，以便增長註冊監聽的功能
歡迎關注個人微信公衆號，和我一塊兒學習一塊兒成長！
複製代碼
相關文章
- 1. Android多進程之Binder的使用
- 2. Android多進程之Binder解綁監聽的問題
- 3. 動手編寫VBA程序
- 4. Python編程之----多進程
- 5. Android Binder線程
- 6. Android Binder之基本類介紹
- 7. unix編程之多進程編程
- 8. Android進階知識樹——Android 多進程、Binder 你必須知道的一切
- 9. Android Binder入門指南之Binder相關的接口和類
- 10. 使用 acl::master_proc 類編寫多進程服務器程序
- 更多相關文章...
- • C# 多線程 - C#教程
- • Rust 併發編程 - RUST 教程
- • Kotlin學習（二）基本類型
- • 爲了進字節跳動，我精選了29道Java經典算法題，帶詳細講解
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
歡迎關注本站公眾號,獲取更多信息
