Android中实现IPC的几种方式详细分析及比较

1.使用Bundle   ----> 用于android四大组件间的进程间通信

android的四大组件都可使用Bundle传递数据  所以如果要实现四大组件间的进程间通信 完全可以使用Bundle来实现 简单方便

2.使用文件共享  ---->用于单线程读写

这种方式在单线程读写的时候比较好用 如果有多个线程并发读写的话需要限制线程的同步读写

另外 SharePreference是个特例  它底层基于xml实现  但是系统对它的读写会基于缓存,也就是说再多进程模式下就变得不那么可靠了,有很大几率丢失数据

3.使用Messenger   ---->用于可存放在message中的数据的传递

使用这个方式可以在不同进程间传递message对象  这是一种轻量级的IPC方案  当传递的对象可以放入message中时  可以考虑用这种方式  但是msg.object最好不要放

因为不一定可以序列化

使用它的步骤如下:

假设这样一个需求  需要在客户端A发送消息给服务端B接受  然后服务端B再回复给客户端A

1. 首先是客户端A发送消息给服务端B  所以在客户端A中 声明一个Handler用来接受消息  并创建一个Messenger对象 用Handler作为参数构造  然后onBinder方法返回messenger.getBinder() 即可

public class MyServiceA extends Service {

		private class MessageHandler extends Handler{  //创建的接受消息的handler
			@Override
			public void handleMessage(Message msg) {
				switch (msg.what){
					case 1:
						Bundle bundle = msg.getData();
						String str = bundle.getString("aaa");
						System.out.println("----"+str);
						Messenger replyTo = msg.replyTo; //此处往下是用来回复消息给客户端A的
						Message replyMsg = Message.obtain(null,2);
						Bundle bundle1 = new Bundle();
						bundle1.putString("bbb","remote222给主进程回复消息啦");
						replyMsg.setData(bundle1);
						try {
							replyTo.send(replyMsg);
						} catch (RemoteException e) {
							e.printStackTrace();
						}
						break;
				}
				super.handleMessage(msg);
			}
		}
		Messenger messenger = new Messenger(new MessageHandler());
		public MyServiceA() {
		}

		public IBinder onBind(Intent intent) {
			return messenger.getBinder();
		}
	}

2.在客户端A自然是需要发送消息给服务端B的  所以需要在服务绑定完成之后  获取到binder对象  之后用该对象构造一个Messenger对象  然后用messenger发送

消息给服务端即可  代码如下  :

public void onServiceConnected(ComponentName name, IBinder service) {
                Messenger messenger = new Messenger(service);
                Message msg = Message.obtain(null,1);
                Bundle bundle = new Bundle();
                bundle.putString("aaa", "主进程给remote22进程发消息啦");
                msg.setData(bundle);
                msg.replyTo = mmessenger; //这行代码用于客户端A接收服务端请求 设置的消息接收者
                try {
                    messenger.send(msg);
                } catch (RemoteException e) {
                    e.printStackTrace();
                }

            }

3.由于在服务端接收到了客户端的消息还需要回复  所以在服务端代码中获取 msg中的replyTo对象  用这个对象发送消息给 客户端即可

在客户端需要创建一个handler和Messenger  将发送的msg.replyTo设置成Messenger对象  就可

4.AIDL android 接口定义语言  ---->主要用于调用远程服务的方法的情况 还可以注册接口 

使用方法很简单

在服务端定义aidl文件 自动生成java文件  然后在service中实现这个aidl  在onbind中返回这个对象

在客户端把服务端的aidl文件完全复制过来  包名必须完全一致   在onServiceConnected方法 中 把  Ibinder对象 用asInterface方法转化成 aidl对象

然后调用方法即可

需要注意的地方:

在aidl文件中并不是支持所有类型

仅支持如下6种类型:

基本数据类型---- int long  char  boolean double

String  charSequence

List  只支持ArrayList  CopyOnWriteArrayList也可以。。  里面元素也必须被aidl支持

Map   只支持HashMap   ConCurrentHashMap也可以  里面元素也必须支持aidl

Parcelable  所有实现了此接口的对象

AIDL  所有的AIDL接口   因此 如果需要使用接口 必须使用AIDL接口

其中自定义的类型和AIDL对象必须显示import进来 不管是不是在一个包中

如果AIDL文件中用到了自定义的Parcelable对象  必须创建同名的AIDL文件 并声明为Parcelable类型

AIDL文件中除了基本数据类型外 其他类型必须标上方向  in  out  inout

AIDL接口中只支持方法  不支持声明静态常量

在使用aidl时  最好把所有aidl文件都放在一个包中  这样方便复制到客户端

