안 드 로 이 드 메 신 저 크로스 프로 세 스 양 방향 통신
30368 단어 안 드 로 이 드 클 라 이언 트
그 중에서 Messenger 는 사용 이 간단 하고 대부분 다 중 프로 세 스,단일 스 레 드 의 응용 에 적용 되 며 AIDL 은 비교적 복잡 한 다 중 프로 세 스,다 중 스 레 드 의 응용 에 적용 된다.
여기 서 Messenger 의 용법 을 소개 하 는데 그 밑바닥 도 AIDL 로 이 루어 졌 다.
Messenger 사용법 을 살 펴 보 겠 습 니 다.
Reference to a Handler, which others can use to send messages to it. This allows for the implementation of message-based communication across processes, by creating a Messenger pointing to a Handler in one process, and handing that Messenger to another process.
Messenger 는 크로스 프로 세 스 메시지 구 조 를 처리 하기 위해 Handler 를 전달 해 야 합 니 다:Messenger(Handler target)에서 메 시 지 를 보 냅 니 다:send(Message message)throws Remote Exception 을 클 라 이언 트 에 전달 합 니 다:IBinder 메커니즘 IBinder getBinder()를 통 해
이 메커니즘 을 사용 하려 면 반드시 통신 쌍방 을 위해 각자 의 Messenger 를 구축 해 야 한다.그리고 Service 의 Messenger 는 여전히 IBinder 를 통 해 Activity 에 전달 되 고 Activity 도 자신의 Messenger 를 Message 의 reply To 속성 을 통 해 Service 에 전달 할 수 있다.
메모:크로스 프로 세 스 통신 은 Bundle 을 사용 합 니 다.그렇지 않 으 면 Java.lang.Runtime Exception:Can't marshal non-Parcelable objects across processes.
양 방향 통신 예:클 라 이언 트 가 서버 에 메 시 지 를 보 내 고 서버 가 받 은 후에 값 을 누적 하여 10 까지 누적 한 후에 클 라 이언 트 에 게 메 시 지 를 보 내 고 클 라 이언 트 는 업 그 레이 드 를 표시 합 니 다.
다 중 프로 세 스 서비스 선언
<service
android:name=".Messenger.MessengerService"
android:process=":it"
android:enabled="true"
android:exported="true"
>service>
서버
/*
* Copyright (c) 2020.
* author: duck
*/
package com.ducky.cachepicasso.Messenger;
import android.app.Service;
import android.content.Context;
import android.content.Intent;
import android.os.Bundle;
import android.os.Handler;
import android.os.IBinder;
import android.os.Message;
import android.os.Messenger;
import android.os.RemoteException;
import android.util.Log;
import android.widget.Toast;
import androidx.annotation.NonNull;
public class MessengerService extends Service {
static final String TAG = "Messenger-Service";
private int sum = 0;
public MessengerService() {
}
private Messenger messenger = new Messenger(new ServiceHandler());
private Messenger mClient;
public class ServiceHandler extends Handler{
private static final int SIG_GET_PLUS = 0;
private static final int SIG_SEND_UPDATE = 1;
@Override
public void handleMessage(@NonNull Message msg) {
//
switch(msg.what){
case SIG_GET_PLUS:
Bundle bundle = msg.getData();
sum += bundle.getInt("value");
Toast.makeText(MessengerService.this, sum+"", Toast.LENGTH_SHORT).show();
// =10
mClient = msg.replyTo;
if (null == mClient) {
return;
}
if (sum == 10) {
Message message = Message.obtain(null, SIG_SEND_UPDATE);
try {
mClient.send(message);
} catch (RemoteException e) {
e.printStackTrace();
}
}
break;
default:
break;
}
}
}
@Override
public IBinder onBind(Intent intent) {
Log.i(TAG, "service bind");
return messenger.getBinder();
}
@Override
public boolean onUnbind(Intent intent) {
Log.i(TAG, "service unbind");
return super.onUnbind(intent);
}
}
클 라 이언 트
/*
* Copyright (c) 2020.
* author: duck
*/
package com.ducky.cachepicasso.Messenger;
import android.content.ComponentName;
import android.content.Context;
import android.content.Intent;
import android.content.ServiceConnection;
import android.os.Bundle;
import android.os.Handler;
import android.os.IBinder;
import android.os.Message;
import android.os.Messenger;
import android.os.RemoteException;
import android.util.Log;
import android.view.View;
import android.widget.Toast;
import androidx.annotation.NonNull;
import androidx.appcompat.app.AppCompatActivity;
import com.ducky.cachepicasso.R;
public class MessengerActivity extends AppCompatActivity {
static final String TAG = "Messenger-Activity";
// Messenger
private Messenger mService;
// Messenger
private Messenger mMessenger;
//
private static final int SIG_SEND_PLUS = 0;
ServiceConnection serviceConnection = new ServiceConnection() {
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
Log.i(TAG, "service connected");
mService = new Messenger(service);
}
@Override
public void onServiceDisconnected(ComponentName name) {
Log.i(TAG, "service disconnected");
mService = null;
}
};
public class ClientHandler extends Handler{
//
private static final int SIG_GET_UPDATE = 1;
@Override
public void handleMessage(@NonNull Message msg) {
switch (msg.what){
case SIG_GET_UPDATE:
Toast.makeText(MessengerActivity.this, " !", Toast.LENGTH_SHORT).show();
break;
}
}
}
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.layout_messenger);
// Messenger
mMessenger = new Messenger(new ClientHandler());
//
bindService(new Intent(this, MessengerService.class), serviceConnection, Context.BIND_AUTO_CREATE);
// +
// 10
findViewById(R.id.button).setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
if (mService != null) {
try {
Message message = Message.obtain(null, SIG_SEND_PLUS);
Bundle bundle = new Bundle();
bundle.putInt("value", 1);
message.setData(bundle);
message.replyTo = mMessenger;
mService.send(message);
} catch (RemoteException e) {
e.printStackTrace();
}
}
}
});
}
@Override
protected void onDestroy() {
super.onDestroy();
unbindService(serviceConnection);
}
}