Binder系列之AIDL的使用

AIDL是Android进程IPC定义语言的缩写，主要是用来定义进程间通信的接口。本文使用一个Demo程序来说明AIDL的使用，demo工程的分2个module:

App "客户端"，发送网络请求到server端，并且在接收到来自于server的数据后展示结果到UI。
Server "服务端"负责执行耗时的网络请求。

以上2个module运行于2个独立的进程当中，进程间的通信依靠aidl接口。

Server

首先，所有的aidl接口都由server端定义，目录结构如下：

server的文件结构

我们服务进程需要提供一个访问入口给客户进程，所以首先定义了IPostInterface.aidl，内容如下：

Paste_Image.png

post方法接受一个Request请求，setResponseInterface接受一个访问客户进程的接口，该接口是用于上报网络任务的结果给客户进程的。
因为使用了自定义类Request，所以我们需要创建一个aidl文件，用于声明Request，如下 aidl文件名要和Request相同:

Paste_Image.png

接下来，还需要实现Request，Request必须实现Parcelable接口，如下:

package www.seven.com.server;

import android.os.Parcel;
import android.os.Parcelable;

/**
 * @author Seven in 2017-01-07
 */

public class Request implements Parcelable {

    public void setRequestId(int requestId) {
        this.mRequestId = requestId;
    }

    public void setUrl(String url) {
        this.mUrl = url;
    }

    public int getRequestId() {
        return mRequestId;
    }

    public String getUrl() {
        return mUrl;
    }

    // 请求的唯一id
    private int mRequestId;

    // 请求的url
    private String mUrl;

    protected Request(Parcel in) {
        mUrl = in.readString();
        mRequestId = in.readInt();
    }

    public Request(int reqId, String url) {
        mRequestId = reqId;
        mUrl = url;
    }

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

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

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

    @Override
    public void writeToParcel(Parcel parcel, int i) {
        parcel.writeString(mUrl);
        parcel.writeInt(mRequestId);
    }
}

上面的实现过程，都是模板代码来的，值得注意的地方是从Parcel里面读取数据的顺序，也和写入数据的顺序一致。

setResponseInterface需要提交一个aidl接口给服务进程，好让服务进程能够及时反馈网络请求的结果，改aidl接口定义如下:

Paste_Image.png

该接口接受成功和失败的消息，当网络任务执行成功时，需要返回一个Response实例给客户进程，类似Request，我们也需要定义Response的aidl声明：

// Response.aidl
package www.seven.com.server;

parcelable Response;

同样，我们也需要实现Response类：

package www.seven.com.server;

import android.os.Parcel;
import android.os.Parcelable;

/**
 * @author Seven in 2017-01-07
 */

public class Response implements Parcelable {

    // 这个应答对应的请求。
    private Request mRequest;

    private int mStatusCode;

    private String mResponseStr;

    public Request getRequest() {
        return mRequest;
    }

    public int getStatusCode() {
        return mStatusCode;
    }

    public String getResponseStr() {
        return mResponseStr;
    }

    protected Response(Parcel in) {
        mRequest = in.readParcelable(getClass().getClassLoader());
        mStatusCode = in.readInt();
        mResponseStr = in.readString();
    }

    public Response(Request request, int code, String resStr) {
        mRequest = request;
        mStatusCode = code;
        mResponseStr = resStr;
    }

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

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

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

    @Override
    public void writeToParcel(Parcel parcel, int i) {
        parcel.writeParcelable(mRequest, i);
        parcel.writeInt(mStatusCode);
        parcel.writeString(mResponseStr);
    }
}

因为一个Response会保存着一个对应的Request，所以这里需要注意下载Parcelable里面读写另外一个Parcelable的实现方式。

接下来是网络任务的实现，在这里，执行网络请求，可以使用第三方库，也可以使用系统API实现，我现在只是模拟一个耗时任务而已。NetworkTask实现如下，该Task接受一个Request，并将结果提交给Handler。

package www.seven.com.server.services;

import android.os.AsyncTask;
import android.os.Handler;
import android.os.Message;
import android.util.Log;

import java.lang.ref.WeakReference;

import www.seven.com.server.Request;
import www.seven.com.server.Response;

/**
 * @author Seven in 2017-01-07
 */