其实所有的跨进程对象传递都是对象的序列化与反序列化  所以必须包名一致

现在加入有这样一个需求 如果服务端是 图书馆添加和查看书的任务   客户端可以查看和添加书   这时候需要添加一个功能  当服务端每添加了一本书

需要通知客户端注册用户  有一本新书上架了   这个功能如何实现?

想想可知  这是一个观察者模式  如果在同一进程中很容易实现,只需要在服务端中的代码中维护一个集合 里面放的是注册监听的用户  然后用户需要实现一个新书到来的回调接口

当有新书上架时 遍历这个集合  调用每个注册者的接口方法  即可实现

现在我们是跨进程通信   所以自然不能如此简单了  但也不是很复杂 想一想  其实就是把以往的接口定义 变成了aidl接口定义  然后其他的一样即可

但是这样还是存在一个问题  如果注册了listener  我们又想解除注册  是不是在客户端传入listener对象 在服务端把它移除就可以呢?

其实是不可以的   因为这是跨进程的  所以对象并不是真正的传递  只是在另一个进程中重新创建了一个一样的对象  内存地址不同 所以根本不是同一个对象

所以是不可以的   如果要解决这个问题  需要使用RemoteCallbackList 类  不要使用CopyWriteArrayList

在RemoteCallBackList中封装了一个Map 专门用来保存所有的AIDL回调  key为IBinder  value是CallBack   使用IBinder 来区别不同的对象  ,

因为跨进程传输时会产生很多个不同的对象  但这些对象的底层的Binder都是同一个对象  所以可以

在使用RemoteCallBackList时 add 变为 register  remove 变为 unregister  遍历的时候需要先 beginBroadcast  这个方法同时也获取集合大小

获取集合中对象使用 getBoardCastItem(i)  最后不要忘记finishBoardCast方法

还有一个情况  由于onServiceConnected方法 是在主线程执行的  如果在这里执行服务端的耗时代码  会ANR  所以需要开启一个子线程执行

同理在服务端中 也不可以运行客户端的耗时程序

总结起来就是 在执行其他进程的耗时程序时  都需要开启另外的线程防止阻塞UI线程  如果要访问UI相关的东西  使用handler

为了程序的健壮性  有时候Binder可能意外死亡  这时候需要重连服务  有2种方法:

1.在onServiceDisconnected方法中  重连服务

2. 给Binder注册DeathRecipient监听  当binder死亡时 我们可以收到回调  这时候我们可以重连远程服务

最后有时候我们不想所有的程序都可以访问我们的远程服务  所以可以给服务设置权限和过滤:

1.我们在onbind中进行校验 用某种方式 如果验证不通过那么就直接返回null

2.我们可以在服务端的AndroidMiniFest.xml中  设置所需的权限  <permission android:name="aaaaaa" android:protectionLevel="normal"/>

然后在onbind中 检查是否有这个权限了  如果没有那么直接返回null即可  判断方法如下  :

int check = checkCallingOrSelfPermission("aaa");
			if(check== PackageManager.PERMISSION_DENIED){
				return null;
			}

3.可以在onTransact方法中 进行权限验证  如果验证失败直接返回false  可以采用permission方法验证  还可以用Uid和Pid验证  很多方法

其中声明权限与 添加权限的方式 是   在Service所在的AndroidMinifest中 声明权限

比如    <permission android:name="com.yangsheng.ydzd_lb.myaidlpro.book" android:protectionLevel="normal"></permission>

然后在 需要远程调用的 app中添加 这个权限 <uses-permission android:name="com.yangsheng.ydzd_lb.myaidlpro.book"/>

这样 就可以在  onbind中验证权限了

至此 AIDL  大体介绍完了   以后需要在使用中提升了

aidl demo 下载  :  http://download.csdn.net/detail/u012760183/9520173

5.ContentProvider方式  实现对另一个应用进程开放provider数据的查询

此方法使用起来也比较简单  底层是对Binder的封装 使之可以实现进程间通信  使用方法如下

1. 在需要共享数据的应用进程中建立一个ContentProvider类 重写它的CRUD 和getType方法  在这几个方法中调用对本应用进程数据的调用

然后在AndroidMinifest.xml文件中声明provider

 <provider
				android:authorities="com.yangsheng.book"  //这个是用来标识provider的唯一标识  路径uri也是这个
				android:name=".BookProdiver"
				android:process=":remote_provider"/>   //此句为了创建多进程  正常不需要使用

2. 在需要获取共享数据的应用进程中调用getContentResolver().crud方法  即可实现数据的查询

需要注意的问题:

1.关于 sqlite crud的各个参数的意义

query函数 参数

Cursor query(boolean distinct, String table, String[] columns,

String selection, String[] selectionArgs, String groupBy,

String having, String orderBy, String limit)

第一个参数 distinct 英语单词意思 独特的   如果true 那么返回的数据都是唯一的  意思就是实现查询数据的去重

第二个参数 table  表名

第三个参数 columns  要查询的行的名字数组  例如  new String[]{"id","name","sex"}

第四个参数 selection 选择语句  sql语句中where后面的语句  值用?代替  例如  "id=? and sex=?"

第五个参数 selectionArgs  对应第四个参数的 ?  例如  new String[]{"1","男"}

第六个参数 groupBy 用于分组

第七个参数 having  筛选分组后的数据

第八个参数 orderby 用于排序  desc/asc  升序和降序  例如  id desc / id asc

最后一个参数 limit  用于限制查询的数据的个数  默认不限制

其他几个函数 根据query函数的参数猜想即可

2.由于每次ipc操作 都是靠uri来区别 想要获取的数据位置  所以provider在调取数据的时候根据uri并不知道要查询的数据是在哪个位置

所以我们可以通过 UriMatcher 这个类来给每个uri标上号 根据编号 对应适当的位置   例如:

public static final int BOOK_CODE = 0;
			public static final int USER_CODE = 1;
			public static UriMatcher matcher = new UriMatcher(UriMatcher.NO_MATCH);

			static {
				matcher.addURI("book uri", "book", BOOK_CODE);
				matcher.addURI("user uri", "user", USER_CODE);
			}
			这样我们可以通过 下面这个样子来获取位置(此处是表名 其他类型也一样)
			private String getTableName(Uri uri) {
				switch (matcher.match(uri)) {
					case BOOK_CODE:
						return "bookTable";
					case USER_CODE:
						return "userTable";
				}
				return "";
			}

3.另外ContentProvider除了crud四个方法外,还支持自定义调用  通过ContentProvider 和ContentResolver的 call方法  来实现

ContentProviderdemo下载 : http://download.csdn.net/detail/u012760183/9520175

6.Socket方法实现Ipc   这种方式也可以实现 但是不常用  

需要权限

<uses-permission android:name="android.permission.INTERNET" />

<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />

这种方式需要一个服务端socket 和一个客户端socket  建立连接后 通过流循环获取消息即可

1.在服务端开启一个serverSocket 不断获取客户端连接  注意要在子线程中开启

