【Android源碼】Binder機制和AIDL分析

一般狀況下,若是兩個對象可以直接相互訪問,那麼這兩個對象存在於同一個內存空間中。 若是兩個對象分別存在於兩個不一樣的進程的時候,那麼這兩個對象是不能相互訪問的,這個時候就須要使用跨進程通訊的技術了。 而Android是基於Linux系統的,Linux傳統的跨進程技術主要是Socket,信號量,管道,消息隊列等,可是這些技術都有不一樣的缺點,如Socket開銷大效率不高,管道和消息隊列拷貝次數多,而對於Android系統來說,更重要的是安全性要高,而這些技術安全性都不是很高,大部分狀況下接收方並不能獲得發送發進程的PID/UID,很難識別身份。 因此Android系統就設計出了Binder跨進程通訊機制,來保證傳輸性能和安全性。java

Binder

Binder主要模塊

Binder主要模塊

  1. BinderDriverandroid

    存在於內核空間中,以字符設備的misc類型註冊,用戶能夠從/dev/binder設備文件節點上,經過open和ioctl文件操做函數與BinderDriver進行通訊,主要是負責Binder通訊的創建,進程間的傳遞、Binder引用計數管理/數據包的管理。git

  2. BinderClientgithub

    存在於用戶空間中,它和BinderServer的跨進程通訊都是經過BinderDriver來處理轉發的。 對於BinderClient只須要知道本身須要使用的Binder的名字和該Binder在ServerManager中的0號引用就能夠了。經過0號引用去訪問ServerManager獲取Binder的引用,獲得引用後就能夠直接調用Binder的方法了。安全

  3. ServerManagerbash

    存在於用戶空間中,用來管理BinderServer,BinderClient能夠經過它來查詢BinderServer接口,查詢到以後就能夠獲取到Binder的映射。服務器

  4. BinderServer併發

    BinderServer會生成一個Binder實體,並會給Binder綁定一個名字,最終封裝成一個數據包傳遞給BinderDriver,BinderDriver在獲取到這個數據包以後,若是發現這個數據包是新傳遞過來的,就會給其在內核空間中建立相應的Binder實體節點和對應的實體節點的引用。 BinderDriver會將Binder的引用傳遞給ServerManager,ServerManager收到後就會取出Binder的名字和引用插入一張數據表中,這個就和DNS存儲域名到IP的映射原理同樣。ide

系統如何使用Binder

在客戶端中ServerManager的接口定義主要是在IServiceManager中:函數

public interface IServiceManager extends IInterface
{
    /**
     * Retrieve an existing service called @a name from the
     * service manager.  Blocks for a few seconds waiting for it to be
     * published if it does not already exist.
     */
    public IBinder getService(String name) throws RemoteException;
    
    /**
     * Retrieve an existing service called @a name from the
     * service manager.  Non-blocking.
     */
    public IBinder checkService(String name) throws RemoteException;

    /**
     * Place a new @a service called @a name into the service
     * manager.
     */
    public void addService(String name, IBinder service, boolean allowIsolated)
                throws RemoteException;

    /**
     * Return a list of all currently running services.
     */
    public String[] listServices() throws RemoteException;

    /**
     * Assign a permission controller to the service manager.  After set, this
     * interface is checked before any services are added.
     */
    public void setPermissionController(IPermissionController controller)
            throws RemoteException;
    
    static final String descriptor = "android.os.IServiceManager";

    int GET_SERVICE_TRANSACTION = IBinder.FIRST_CALL_TRANSACTION;
    int CHECK_SERVICE_TRANSACTION = IBinder.FIRST_CALL_TRANSACTION+1;
    int ADD_SERVICE_TRANSACTION = IBinder.FIRST_CALL_TRANSACTION+2;
    int LIST_SERVICES_TRANSACTION = IBinder.FIRST_CALL_TRANSACTION+3;
    int CHECK_SERVICES_TRANSACTION = IBinder.FIRST_CALL_TRANSACTION+4;
    int SET_PERMISSION_CONTROLLER_TRANSACTION = IBinder.FIRST_CALL_TRANSACTION+5;
}
複製代碼