public class NetworkTask extends AsyncTask<Request, Integer, Response> {

    private WeakReference<Handler> mWeakRef;

    public NetworkTask(Handler receiver) {
        mWeakRef = new WeakReference<Handler>(receiver);
    }

    @Override
    protected Response doInBackground(Request... requests) {
        Log.d("SevenThread", "[NetworkTask] Current Thread " + Thread.currentThread().getId());
        Response response = null;
        if (requests[0].getRequestId() % 3 == 0) {
            // 失败的情况
            postFailure(requests[0].getRequestId(), requests[0].getUrl() + "'s response Fail !!!!");

        } else {
            // 成功的情况
            response = new Response(requests[0], 200, requests[0].getUrl() + "'s response");
        }
        return response;
    }

    @Override
    protected void onPostExecute(Response response) {
        if (response != null) {
            postSuccess(response);
        }
    }

    private void postSuccess(Response response) {
        Handler handler = mWeakRef.get();
        if (handler != null) {
            handler.obtainMessage(NetworkService.RESPONSE_SUCCESS, response).sendToTarget();

        }
    }

    private void postFailure(int reqId, String msg) {
        Handler handler = mWeakRef.get();
        if (handler != null) {
            Message message = handler.obtainMessage(NetworkService.RESPONSE_FIAL);
            message.arg1 = reqId;
            message.obj = msg;
            message.sendToTarget();
        }
    }
}

该Handler来自于NetwokService，NetworkService的实现如下：

package www.seven.com.server.services;

import android.app.Service;
import android.content.Intent;
import android.os.Handler;
import android.os.IBinder;
import android.os.Message;
import android.os.RemoteException;
import android.support.annotation.Nullable;
import android.util.Log;

import java.security.PublicKey;

import www.seven.com.server.IPostInterface;
import www.seven.com.server.IResponseInterface;
import www.seven.com.server.Request;
import www.seven.com.server.Response;

/**
 * @author Seven in 2017-01-07
 */

public class NetworkService extends Service {

    public static final int RESPONSE_SUCCESS = 0;
    public static final int RESPONSE_FIAL    = 1;

    private IResponseInterface mIResponseInterface;

    private NetworkResponseHandler mNetworkResponseHandler = new NetworkResponseHandler();

    private IPostInterface mPostInterface = new IPostInterface.Stub() {

        @Override
        public void setResponseInterface(IResponseInterface responseInterface) throws RemoteException {
            mIResponseInterface = responseInterface;
        }

        @Override
        public boolean post(Request request) throws RemoteException {
            Log.d("SevenThread", "[NetworkService] Current Thread " + Thread.currentThread().getId());
            new NetworkTask(mNetworkResponseHandler).execute(request);
            return true;
        }
    };
    @Nullable
    @Override
    public IBinder onBind(Intent intent) {
        return mPostInterface.asBinder();
    }

    private class NetworkResponseHandler extends Handler {

        @Override
        public void handleMessage(Message msg) {

            switch (msg.what) {
                case RESPONSE_SUCCESS:
                    handleSuccess((Response) msg.obj);
                    break;
                case RESPONSE_FIAL:
                    handleFailure(msg.arg1, (String) msg.obj);
                    break;
            }
        }
    }

    private void handleSuccess(Response response) {
        if (mIResponseInterface != null) {
            try {
                mIResponseInterface.onResponseSuccess(response.getRequest().getRequestId(), response);
            } catch (RemoteException e) {
                e.printStackTrace();
            }
        }
    }

    private void handleFailure(int reqId, String msg) {
        if (mIResponseInterface != null) {
            try {
                mIResponseInterface.onResponseFailure(reqId, msg);
            } catch (RemoteException e) {
                e.printStackTrace();
            }
        }
    }
}

NetworkService的具体工作是：接受一个Request，创建一个NetworkTask，执行完毕后，返回给客户进程。

Client

客户端比较简单，就一个ClientActivity，具体实现如下：

package www.seven.com.aidldemo;

import android.content.ComponentName;
import android.content.Context;
import android.content.Intent;
import android.content.ServiceConnection;
import android.os.IBinder;
import android.os.RemoteException;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.view.View;
import android.widget.TextView;

