package com.demo.aidl;

import com.demo.aidl.ParcelableData;

interface IRemoteService {
 /**
 * 获取当前进程的pid
 */
 int getPid();
 /**
 * 获取当前服务名称
 */
 String getServiceName();
 /**
 * 处理客户端传过来的数据
 */
 void handleData(in ParcelableData data);
}

package com.demo.aidl;

/**
 * 声明支持传递的类
 */
parcelable ParcelableData;

package com.demo.aidl;

oneway interface IRemoteServiceCallBack {
 void valueChanged(int value);
}

private final IRemoteService.Stub mBinder = new IRemoteService.Stub() {
 @Override
 public int getPid() throws RemoteException {
 return Process.myPid();
 }

 @Override
 public String getServiceName() throws RemoteException {
 return RemoteService.this.getClass().getSimpleName();
 }

 @Override
 public void handleData(ParcelableData data) throws RemoteException {
 Toast.makeText(RemoteService.this, "num is " + data.num, Toast.LENGTH_SHORT).show();
 }

 @Override
 public void registerCallback(IRemoteServiceCallBack cb) throws RemoteException {
 if(cb != null) {
 mCallBacks.register(cb);
 }
 }

 @Override
 public void unregisterCallback(IRemoteServiceCallBack cb) throws RemoteException {
 if(cb != null) {
 mCallBacks.unregister(cb);
 }
 }
};

public class RemoteService extends Service {
 /**
 * 回调容器
 */
 private final RemoteCallbackList<IRemoteServiceCallBack> mCallBacks = new RemoteCallbackList<>();
 /**
 * aidl接口具体实现
 */
 private final IRemoteService.Stub mBinder = new IRemoteService.Stub() {
 @Override
 public int getPid() throws RemoteException {
 return Process.myPid();
 }

 @Override
 public String getServiceName() throws RemoteException {
 return RemoteService.this.getClass().getSimpleName();
 }

 @Override
 public void handleData(ParcelableData data) throws RemoteException {
 Toast.makeText(RemoteService.this, "num is " + data.num, Toast.LENGTH_SHORT).show();
 }

 @Override
 public void registerCallback(IRemoteServiceCallBack cb) throws RemoteException {
 if(cb != null) {
 mCallBacks.register(cb);
 }
 }

 @Override
 public void unregisterCallback(IRemoteServiceCallBack cb) throws RemoteException {
 if(cb != null) {
 mCallBacks.unregister(cb);
 }
 }
 };

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

 @Override
 public void onDestroy() {
 // 注销所有回调
 mCallBacks.kill();
 }
}

/**
 * 远端服务
 */
private IRemoteService mService;

private ServiceConnection mConnection = new ServiceConnection() {
 /**
 * 连接服务器成功回调
 * 
 * @param className
 * @param service
 */
 public void onServiceConnected(ComponentName className, IBinder service) {
 mService = IRemoteService.Stub.asInterface(service);
 }

 /**
 * 服务器因为一场情况断开连接时候回调
 * 
 * @param className
 */
 public void onServiceDisconnected(ComponentName className) {
 mService = null;
 }
};

/**
 * 绑定服务
 */
private void doBindService() {
 isBound = true;
 Intent intent = new Intent(BindRemoteServiceActivity.this, RemoteService.class);
 bindService(intent, mConnection, Context.BIND_AUTO_CREATE);
}

/**
 * 解除绑定
 */
private void doUnbindService() {
 if(isBound && mService != null) {
 isBound = false;
 try {
 mService.unregisterCallback(mCallback);
 } catch (RemoteException e) {
 e.printStackTrace();
 }

 unbindService(mConnection);
 }
}

/**
 * 向服务端发送信息
 */
private void doSendMsg() {
 if(!isBound || mService == null) {
 return;
 }
 ParcelableData data = new ParcelableData(1);
 try {
 mService.handleData(data);
 } catch (RemoteException e) {
 e.printStackTrace();
 }
}