ServerSocket serverSocket = new ServerSocket(8688);
		while(isActive) { //表示服务生存着
                try {
                    final Socket client = serverSocket.accept();  //不断获取客户端连接
                    System.out.println("---服务端已获取客户端连接");
                    new Thread(){
                        @Override
                        public void run() {
                            try {
                                dealWithMessageFromClient(client);  //处理客户端的消息 就是开启一个线程循环获取out 和 in  流 进行通信
                            } catch (IOException e) {
                                e.printStackTrace();
                            }
                        }
                    }.start();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

2.在客户端开启一个线程 使用ip和端口号连接服务端socket  连接成功后 一样 开启子线程 循环获取消息 处理

Socket socket = null;
                while(socket==null){  //失败重连
                    try {
                        socket = new Socket("localhost",8688);
                        out = new PrintWriter(socket.getOutputStream(),true);
                        handler.sendEmptyMessage(1);
                        final Socket finalSocket = socket;
                        new Thread(){
                            @Override
                            public void run() {
                                try {
                                    reader = new BufferedReader(new InputStreamReader(finalSocket.getInputStream()));
                                } catch (IOException e) {
                                    e.printStackTrace();
                                }
                                while(!MainActivity.this.isFinishing()){  //循环获取消息  这里必须用 循环 否则 只能获取一条消息 服务端也一样
                                    try {
                                        String msg = reader.readLine();
                                        System.out.println("---"+msg);
                                        if (msg!=null){
                                            handler.sendMessage(handler.obtainMessage(2,msg));
                                        }
                                    } catch (IOException e) {
                                        e.printStackTrace();
                                    }
                                }
                            }
                        }.start();
                    } catch (IOException e) {
                        SystemClock.sleep(1000);
                        e.printStackTrace();
                    }
                }

7.Binder 连接池的使用  很好用

我们在android中进程间通信 一般都使用 AIDL实现 因为它强大  但是普通的使用方法每次使用AIDL 都需要开启一个服务  如果有多个AIDL请求 那岂不是要开启很多个服务

这明显是不可以的  比如你让你用户的手机 发现你这一个应用程序绑定了10个服务  那是极差的  所以 我们在多个AIDL 请求的时候可以使用Binder连接池技术

只开启一个服务  根据需要获取的AIDL不同 转化成需要的AIDL 接口 执行不同的方法

实现的基本原理  就是在onbind中返回一个BinderPool 接口 这个接口有个方法 可以根据不同的标志位返回不同的aidl接口  这样我们在asInTerface之后调用哪个方法

传入标志位即可返回需要的aidl接口

说起来简单 让我们来实现一个试试吧

1.假设原来有2个AIDL接口需要实现(可以扩展成多个)  在服务端建立好AIDL文件  并且建立一个IBinderPool aidl接口  只有一个查询binder的方法 用于查询需要的binder

interface IBinderPool {

/**

* Demonstrates some basic types that you can use as parameters

* and return values in AIDL.

*/

IBinder queryBinder(int code);  //此方法返回Ibinder  用于转化成需要的AIDL接口

}

2.在服务端 onbind方法中返回 IBinderPool的实现类  实现query方法 按照传入的code 返回需要的ibinder

@Override

public IBinder onBind(Intent intent) {

return iBinderPool;

}

private Binder iBinderPool = new IBinderPool.Stub() {

@Override

public IBinder queryBinder(int code) throws RemoteException {

switch (code) {

case 1:

return new IBookManger.Stub() {

@Override

public void getBook() throws RemoteException {

System.out.println("--->book");

}

};

case 2:

return new IPersonManager.Stub() {

@Override

public void getPerson() throws RemoteException {

System.out.println("---->person");

}

};

}

return null;

}

};

3.客户端实现一个BinderPool类  这个类主要是封装了 AIDL的一些实现方法 方便调用罢了 其中 涉及到一个可以实现同步机制的类

CountDownLatch  这个类 当他的值 不是0的时候  执行了await方法后会使方法一直停在await处  不进行 直到他的值变成了0 才可以继续执行

也就是说 当执行了await方法  这个线程就会阻塞 等待这个数值变到0后继续执行

而在BinderPool中的应用场景是这样的

private void connectService(){

countDownLatch = new CountDownLatch(1);  //实现同步机制

Intent intent = new Intent();

intent.setClass(ctx,MyService.class);

ctx.bindService(intent,connection,Context.BIND_AUTO_CREATE);

try {

countDownLatch.await();

} catch (InterruptedException e) {

e.printStackTrace();

}

}

首先为什么在这里要使用同步机制  我们要搞清楚 让我们看这个方法调用的时机 :

binderPool = BinderPool.getInstance(MainActivity.this);  //connectService方法 是在这个方法中调用的

IBinder iBinder = binderPool.queryBinder(2);

iPersonManager = IPersonManager.Stub.asInterface(iBinder);

try {

iPersonManager.getPerson();

} catch (RemoteException e) {

e.printStackTrace();

}

因为我们最终的目的是在bind服务  连接到远程服务之后获取到 binderPool对象调用它的 binderPool.queryBinder(2) 方法  如果不加同步机制

异步执行  就有可能在 connectService方法 执行完之后  执行IBinder iBinder = binderPool.queryBinder(2);这行代码的时候binderPool对象还

没有被赋值  这样就会产生问题  所以我们让 connectService方法 阻塞  当BinderPool中的 binderPool对象赋值之后 让CountDownLatch的值countDown到0

这样 connectService方法就会继续执行 然后执行下一行代码了

BinderPool demo下载 : http://download.csdn.net/detail/u012760183/9520188

最后 总结了这么多IPC通信方式  那我们该如何选择合适的IPC方式呢  针对这几种IPC通信方式分析一下优缺点

1.bundle :

简单易用  但是只能传输Bundle支持的对象 常用于四大组件间进程间通信

2.文件共享:

简单易用  但不适合在高并发的情况下 并且读取文件需要时间 不能即时通信   常用于并发程度不高 并且实时性要求不高的情况

3.AIDL :

功能强大 支持一对多并发通信 支持即时通信   但是使用起来比其他的复杂 需要处理好多线程的同步问题  常用于一对多通信 且有RPC 需求的场合(服务端和客户端通信)

4.Messenger :

功能一般 支持一对多串行通信 支持实时通信  但是不能很好处理高并发情况 只能传输Bundle支持的类型  常用于低并发的无RPC需求一对多的场合

5.ContentProvider :

在数据源访问方面功能强大 支持一对多并发操作 可扩展call方法  可以理解为约束版的AIDL  提供CRUD操作和自定义函数  常用于一对多的数据共享场合

6.Socket :

功能强大 可以通过网络传输字节流 支持一对多并发操作  但是实现起来比较麻烦 不支持直接的RPC   常用于网络数据交换

总结起来

当仅仅是跨进程的四大组件间的传递数据时 使用Bundle就可以  简单方便

当要共享一个应用程序的内部数据的时候  使用ContentProvider实现比较方便

当并发程度不高  也就是偶尔访问一次那种 进程间通信 用Messenger就可以

当设计网络数据的共享时  使用socket

当需求比较复杂  高并发 并且还要求实时通信 而且有RPC需求时  就得使用AIDL了

文件共享的方法用于一些缓存共享 之类的功能

时间: 2024-07-29 09:39:21

Android中实现IPC的几种方式详细分析及比较的相关文章

Android攻城狮 Android中更新UI的几种方式

Android中更新UI的几种方式: 1. Activity 的 runOnUiThread() 2. Handler 的 post() 3. Handler 的 sendMessage() 4. View 的 post() 1 public class FiveActivity extends Activity { 2 3 private TextView textView; 4 5 private Handler handler = new Handler() { 6 public void

Android中多线程的使用四种方式最全总结

当我们启动一个App的时候,Android系统会启动一个Linux Process,该Process包含一个Thread,称为UI Thread或Main Thread.通常一个应用的所有组件都运行在这一个Process中,当然,你可以通过修改四大组件在Manifest.xml中的代码块(<activity><service><provider><receiver>)中的android:process属性指定其运行在不同的process中.当一个组件在启动的

Android中关闭应用的三种方式

当应用不再使用的时候,通常需要关闭应用,我们可以使用三种方式关闭android应用: 第一种方式:首先获取当前进程的id,然后杀死该进程(推荐) android.os.Process.killProcess(android.os.Process.myPid()) 第二种方式:终止当前正在运行的Java虚拟机,导致该程序终止 System.exit(0) 第三种方式:强制关闭与该包有关联的一切执行 ActivityManager manager=(ActivityManager) getSyste

(原创)android中使用相机的两种方式

在社交类应用或扫描二维码的场合都需要用到手机上的摄像头 在程序中启用这一硬件主要有两类方法 1.发送intent启动系统自带的摄像应用 此应用的AndroidManifest中的intent-filter如下 <intent-filter> <action android:name="android.media.action.VIDEO_CAPTURE" /> <category android:name="android.intent.cate

Android中activity传值的两种方式

第一种:第一个Activity  /**      * 通过这个方法跳转到activity2界面*/     public void gotoActivity2(View v){      //创建一个意图      Intent intent=new Intent(this,MainActivity2.class);                //第一种传值方式      Bundle bundle=new Bundle();      bundle.putString("name&quo

转:在android中button响应的两种方式

1. 在布局文件中添加button的监听名字 Android:onClick="buttonOnClick" 例如: <Button android:id="@+id/button2" android:layout_width="wrap_content" android:layout_height="wrap_content" android:layout_alignRight="@+id/button1&q

android中获取打气筒的几种方式

1,简单说明,打气筒就是将我们的xml布局转换为我们的view对象,不扯远了,直接看代码 1 A:从context中获取 2 LayoutInflater inflater1 = LayoutInflater.from(this); 3 B:通过Activitiy直接获取 4 LayoutInflater inflater2 = this.getLayoutInflater(); 5 C:根据SystemService获取资源 6 LayoutInflater inflater3 = (Layo

【Android】播放音频的几种方式介绍

接下来笔者介绍一下Android中播放音频的几种方式,android.media包下面包含了Android开发中媒体类,当然笔者不会依次去介绍,下面介绍几个音频播放中常用的类: 1.使用MediaPlayer播放音频 MediaPlayer的功能很强大,下面附上一张该类封装音频的生命周期图: MediaPlayer支持AAC.AMR.FLAC.MP3.MIDI.OGG.PCM等格式,MediaPlayer可以通过设置元数据和播放源来音频. 1.1播放Raw文件夹下面音频的元数据 //直接创建,不

【转】Android播放音频MediaPlayer的几种方式介绍

接下来笔者介绍一下Android中播放音频的几种方式,android.media包下面包含了Android开发中媒体类,当然笔者不会依次去介绍,下面介绍几个音频播放中常用的类: 1.使用MediaPlayer播放音频 MediaPlayer的功能很强大,下面附上一张该类封装音频的生命周期图: MediaPlayer支持AAC.AMR.FLAC.MP3.MIDI.OGG.PCM等格式,MediaPlayer可以通过设置元数据和播放源来音频. 1.1播放Raw文件夹下面音频的元数据 //直接创建,不