import www.seven.com.server.IPostInterface;
import www.seven.com.server.IResponseInterface;
import www.seven.com.server.Request;
import www.seven.com.server.Response;
import www.seven.com.server.services.NetworkService;

public class ClientActivity extends AppCompatActivity {

    private static int REQ_CODE = 0;


    private IResponseInterface mIResponseInterface = new IResponseInterface.Stub() {

        @Override
        public void onResponseSuccess(final int requestId, final Response response) throws RemoteException {
            runOnUiThread(new Runnable() {
                @Override
                public void run() {
                    mResponseSb.append("request " + requestId + " " + response.getResponseStr() + "\n");
                    mResponseTv.setText(mResponseSb.toString());
                }
            });
        }

        @Override
        public void onResponseFailure(final int requestId, final String msg) throws RemoteException {
            // aidl回调是在独立的线程执行,所以需要在ui线程更新
            runOnUiThread(new Runnable() {
                @Override
                public void run() {
                    mResponseSb.append("request " + requestId + " " + msg + "\n");
                    mResponseTv.setText(mResponseSb.toString());
                }
            });
        }
    };

    private IPostInterface mIPostInterface;

    private StringBuilder mResponseSb = new StringBuilder();

    private TextView mResponseTv;

    private ServiceConnection mServiceConnection;


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

        mResponseTv = (TextView) findViewById(R.id.response);
    }

    public void onSend(View view) {

        int reqId = REQ_CODE++;
        Request request = new Request(reqId, "request " + reqId);

        mResponseSb.append("request " + reqId + "\n");
        mResponseTv.setText(mResponseSb.toString());

        if (mIPostInterface == null) {
            Intent service = new Intent(this, NetworkService.class);
            mServiceConnection = new ServerConnection(request);
            bindService(service, mServiceConnection, Context.BIND_AUTO_CREATE);
        } else {
            try {
                mIPostInterface.post(request);
            } catch (RemoteException e) {
                e.printStackTrace();
            }
        }
    }

    private class ServerConnection implements ServiceConnection {

        private Request mRequest;

        public ServerConnection(Request request) {
            mRequest = request;
        }

        @Override
        public void onServiceConnected(ComponentName componentName, IBinder iBinder) {
            mIPostInterface = IPostInterface.Stub.asInterface(iBinder);

            try {
                mIPostInterface.setResponseInterface(mIResponseInterface);
            } catch (RemoteException e) {
                e.printStackTrace();
            }
            try {
                mIPostInterface.post(mRequest);
            } catch (RemoteException e) {
                e.printStackTrace();
            }
        }

        @Override
        public void onServiceDisconnected(ComponentName componentName) {
            mIPostInterface = null;
            mServiceConnection = null;
        }
    }

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

需要注意的点是：在第一次发送请求时，会先进行服务绑定；IResponseInterface接收到消息时，需要在将更新view的操作放到ui线程中，因为aidl的回调是在独立非UI线程中的。

最后，需要在manifest文件中声明NetworkService运行在独立的进程中：

<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
    package="www.seven.com.aidldemo">

    <application
        android:allowBackup="true"
        android:icon="@mipmap/ic_launcher"
        android:label="@string/app_name"
        android:supportsRtl="true"
        android:theme="@style/AppTheme">
        <activity android:name="www.seven.com.aidldemo.ClientActivity">
            <intent-filter>
                <action android:name="android.intent.action.MAIN" />

                <category android:name="android.intent.category.LAUNCHER" />
            </intent-filter>
        </activity>

        <service android:name="www.seven.com.server.services.NetworkService"
            android:process=":networking"
            />
    </application>

</manifest>

最后编辑于：2017.12.05 05:50:42

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 204,189评论 6赞 478
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 85,577评论 2赞 381
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 150,857评论 0赞 337
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 54,703评论 1赞 276
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 63,705评论 5赞 366
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 48,620评论 1赞 281
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 37,995评论 3赞 396
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 36,656评论 0赞 258
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 40,898评论 1赞 298
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 35,639评论 2赞 321
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 37,720评论 1赞 330
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 33,395评论 4赞 319
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 38,982评论 3赞 307
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 29,953评论 0赞 19
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 31,195评论 1赞 260
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 44,907评论 2赞 349
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 42,472评论 2赞 342

Binder系列之AIDL的使用

Server

Client

推荐阅读更多精彩内容