能夠看到IServiceManager定義的方法主要是添加,獲取,檢查等關於各類服務。主要做用其實就是像上面所說的簡單的將Binder以字符表示的名字轉換成引用。而對於BinderClient的實現其實就是ServiceManagerNative和ServiceManagerProxy,這兩個類實現了該接口,咱們在AIDL的時候在分析。

AIDL

咱們以具體的例子來分析,首先咱們建立相關aidl文件:

// Book.java
public class Book implements Parcelable {
    public int bookId;
    public String bookName;

    protected Book(Parcel in) {
        bookId = in.readInt();
        bookName = in.readString();
    }

    @Override
    public void writeToParcel(Parcel dest, int flags) {
        dest.writeInt(bookId);
        dest.writeString(bookName);
    }

    @Override
    public int describeContents() {
        return 0;
    }

    public static final Creator<Book> CREATOR = new Creator<Book>() {
        @Override
        public Book createFromParcel(Parcel in) {
            return new Book(in);
        }

        @Override
        public Book[] newArray(int size) {
            return new Book[size];
        }
    };
}

// Book.aidl
package com.fastaoe.proficient;
parcelable Book;

// IBookManager.aidl
package com.fastaoe.proficient;

import com.fastaoe.proficient.Book;

interface IBookManager {
    List<Book> getBookList();
    void addBook(in Book book);
}
複製代碼

上面3個文件,Book.java表示圖書信息,實現了Parcelable接口。 Book.aidl是Book.java在AIDL中的聲明。 IBookManager是定義了用來操做Book的方法,getBookList從服務器中獲取圖書列表,addBook向服務器圖書列表中插入一本新書。 當咱們聲明好了AIDL以後,IDE編譯好以後,就生成了IBookManager.java這個類。

public interface IBookManager extends android.os.IInterface {
    // 代碼省略,下面在分析
}
複製代碼

能夠看到這個系統爲咱們生成的類,實現了IInterface這個接口,本身自己也是一個接口,咱們能夠實現這個接口來實現相關的方法。咱們來具體分析下這個生成的接口:

private static final java.lang.String DESCRIPTOR = "com.fastaoe.proficient.IBookManager";
複製代碼

Binder的惟一標識,通常狀況下使用當前的類來表示。

public static com.fastaoe.proficient.IBookManager asInterface(android.os.IBinder obj) {
            if ((obj == null)) {
                return null;
            }
            android.os.IInterface iin = obj.queryLocalInterface(DESCRIPTOR);
            if (((iin != null) && (iin instanceof com.fastaoe.proficient.IBookManager))) {
                return ((com.fastaoe.proficient.IBookManager) iin);
            }
            return new com.fastaoe.proficient.IBookManager.Stub.Proxy(obj);
        }
複製代碼

用來將服務器中的Binder對象轉換成客戶端中所須要的AIDL接口類型的對象。能夠看到當客戶端和服務端在同一個進程的時候,返回的就是服務端的Stub自己,若是不在同一個進程,返回的是系統封裝好的Stub.proxy對象,這表示當不在同一個進程的時候,客戶端拿到的其實不是服務端Binder自己,而是一個副本。

public android.os.IBinder asBinder() {
            return this;
        }
複製代碼

返回Binder對象自己。

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.fastaoe.proficient.Book> _result = this.getBookList();
               reply.writeNoException();
               reply.writeTypedList(_result);
               return true;
           }
           case TRANSACTION_addBook: {
               data.enforceInterface(DESCRIPTOR);
               com.fastaoe.proficient.Book _arg0;
               if ((0 != data.readInt())) {
                   _arg0 = com.fastaoe.proficient.Book.CREATOR.createFromParcel(data);
               } else {
                   _arg0 = null;
               }
               this.addBook(_arg0);
               reply.writeNoException();
               return true;
           }
       }
       return super.onTransact(code, data, reply, flags);
   }
複製代碼

這個方法運行在服務器端的Binder線程池中,當客戶端發起跨進程的請求的時候,請求會經過底層封裝以後交給此方法執行。服務器端經過code來判斷客戶端請求的方法是什麼,接着從data中獲取目標方法所須要的數據,並執行目標方法。當方法執行完以後經過reply寫入返回值,最後返回是否成功,若是成功返回true,不然則是false失敗。

