IPC之AIDL分析

AIDL用法及代码分析

AIDL为安卓接口定义语言的简称,作用是利用binder机制,实现IPC。

1、AIDL用法

服务端

新建项目,名字定义为server,顾名思义当做服务端,然后创建aidl文件,项目结构如下图:
image.png

看一下两个aidl文件中的内容:

// IWsyAidl.aidl
package com.wsy.service;
import com.wsy.service.Person;

interface IWsyAidl {
    void addPersonIn(in Person person);
    void addPersonInOut(inout Person person);
    void addPersonOut(out Person person);
    List<Person> getPersons();
}

这个aidl文件定义了四个方法,即服务端提供四个方法供客户端调用,概括一下就是客户端可以以三种方式向服务端添加Person对象,也可以获取服务端已经存储的Person的数量
参数说明:

  • in 客户端向服务端传递参数,服务端对参数修改后不会同步到客户端

  • inout 客户端向服务端传递参数,服务端对参数修改后会同步到客户端

  • out 客户端向服务端传递一个所有属性为空的对象(比如Person类中有name属性,即使给Person对象设置了name,传递到服务端的时候name依然为null),服务端对参数修改后会同步到客户端
    具体的现象后面会结合日志说明。

      // Person.aidl
      package com.wsy.service;
      parcelable Person;
    

aidl中需要将自定义对象序列化之后进行数据传输,即上面的关键字parcelable修饰Person

在对应的目录下创建Person类实现Parcelable接口:
image.png
public class Person implements Parcelable {
private String name;

    public Person() {
    }

    public Person(String name) {
        this.name = name;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    protected Person(Parcel in) {
        name = in.readString();
    }

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

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

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

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

    public void readFromParcel(Parcel dest){
        name = dest.readString();
    }
}
build项目,项目会在build目录下自动生成aidl对应的文件:
image.png

IWsyAidl结构如下:


image.png
创建Service类,里面重写onBind方法,返回IWsyAidl.Stub的实例
public class PersonService extends Service {
private String TAG = "aidlServer";
private List<Person> personList = new ArrayList<>();

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

@Override
public void onCreate() {
    super.onCreate();
    Log.e("PersonService", "服务已启动");
}

class PersonStub extends IWsyAidl.Stub{

    @Override
    public void addPersonIn(Person person) throws RemoteException {
        if (person != null) {
            Log.e(TAG, "客户端传来的人的名字:" + person.getName());
            person.setName("服务器改了人的名字 In");
            personList.add(person);
        } else {
            Log.e(TAG, "接收到了一个空对象 In");
        }
    }

    @Override
    public void addPersonInOut(Person person) throws RemoteException {
        if (person != null) {
            Log.e(TAG, "客户端传来的人的名字:" + person.getName());
            person.setName("服务器改了人的名字 InOut");
            personList.add(person);
        } else {
            Log.e(TAG, "接收到了一个空对象 InOut");
        }
    }

    @Override
    public void addPersonOut(Person person) throws RemoteException {
        if (person != null) {
            Log.e(TAG, "客户端传来的人的名字:" + person.getName());
            person.setName("服务器改了人的名字 Out");
            personList.add(person);
        } else {
            Log.e(TAG, "接收到了一个空对象 Out");
        }
    }

    @Override
    public List<Person> getPersons() throws RemoteException {
        return personList;
    }
}

}

在清单文件配置Service
<service
    android:name=".PersonService"
    android:enabled="true"
    android:exported="true">
    <intent-filter>
        <action android:name="com.wsy.service.PersonService" />
        <category android:name="android.intent.category.DEFAULT"/>
    </intent-filter>
</service>
启动服务
public class MainActivity extends AppCompatActivity {

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

        startService(new Intent(this, PersonService.class));
    }
}

客户端

新建项目,名字为client,作为客户端

拷贝server中的aidl目录及Person类到对应目录,这里要保证client端和server端的aidl和Person的目录要完全一致,否则会报类找不到的错误,build项目:

image.png
绑定服务
public class MainActivity extends AppCompatActivity {
    private String TAG = "aidlClient";
    private Button addIn, addInOut, addOut, get;
    private IWsyAidl iWsyAidl;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        bindAidlService();
        addIn = findViewById(R.id.btn_add_in);
        addInOut = findViewById(R.id.btn_add_in_out);
        addOut = findViewById(R.id.btn_add_out);
        get = findViewById(R.id.btn_get);
        addIn.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                try {
                    Person person = new Person("客户端In");
                    iWsyAidl.addPersonIn(person);
                    Log.e(TAG, person.getName());
                } catch (RemoteException e) {
                    e.printStackTrace();
                }
            }
        });
        addInOut.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                try {
                    Person person = new Person("客户端InOut");
                    iWsyAidl.addPersonInOut(person);
                    Log.e(TAG, person.getName());
                } catch (RemoteException e) {
                    e.printStackTrace();
                }
            }
        });
        addOut.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                try {
                    Person person = new Person("客户端out");
                    iWsyAidl.addPersonOut(person);
                    Log.e(TAG, person.getName());
                } catch (RemoteException e) {
                    e.printStackTrace();
                }
            }
        });
        get.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                try {
                    List<Person> persons = iWsyAidl.getPersons();
                    Log.e(TAG, "persons.size = " + persons.size());
                } catch (RemoteException e) {
                    e.printStackTrace();
                }
            }
        });
    }

    ServiceConnection conn = new ServiceConnection() {
        @Override
        public void onServiceConnected(ComponentName name, IBinder service) {
            iWsyAidl = IWsyAidl.Stub.asInterface(service);
            Log.e(TAG, "服务已绑定");
        }

        @Override
        public void onServiceDisconnected(ComponentName name) {

        }
    };

    void bindAidlService() {
        Intent service = new Intent();
        service.setPackage("com.wsy.service");
        service.setAction("com.wsy.service.PersonService");
        bindService(service, conn, Context.BIND_AUTO_CREATE);

    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        unbindService(conn);
    }
}
运行server,启动服务;运行client,绑定服务:
image.png
分别点击添加IN、添加INOUT、添加OUT
image.png

由上图验证了文章开头提到的in/out/inout起到的作用

  1. 为in时,客户端执行new Person("客户端In"),name为“客户端In”;服务端首先打印了客户端传来的名字是“客户端In”,然后执行setName("服务器改了人的名字 In"),返回客户端,客户端打印的名字仍为“客户端In”, 所以说明了in关键字可以让客户端传递完整的对象到服务端,服务端修改后不会同步到客户端;
  2. 为inout时,客户端执行new Person("客户端InOut"),name为“客户端InOut”;服务端首先打印了客户端传来的名字是“客户端InOut”,然后执行setName("服务器改了人的名字 InOut"),返回客户端,客户端打印的名字为“服务器改了人的名字 InOut”,所以说明了inout关键字可以让客户端传递完整的对象到服务端,服务端修改后会同步到客户端;
  3. 为out时,客户端执行new Person("客户端out"),name为“客户端InOut”;服务端首先打印了客户端传来的名字是“null”,然后执行setName("服务器改了人的名字 Out"),返回客户端,客户端打印的名字为“服务器改了人的名字 Out”,所以说明了out关键字可以让客户端传递对象到服务端,但是对象的属性为null,服务端修改后会同步到客户端;

2、AIDL详解

首先还是先看一下根据aidl文件生成的代码的结构:

image.png

用aidl实现线程间通信,生成的代码主要分两方面分析,Stub接收端和Proxy发送端,先看一下类的继承关系:

public static abstract class Stub extends android.os.Binder implements com.wsy.service.IWsyAidl

private static class Proxy implements com.wsy.service.IWsyAidl

由此可见Stub和Proxy都实现了IWsyAidl接口,Stub还继承了Binder抽象类。先分析下Stub中的方法:

Stub():

public Stub() {
    this.attachInterface(this, DESCRIPTOR);
}

Binder:
public void attachInterface(@Nullable IInterface owner, @Nullable String descriptor) {
    mOwner = owner;
    mDescriptor = descriptor;
}

Stub方法调用的其实是父类Binder的attachInterface方法,其实就是用Stub自己及Stub中的DESCRIPTOR做了初始化的操作:

asInterface(IBinder):

public static com.wsy.service.IWsyAidl asInterface(android.os.IBinder obj) {
    if ((obj == null)) {
        return null;
    }
    android.os.IInterface iin = obj.queryLocalInterface(DESCRIPTOR);
    if (((iin != null) && (iin instanceof com.wsy.service.IWsyAidl))) {
        return ((com.wsy.service.IWsyAidl) iin);
    }
    return new com.wsy.service.IWsyAidl.Stub.Proxy(obj);
}

