服务端代码
1 public class MessengerService extends Service { 2 private static final String TAG = "Messenger-Demo"; 3 private static final int MSG_CLIENT = 0x001; 4 private static final int MSG_SERVER = 0X002; 5 private static final String KEY_CLIENT = "key_client"; 6 private static final String KEY_SERVER = "key_server"; 7 8 private final Messenger mMessenger = new Messenger(new MessageHandler()); 9 10 @Nullable 11 @Override 12 public IBinder onBind(Intent intent) { 13 return mMessenger.getBinder(); 14 } 15 16 private static class MessageHandler extends Handler { 17 @Override 18 public void handleMessage(Message msg) { 19 switch (msg.what) { 20 case MSG_CLIENT: 21 Log.d(TAG, "receive msg from Client:" + msg.getData().getString(KEY_CLIENT)); 22 Messenger messenger = msg.replyTo; 23 Message serverMsg = Message.obtain(); 24 serverMsg.what = MSG_SERVER; 25 Bundle bundle = new Bundle(); 26 bundle.putString(KEY_SERVER, "Hello Client! I am fine, thank you"); 27 serverMsg.setData(bundle); 28 try { 29 messenger.send(serverMsg); 30 } catch (RemoteException e) { 31 e.printStackTrace(); 32 } 33 break; 34 default: 35 super.handleMessage(msg); 36 } 37 } 38 } 39 }
清单文件中注册:
1 public class MessengerClientActivity extends AppCompatActivity { 2 3 private static final String TAG = "Messenger-Demo"; 4 private static final int MSG_CLIENT = 0x001; 5 private static final int MSG_SERVER = 0X002; 6 private static final String KEY_CLIENT = "key_client"; 7 private static final String KEY_SERVER = "key_server"; 8 private static final String SERVER_PKGNAME = "com.example.messageserver"; 9 private static final String SERVICE_PATH = "com.example.messageserver.MessengerService"; 10 private Messenger mRemoteMessenger; 11 private Messenger mLocalMessenger = new Messenger(new MessengerClientHandler()); 12 13 @Override 14 protected void onCreate(Bundle savedInstanceState) { 15 super.onCreate(savedInstanceState); 16 setContentView(R.layout.activity_main); 17 Log.d(TAG,"onCreate"); 18 bindService(); 19 } 20 21 private void bindService() { 22 Intent intent = new Intent(); 23 ComponentName componentName = new ComponentName(SERVER_PKGNAME, SERVICE_PATH); 24 intent.setComponent(componentName); 25 bindService(intent, mServiceConnection, Context.BIND_AUTO_CREATE); 26 } 27 28 private static class MessengerClientHandler extends Handler { 29 @Override 30 public void handleMessage(Message msg) { 31 switch (msg.what) { 32 case MSG_SERVER: 33 Log.d(TAG, "receive msg from Server:" + msg.getData().getString(KEY_SERVER)); 34 break; 35 default: 36 break; 37 } 38 super.handleMessage(msg); 39 } 40 } 41 42 private ServiceConnection mServiceConnection = new ServiceConnection() { 43 @Override 44 public void onServiceConnected(ComponentName name, IBinder service) { 45 mRemoteMessenger = new Messenger(service); 46 Message clientMsg = Message.obtain(); 47 clientMsg.what = MSG_CLIENT; 48 Bundle bundle = new Bundle(); 49 bundle.putString(KEY_CLIENT, "Hello,Server! How are you ?"); 50 clientMsg.setData(bundle); 51 clientMsg.replyTo = mLocalMessenger; 52 try { 53 mRemoteMessenger.send(clientMsg); 54 } catch (RemoteException e) { 55 e.printStackTrace(); 56 } 57 } 58 59 @Override 60 public void onServiceDisconnected(ComponentName name) { 61 62 } 63 }; 64 65 @Override 66 protected void onDestroy() { 67 super.onDestroy(); 68 unbindService(mServiceConnection); 69 } 70 }
运行log:
1 15185-15185/com.example.messageserver D/Messenger-Demo: receive msg from Client:Hello,Server! How are you ? 2 14269-14269/com.example.messageclient D/Messenger-Demo: receive msg from Server:Hello Client! I am fine, thank you