private static class Proxy implements com.fastaoe.proficient.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;
       }

       @Override
       public java.util.List<com.fastaoe.proficient.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.fastaoe.proficient.Book> _result;
           try {
               _data.writeInterfaceToken(DESCRIPTOR);
               mRemote.transact(Stub.TRANSACTION_getBookList, _data, _reply, 0);
               _reply.readException();
               _result = _reply.createTypedArrayList(com.fastaoe.proficient.Book.CREATOR);
           } finally {
               _reply.recycle();
               _data.recycle();
           }
           return _result;
       }

       @Override
       public void addBook(com.fastaoe.proficient.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();
           }
       }
   }
複製代碼

這個類運行在客戶端中,當客戶端調用此方法以後,首先會建立parcel的類型的輸入對象_data,輸出對象_reply,返回值對象_result(若是有的話),接着經過_data將參數存儲起來,在經過transact方法來發送RPC請求,同時線程會被掛起。接着服務端的onTransact方法會調用,最終RPC過程返回後,當前線程繼續執行,從_reply獲取到返回的結果。

經過AIDL實現跨進程通訊(參考《Android開發藝術探索第二章例子》)

咱們把AIDL生成的類分析完以後,就來實現一個服務器和客戶端通訊的例子吧。

首先定義AIDL文件,就是上面圖書的例子

其中須要注意的是:

AIDL支持的數據類型:

  • 基本數據類型
  • String和CharSequence
  • ArrayList和HashMap
  • Parcelable
  • AIDL自己

當咱們自定義了Parcelable的時候,必須新建一個同名的.aidl文件,並將其聲明爲parcelable類型。 AIDL中全部的實現了Parcelabe接口的類都須要聲明相對應的aidl文件,而且須要標識in(輸入)、out(輸出)、inout(輸入輸出)。

服務端的實現

public class ServerService extends Service {
    
   private CopyOnWriteArrayList<Book> list = new CopyOnWriteArrayList<>();
   private RemoteCallbackList<IAddBookListener> listeners = new RemoteCallbackList<>();
    
   @Override
   public void onCreate() {
       super.onCreate();
       list.add(new Book(1, "島上書店"));
       list.add(new Book(2, "白夜行"));
   }
    
   @Nullable
   @Override
   public IBinder onBind(Intent intent) {
       return binder;
   }
    
   private IBinder binder = new IBookManager.Stub(){
    
       @Override
       public List<Book> getListBook() throws RemoteException {
           return list;
       }
    
       @Override
       public void addBook(Book book) throws RemoteException {
           onNewBookAdd(book);
       }
    
       @Override
       public void registerListener(IAddBookListener listener) throws RemoteException {
           listeners.register(listener);
       }
    
       @Override
       public void unregisterListener(IAddBookListener listener) throws RemoteException {
           listeners.unregister(listener);
       }
   };
    
   private void onNewBookAdd(Book book) throws RemoteException {
       list.add(book);
       int N = listeners.beginBroadcast();
       for (int i = 0; i < N; i++) {
           IAddBookListener broadcastItem = listeners.getBroadcastItem(i);
           broadcastItem.OnNewBookAddListener(book);
       }
       listeners.finishBroadcast();
   }
}
複製代碼

在服務端中咱們首先初始化了圖書列表,並建立了Binder對象並在onBind中返回。

  1. 使用了CopyOnWriteArrayList,這個List是支持併發讀寫的,由於當多個客戶端同時鏈接的時候,會出現多個線程同時訪問的問題,因此須要在AIDL中處理線程問題。

  2. 使用RemoteCallbackList來管理跨進程的listener接口,由於若是使用List的話,並不能在unregister的時候刪除掉當前listener接口,雖然咱們使用的看上去是同一個listener,可是其實並非同一個對象。

    客戶端和服務端在多進程的環境中,而對象是不可能在多進程下傳遞的,因此Binder會將客戶端傳遞過來的對象從新轉化成新的對象,並非原來的對象,這實際上是反序列化的過程,因此AIDL中的自定義對象必須實現Parcelable接口。

    那麼怎麼解除註冊呢?

    能夠經過RemoteCallbackList,RemoteCallbackList是系統專門提供用來刪除跨進程listener的接口,在它的內部有一個Map用來保存全部的AIDL回調,key是IBinder,value是callback。雖然在跨進程的環境中,生成的對象不是同一個對象,可是它們底層的Binder確定是同一個,因此能夠利用這個來實現解除註冊。當客戶端要解除註冊的時候,服務端經過RemoteCallbackList找到具備相同Binder對象的服務端listener並將其刪除。