/**
 * 调用服务端方法获取信息
 */
private void doGetServiceInfo() {
 if(!isBound || mService == null) {
 return;
 }
 try {
 String info = mService.getServiceName();

 mInfoTv.setText("Service info :" + info);
 } catch (RemoteException e) {
 e.printStackTrace();
 }
}

public class MessengerService extends Service {

 public static final int MSG_REGISTER_CLIENT = 0X001;
 public static final int MSG_UNREGISTER_CLIENT = 0X010;
 public static final int MSG_HANDLE = 0X100;

 private ArrayList<Messenger> mClients = new ArrayList<>();

 private final Messenger mMessenger = new Messenger(new IncomingHandler());

 @Nullable
 @Override
 public IBinder onBind(Intent intent) {
 return mMessenger.getBinder();
 }

 @Override
 public void onDestroy() {
 Toast.makeText(this, "Remote Service Destroy", Toast.LENGTH_SHORT).show();
 }

 private class IncomingHandler extends Handler {
 @Override
 public void handleMessage(Message msg) {
 switch (msg.what) {
 case MSG_REGISTER_CLIENT:
  mClients.add(msg.replyTo);
  break;
 case MSG_UNREGISTER_CLIENT:
  mClients.remove(msg.replyTo);
  break;
 case MSG_HANDLE:
  for (Messenger mClient : mClients) {
  try {
  mClient.send(Message.obtain(null, MSG_HANDLE, msg.arg1, 0));
  } catch (RemoteException e) {
  e.printStackTrace();
  mClients.remove(mClient);
  }
  }
  break;
 default:
  super.handleMessage(msg);
 }
 }
 };
}

/**
 * 关联远端服务的messenger
 */
private Messenger mServiceWrapper;
/**
 * 用于处理服务端发送的信息
 */
final Messenger mMessenger = new Messenger(new IncomingHandler());

private ServiceConnection mConnection = new ServiceConnection() {
 @Override
 public void onServiceConnected(ComponentName name, IBinder service) {
 mServiceWrapper = new Messenger(service);

 mInfoTv.setText("Connected Service");


 try {
 // 添加监听注册
 Message msg = Message.obtain(null, MessengerService.MSG_REGISTER_CLIENT);
 msg.replyTo = mMessenger;
 mServiceWrapper.send(msg);
 } catch (RemoteException e) {
 e.printStackTrace();
 }
 }

 @Override
 public void onServiceDisconnected(ComponentName name) {
 mServiceWrapper = null;
 mInfoTv.setText("Disconnected");
 }
};

/**
 * 绑定服务
 */
private void doBindService() {
 if(!isBound) {
 bindService(new Intent(this, MessengerService.class), mConnection, Context.BIND_AUTO_CREATE);

 isBound = true;

 mInfoTv.setText("Binding...");
 }
}

/**
 * 移除监听并解绑服务
 */
private void doUnbindService() {
 if(isBound) {
 if(mServiceWrapper != null) {
 try {
 Message msg = Message.obtain(null, MessengerService.MSG_UNREGISTER_CLIENT);
 msg.replyTo = mMessenger;
 mServiceWrapper.send(msg);
 } catch (RemoteException e) {
 e.printStackTrace();
 }
 }

 unbindService(mConnection);
 isBound = false;
 mInfoTv.setText("Unbinding...");
 }
}

/**
 * 向服务端发送信息
 */
private void doSendMsg() {
 if(mServiceWrapper != null) {
 try {
 Message msg = Message.obtain(null,
  MessengerService.MSG_HANDLE, this.hashCode(), 0);
 mServiceWrapper.send(msg);
 } catch (RemoteException e) {
 e.printStackTrace();
 }
 }
}

public void send(Message message) throws RemoteException {
 mTarget.send(message);
}

public Messenger(Handler target) {
 mTarget = target.getIMessenger();
}

public Messenger(IBinder target) {
 mTarget = IMessenger.Stub.asInterface(target);
}