Android下的IPC通信方式

2022-04-08 19:02:37 阅读：198 来源： 互联网

标签：IPC void 通信 Game Messenger Override new Android public

一、Bundle

Android的Activity、Service、Receiver都支持在Intent传递Bundle数据,Bundle实现了Parcelable接口,

所以能很方便的在不同进程之间进行数据传传输.比如A应用打开B应用的某个Activity,如果要传递自定义的类型,

可以继承自Parcelable接口,参考Parcelable的使用方式 Android序列化的几种实现方式

A页面:

public class MainActivity extends AppCompatActivity {
    private final static int OPEN_OTHER_ACTIVITY_REQUEST_CODE = 0;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
	setContentView(R.layout.activity_main);

	Intent intent = new Intent();
	String packageName = "komine.demos.ipcdemo2";
	String activityName = packageName + ".MainActivity";
	intent.putExtra("msg","来自komine.demos.ipc传递的参数");
	ComponentName componentName = new ComponentName(packageName,activityName);
	intent.setComponent(componentName);

	startActivityForResult(intent,OPEN_OTHER_ACTIVITY_REQUEST_CODE);
    }
  
    @Override
    protected void onActivityResult(int requestCode, int resultCode, @Nullable Intent data) {
        if(data != null){
            if(requestCode == OPEN_OTHER_ACTIVITY_REQUEST_CODE){
                Toast.makeText(getApplicationContext(),data.getStringExtra("value"),Toast.LENGTH_SHORT).show();
            }
        }
    }
}

B页面:

public class MainActivity extends AppCompatActivity {

    private final static int RESULT_CODE = 0;
    private TextView textView;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
	setContentView(R.layout.activity_main);

	textView = findViewById(R.id.tv);
        if(getIntent() != null){
            String msg = getIntent().getStringExtra("msg");
            textView.setText(msg);
        }
    }

    @Override
    public void onBackPressed() {
       Intent intent = new Intent();
       intent.putExtra("value","来自komine.demos.ipcdemo2的MainActivity页面返回的值");
       setResult(RESULT_CODE,intent);

       finish();
    }
}

二、Messenger

1.基本使用

Messenger是基于AIDL的一种轻量化跨进程通信方式,内部是通过Handler进行消息发送的

首先新建一个MessengerService类

public class MessengerService extends Service implements Handler.Callback {

    private static final String TAG = "MessengerService";
    public static final int CLIENT_WHAT = 1;
    public static final int SERVER_WHAT = 2;

    //服务端接收到一条消息就会向客户端发送一条回复消息
    @Override
    public boolean handleMessage(@NonNull Message msg) {
        if (msg.what == CLIENT_WHAT) {
            Log.d(TAG, "收到来自客户端的消息:" + msg.getData());

	    //msg.replyTo是客户端定义的Messenger对象,用来向客户端发送消息
	    Messenger client = msg.replyTo;
            Message replyMessage = Message.obtain(null, SERVER_WHAT);

	    Bundle bundle = new Bundle();
	    bundle.putString("reply", "服务端回复客户端的数据..." + new Date());
	    replyMessage.setData(bundle);

            try {
		//调用客户端的Messenger对象向客户端发送消息
                client.send(replyMessage);
	    } catch (Exception e) {
                e.printStackTrace();
	    }
        }
        return false;
    }

    //服务端的Messenger对象,客户端可以通过onBind中返回的IBinder对象
    //来实例化一个Messenger对象,用来向服务端发送Message,Messenger内部采用
    //的是Message来进行消息传递,所以需要一个Handler对象来进行消息发送
    private final Messenger mMessenger = new Messenger(new Handler(Looper.getMainLooper(),this));

    @Nullable
    @Override
    public IBinder onBind(Intent intent) {
	//返回Messenger的Binder对象
        return mMessenger.getBinder();
    }
}

在AndroidManifest.xml注册MessengerService,该服务运行在另外一个进程中,冒号开头表示在当前进程名之前加上完整的包名,

并且该进程为应用的私有进程,不以冒号开头,则表示全局进程,其他可以通过sharedUserId的方式将自己运行在同一个进程中,比如

sharedUserId = "android.uid.system",将自己运行在系统进程中,以取得系统进程的一些权限,以这种方式运行在一起的进程之间

可以互相访问对方的私有数据,比如data目录、files目录,另外签名要保持一致才行,debug版本不需要.