客戶端實現

public class MainActivity extends AppCompatActivity {
    
   private List<Book> list = new ArrayList<>();
    
   private int index = 3;
    
   Handler handler = new Handler(){
       @Override
       public void handleMessage(Message msg) {
           switch (msg.what) {
               case 1:
                   list.add((Book) msg.obj);
                   tv_book.setText(list.toString());
                   break;
    
           }
       }
   };
    
   private ServiceConnection conn = new ServiceConnection() {
       @Override
       public void onServiceConnected(ComponentName name, IBinder service) {
           iBookManager = IBookManager.Stub.asInterface(service);
           try {
               iBookManager.registerListener(listener);
           } catch (RemoteException e) {
               e.printStackTrace();
           }
       }
    
       @Override
       public void onServiceDisconnected(ComponentName name) {
           iBookManager = null;
       }
   };
    
   private IBookManager iBookManager;
   private IAddBookListener listener = new IAddBookListener.Stub() {
       @Override
       public void OnNewBookAddListener(Book book) throws RemoteException {
           handler.obtainMessage(1, book).sendToTarget();
       }
   };
   private Button btn_search;
   private Button btn_add;
   private TextView tv_book;
    
   @Override
   protected void onCreate(Bundle savedInstanceState) {
       super.onCreate(savedInstanceState);
       setContentView(R.layout.activity_main);
    
       btn_search = (Button) findViewById(R.id.btn_search);
       btn_add = (Button) findViewById(R.id.btn_add);
       tv_book = (TextView) findViewById(R.id.tv_book);
    
       btn_search.setOnClickListener(new View.OnClickListener() {
           @Override
           public void onClick(View v) {
               if (iBookManager != null) {
                   try {
                       // TODO: 2017/7/9 放在子線程中 
                       list = iBookManager.getListBook();
                   } catch (RemoteException e) {
                       e.printStackTrace();
                   }
                   tv_book.setText(list.toString());
               }
           }
       });
    
       btn_add.setOnClickListener(new View.OnClickListener() {
           @Override
           public void onClick(View v) {
               if (iBookManager != null) {
                   Book book = new Book(index, "圖書"+ index);
                   index += 1;
                   try {
                       // TODO: 2017/7/9 放在子線程中 
                       iBookManager.addBook(book);
                   } catch (RemoteException e) {
                       e.printStackTrace();
                   }
               }
           }
       });
    
       Intent intent = new Intent();
       intent.setAction("com.fastaoe.server.ServerService");
       intent.setComponent(new ComponentName("com.fastaoe.server", "com.fastaoe.server.ServerService"));
       bindService(intent, conn, Context.BIND_AUTO_CREATE);
   }
    
   @Override
   protected void onDestroy() {
       try {
           iBookManager.unregisterListener(listener);
       } catch (RemoteException e) {
           e.printStackTrace();
       }
       unbindService(conn);
       super.onDestroy();
   }
}
複製代碼

首先綁定遠程服務,接着將遠程服務返回的Binder對象轉換成AIDL接口,接着就能夠調用服務端中的方法了。

  1. 須要注意的是若是aidl中的方法在服務端是耗時的操做的時候,須要處理,否則會致使ANR的產生,一樣的當服務端調用客戶端的耗時操做的時候,也須要保證在服務端的方法運行在非UI線程,由於Service自己是運行在UI線程中的。

  2. OnNewBookAddListener運行在Binder線程池中,因此不能在其中訪問UI相關的內容,若是須要訪問的話,則須要經過Handler切換線程。

  3. Binder在鏈接過程當中是可能意外死亡的,主要是由於服務端的進程被終止了,因此咱們須要從新鏈接服務。

    1. 能夠經過在onServiceDisconnected中重連。
    2. 也能夠經過DeathRecipient來監聽是否被斷開。

具體的Demo能夠查看AIDL的簡單實現

相關文章
相關標籤/搜索