public @Nullable IInterface queryLocalInterface(@NonNull String descriptor) {
    if (mDescriptor != null && mDescriptor.equals(descriptor)) {
        return mOwner;
    }
    return null;
}
  • 在Binder中queryLocalInterface中,mDescriptor就是Stub方法中传入的DESCRIPTOR,符合条件的话返回mOwer,即Stub的实例。
  • asInterface作用就是判断返回一个Stub实例,如果属于同一进城则直接返回Stub,否则返回一个Stub的代理。(因为返回类型是IWsyAidl,而Stub和Proxy都实现了IWsyAidl接口,所以返回Stub和Proxy都没问题)

asBinder(),返回一个Binder对象:

public android.os.IBinder asBinder() {
    return this;
}

onTransact()就是Stub作为接收端的处理方法,先不讲,接下来看Proxy结构,Proxy是Stub的内部类

image.png

Proxy():

Proxy(android.os.IBinder remote) {
    mRemote = remote;
}

构造方法,mRemote保存了一个Binder实例。在Stub的分析中当不属于统一进程时会调用new com.wsy.service.IWsyAidl.Stub.Proxy(obj),所以这里其实存的是服务端Stub的实例;
asBinder(),返回Stub实例:

public android.os.IBinder asBinder() {
    return mRemote;
}

getInterfaceDescriptor(),返回描述符即Stub.DESCRIPTOR:

public java.lang.String getInterfaceDescriptor() {
    return DESCRIPTOR;
}

Proxy实现IWsyAidl接口,所以必须实现接口中的四个方法

image.png

以addPersonIn为例:

public void addPersonIn(com.wsy.service.Person person) 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 ((person != null)) {
            _data.writeInt(1);
            person.writeToParcel(_data, 0);
        } else {
            _data.writeInt(0);
        }
        boolean _status = mRemote.transact(Stub.TRANSACTION_addPersonIn, _data, _reply, 0);
        if (!_status && getDefaultImpl() != null) {
            getDefaultImpl().addPersonIn(person);
            return;
        }
        _reply.readException();
    } finally {
        _reply.recycle();
        _data.recycle();
    }
}

_data和_reply都是通过池获取到的序列化实例,_data其实是客户端发送给服务端的数据,_reply是服务端返回给客户端的数据。_data.writeInterfaceToken(DESCRIPTOR),向要发送的数据中写入描述符,
如果person不为空,执行person.writeToParcel(_data, 0),即:

public void writeToParcel(Parcel dest, int flags) {
    dest.writeString(name);
}

所以,_data中其实包含两个数据,一个是int类型的1,一个是String类型的name; 然后调用mRemote.transact(Stub.TRANSACTION_addPersonIn, _data, _reply, 0);上面提到了,mRemote其实就是服务端的Stub实例,所以这里从客户端回到了服务端,transact是IBinder接口中的方法,所以看下Binder类:

public final boolean transact(int code, @NonNull Parcel data, @Nullable Parcel reply,
        int flags) throws RemoteException {
    if (false) Log.v("Binder", "Transact: " + code + " to " + this);

    if (data != null) {
        data.setDataPosition(0);
    }
    boolean r = onTransact(code, data, reply, flags);
    if (reply != null) {
        reply.setDataPosition(0);
    }
    return r;
}

里面找到了,onTransact方法,上面提到过Stub继承了Binder类,所以回到Stub中:

public boolean onTransact(int code, android.os.Parcel data, android.os.Parcel reply, int flags) throws android.os.RemoteException {
        java.lang.String descriptor = DESCRIPTOR;
        switch (code) {
            case INTERFACE_TRANSACTION: {
                reply.writeString(descriptor);
                return true;
            }
            case TRANSACTION_addPersonIn: {
                data.enforceInterface(descriptor);
                com.wsy.service.Person _arg0;
                if ((0 != data.readInt())) {
                    _arg0 = com.wsy.service.Person.CREATOR.createFromParcel(data);
                } else {
                    _arg0 = null;
                }
                this.addPersonIn(_arg0);
                reply.writeNoException();
                return true;
            }
            case TRANSACTION_addPersonInOut: {
                data.enforceInterface(descriptor);
                com.wsy.service.Person _arg0;
                if ((0 != data.readInt())) {
                    _arg0 = com.wsy.service.Person.CREATOR.createFromParcel(data);
                } else {
                    _arg0 = null;
                }
                this.addPersonInOut(_arg0);
                reply.writeNoException();
                if ((_arg0 != null)) {
                    reply.writeInt(1);
                    _arg0.writeToParcel(reply, android.os.Parcelable.PARCELABLE_WRITE_RETURN_VALUE);
                } else {
                    reply.writeInt(0);
                }
                return true;
            }
            case TRANSACTION_addPersonOut: {
                data.enforceInterface(descriptor);
                com.wsy.service.Person _arg0;
                _arg0 = new com.wsy.service.Person();
                this.addPersonOut(_arg0);
                reply.writeNoException();
                if ((_arg0 != null)) {
                    reply.writeInt(1);
                    _arg0.writeToParcel(reply, android.os.Parcelable.PARCELABLE_WRITE_RETURN_VALUE);
                } else {
                    reply.writeInt(0);
                }
                return true;
            }
            case TRANSACTION_getPersons: {
                data.enforceInterface(descriptor);
                java.util.List<com.wsy.service.Person> _result = this.getPersons();
                reply.writeNoException();
                reply.writeTypedList(_result);
                return true;
            }
            default: {
                return super.onTransact(code, data, reply, flags);
            }
        }
    }

code即为客户调用mRemote.transact(Stub.TRANSACTION_addPersonIn, _data, _reply, 0)对应的参数Stub.TRANSACTION_addPersonIn,

static final int TRANSACTION_addPersonIn = (android.os.IBinder.FIRST_CALL_TRANSACTION + 0);
static final int TRANSACTION_addPersonInOut = (android.os.IBinder.FIRST_CALL_TRANSACTION + 1);
static final int TRANSACTION_addPersonOut = (android.os.IBinder.FIRST_CALL_TRANSACTION + 2);
static final int TRANSACTION_getPersons = (android.os.IBinder.FIRST_CALL_TRANSACTION + 3);

这些值其实就是1、2、3、4,这里是个小技巧,因为服务端可客户端的代码完全一致,所以用数字代表定义的方法,这样相对于通过方法名找到对应的方法更高效。
code的作用就是为了让到服务端要执行哪个方法,这里以addPersonIn为例,所以看这里:

case TRANSACTION_addPersonIn: {
    data.enforceInterface(descriptor);
    com.wsy.service.Person _arg0;
    if ((0 != data.readInt())) {
        _arg0 = com.wsy.service.Person.CREATOR.createFromParcel(data);
    } else {
        _arg0 = null;
    }
    this.addPersonIn(_arg0);
    reply.writeNoException();
    return true;
}

data是客户端传来的序列化对象,在Proxy的分析中,如果person不为空,data中包含int类型的1和String类型的name。所以这里会走_arg0 = com.wsy.service.Person.CREATOR.createFromParcel(data),即

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

    @Override
    public Person[] newArray(int size) {
        return new Person[size];
    }
};
    
protected Person(Parcel in) {
    name = in.readString();
}

这里其实是创建了一个新的Person对象,然后用客户端传来的数据给Person的属性赋了值,然后调用this.addPersonIn(_arg0)即Stub的实现类的addPersonIn方法,上面在server中的PersonService类中定义了Stub的实现类:

image.png

reply是返回给客户端的对象,因为addPersonIn没有返回值,所以返回客户端直接reply.writeNoException()就可以了。如果客户端需要返回值,如getPersons方法,则

reply.writeNoException(); 
reply.writeTypedList(_result);

当客户端调用服务端借口时,客户端的进城处于挂起状态,会一直等待服务端处理数据后返回。

至于客户端是怎么获取到的服务端的Stub对象,如何绑定成功的可以参考bindService源码解析

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 214,658评论 6 496
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,482评论 3 389
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 160,213评论 0 350
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,395评论 1 288
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,487评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,523评论 1 293
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,525评论 3 414
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,300评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,753评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,048评论 2 330
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,223评论 1 343
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,905评论 5 338
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,541评论 3 322
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,168评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,417评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,094评论 2 365
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,088评论 2 352