注册MessengerService

<service android:name="komine.demos.messager.MessengerService" android:process=":remote"/>

MainActivity,布局就一个按钮,绑定了sendMsg方法就不贴代码了

public class MainActivity extends AppCompatActivity implements ServiceConnection,Handler.Callback {

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

	//绑定远程Service
	bindService(new Intent(this, MessengerService.class),this,Context.BIND_AUTO_CREATE);
    }

    @Override
    public void onServiceConnected(ComponentName name, IBinder service) {
        //通过IBinder对象创建一个Messenger实例
	mService = new Messenger(service);
    }

    //点击发送按钮就会向服务端发送一条Message
    public void sendMsg(View view) {
        Message msg = Message.obtain(null,MessengerService.CLIENT_WHAT);

	Bundle data = new Bundle();
	data.putString("msg","hello,this is client");
	msg.setData(data);

	//指定当前消息是那个Messenger对象发送的,该对象就是我们在服务端
	//向客户端发送Message的Messenger对象
	msg.replyTo = mGetReplyMessenger;
        try{
            mService.send(msg);
	}catch (RemoteException e){
            e.printStackTrace();
	}
    }

    @Override
    public void onServiceDisconnected(ComponentName name) {

    }

    //客户端的Messenger对象
    private Messenger mGetReplyMessenger = new Messenger(new Handler(Looper.getMainLooper(),this));

    //处理服务端发送回来的Message
    @Override
    public boolean handleMessage(@NonNull Message msg) {
        if(msg.what == MessengerService.SERVER_WHAT){
            Log.d("client", "收到来自服务端的消息:" + msg.getData().getString("reply"));
    	}
        return false;
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        if(mService != null && mService.getBinder().isBinderAlive()){
            unbindService(this);
	}
    }
}

客户端输出:

服务端输出:

注意:由于MessengerService是在不同的线程,需要切换进程才能看到对于的日志输出

Messenger是通过Handler来实现消息发送的,而Handler的内部是通过消息队列来维护每一个Message对象,

队列是一个先进先出的数据结构,所以Messenger无法并发处理多个消息,只能一条一条的处理.

2.绑定其他应用的Service

上述代码是客户端和服务端都在同一个应用之内的两个不同进程,如果要绑定其他应用的xxx服务,需要通过显式Intent来绑定,
并且远程Service要设置 exported = "true",不然会抛异常

<service android:name=".MessengerServer" android:exported="true"/>

a.setClassName()方式

intent.setClassName("包名","包名.Service名称");

b.setComponent() 方式

intent.setComponent(new ComponentName("包名","包名.Service名称"));

例如:

Intent intent = new Intent();
intent.setComponent(new ComponentName("komine.demos.messenegerserver","komine.demos.messenegerserver.MessengerServer"));

//网上有说直接在bindService()之前调用startService()开启服务,我试过是无效的,小米Note4x(7.1)可以
//在调用该方法之前,需要在另一端(要绑定的服务所在的应用)开启对应的Service
//测试环境:模拟器和真机(索尼),Android11必要在对应应用开启Service才能绑定成功
bindService(intent, this, Context.BIND_AUTO_CREATE);

注意:在在调用bindService()之前,需要远程进程(指要绑定的服务所在的应用)开启要绑定的Service,

不然bindService()不报错,也不会回调onServiceConnected()

三、AIDL

AIDL是Android 接口定义语言,可以通过AIDL在两个进程之间进行IPC通信.

1.基本使用

新建Game.java

public class Game implements Parcelable {
    public String name;

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

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

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

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

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

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

新建Game.aidl

可能会提示名称不唯一的错误,不让创建,可以先随便取个名字,然后再重命名,应该是as的bug

Game.aidl 对应 Game.java

// Game.aidl
package komine.demos.ipcdemo3;

// Declare any non-default types here with import statements
//指向Game.java
parcelable Game;

新建IGameShopManager.aidl

// IGameShopManager.aidl
package komine.demos.ipcdemo3;

// Declare any non-default types here with import statements
//引入Game.aild 即使是在同一包名下也需要import
import komine.demos.ipcdemo3.Game;
import komine.demos.ipcdemo3.IDownloadCompleteListener;

interface IGameShopManager {
    boolean buy(float money);
    void download(in IDownloadCompleteListener listener);
    void registerDownloadListener(in IDownloadCompleteListener listener);
    void unregisterDownloadListener(in IDownloadCompleteListener listener);
}

新建IDownloadCompleteListener.aidl

// IDownloadCompleteListener.aidl
package komine.demos.ipcdemo3;

// Declare any non-default types here with import statements
import komine.demos.ipcdemo3.Game;

interface IDownloadCompleteListener {
    void onDownloadCompleted(in Game game);
}

新建EShopManagerService.java

public class EShopManagerService extends Service {

    //Android提供的用于跨进程删除listener的接口,内部维护了一个Map集合,key是IBinder,通过
    //比对key来删除对应的listener,如果不使用这个类,而使用普通的集合,在服务解绑,页面关闭之后,listener也不会
    //移除,可以在循环中不断回调打印日志试试
    private RemoteCallbackList<IDownloadCompleteListener> listeners = new RemoteCallbackList<>();

    private Binder mBinder = new IGameShopManager.Stub() {
        @Override
	public boolean buy(float money) throws RemoteException {
            return money >= 100;
        }

        @Override
	public void download(IDownloadCompleteListener listener) throws RemoteException {
            Game game = new Game("黑暗之魂重置版");
            try {
                //模拟耗时操作
		Thread.sleep(3000);

		//固定写法,从RemoteCallbackList取数据的固定写法
		listeners.beginBroadcast();

                int size = listeners.getRegisteredCallbackCount();
                for (int i = 0;i < size;i++){
                    listeners.getBroadcastItem(i).onDownloadCompleted(game);
	      	}

                //固定写法
		listeners.finishBroadcast();

	   } catch (InterruptedException e) {
                e.printStackTrace();
	   }
        }

        @Override
	public void registerDownloadListener(IDownloadCompleteListener listener) throws RemoteException {
	    //注册回调接口
            listeners.register(listener);
	}

        @Override
	public void unregisterDownloadListener(IDownloadCompleteListener listener) throws RemoteException {
	    //移除回调接口
            listeners.unregister(listener);
	}
    };

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

注册EShopManagerService

<service android:name=".EShopManagerService" android:process=":remote"/>

MainActivity.java

public class MainActivity extends AppCompatActivity implements ServiceConnection {
    private IGameShopManager mShopManager;

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

	bindService(new Intent(this,EShopManagerService.class),this, Context.BIND_AUTO_CREATE);
    }

    @Override
    public void onServiceConnected(ComponentName name, IBinder service) {
        mShopManager = IGameShopManager.Stub.asInterface(service);
        try {
	    //注册回调接口
            mShopManager.registerDownloadListener(downloadCompleteListener);
	} catch (RemoteException e) {
            e.printStackTrace();
	}
    }

    @Override
    public void onServiceDisconnected(ComponentName name) {

    }

    public void buy(View view) throws RemoteException {
        boolean buyResult = mShopManager.buy(100);
        if(buyResult){
            Toast.makeText(getApplicationContext(),"购买成功!",Toast.LENGTH_SHORT).show();
	}
    }

    public void download(View view) {
        try{
            mShopManager.download(downloadCompleteListener);
	}catch (Exception e){
            e.printStackTrace();
	}
    }

    private IDownloadCompleteListener downloadCompleteListener = new IDownloadCompleteListener.Stub() {
        @Override
	public void onDownloadCompleted(final Game game) throws RemoteException {
            runOnUiThread(new Runnable() {
                @Override
		public void run() {
                    Toast.makeText(getApplicationContext(),"下载完成:" + game.name,Toast.LENGTH_SHORT).show();
		}
            });
	}
    };

    @Override
    protected void onDestroy() {
        super.onDestroy();
	//如果mShopManager的Binder未被销毁
        if(mShopManager != null && mShopManager.asBinder().isBinderAlive()){
            unbindService(this);
            try {
                mShopManager.unregisterDownloadListener(downloadCompleteListener);
	    } catch (RemoteException e) {
                e.printStackTrace();
	    }
        }
    }
}

AIDL绑定其他应用的Service的流程和Messenger一致,参考Messenger的绑定流程

...待更新

标签：IPC,void,通信,Game,Messenger,Override,new,Android,public
来源： https://www.cnblogs.com/komine/p/16119249.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

Android下的IPC通信方式

一、Bundle

二、Messenger

1.基本使用

2.绑定其他应用的Service

三、AIDL

1.基本使用