2. 程式人生 > >Messenger實現多程序通訊

Messenger實現多程序通訊

阿新 • • 發佈：2019-02-14

Messenger進行多程序通訊時一次處理一個請求，在服務端不用考慮執行緒同步的問題，因為服務端不存在併發執行的情況。它的作用主要是為了傳遞訊息，如果需要跨程序呼叫服務端的方法就不適合使用。

用Messenger實現多執行緒通訊時，服務端：

在服務端建立一個Service來處理客戶端的連線請求，同時建立一個Handler並通過這個Handler來建立一個Messenger物件，然後在Service的onBaind方法中返回這個Messenger物件底層的Binder即可。程式碼如下：

public class MessengerService extends Service {
private static final int 
 
SAY_HOLLE = 0;private static final String TAG = "MessengerService";
private static class MessengerHandler extends Handler{
@Override
public void handleMessage(Message msg) {
switch(msg.what){
case SAY_HOLLE:
                    Log.e(TAG, "receive msg from client:" + msg.getData().getString("msg"));

 
break;
default:
                    super.handleMessage(msg);
            }
        }
    }
private final Messenger mMessenger = new Messenger(new MessengerHandler());
@Nullable
    @Override
public IBinder onBind(Intent intent) {
return mMessenger.getBinder();
    }
}
Service在Android Manifest檔案中的註冊為： 
<
 
service
android:name=".MessengerService"
android:exported="true"
android:enabled="true"
android:process=":remote"/>
通過Android Manifest檔案中給Service指定process屬性來實現與客戶端處於不同的程序。

客戶端：

客戶端程序首先要繫結服務端的Service，繫結成功之後用服務端返回的IBinder物件建立一個Messenger，即通過onServiceConnected()方法中的IBinder service引數建立一個客戶端的Messenger物件，然後通過這個Messenger就可以向服務端傳送訊息了，傳送的訊息是Message型別。(新建Message物件，Bundle物件，Bundle物件中放入需要往服務端傳送的訊息內容，然後將Bundle物件放進Message物件中，最後通過Messenger物件將該Message傳送給服務端)程式碼如下圖所示：

public class MainActivity extends AppCompatActivity {
private static final int SAY_HOLLE = 0;private static final String TAG = "MainActivity";
private Messenger mService;
private ServiceConnection mConnection = new ServiceConnection() {
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
mService = new Messenger(service);
Message msg = Message.obtain(null, SAY_HOLLE,0,0);
Bundle data = new Bundle();
data.putString("msg", "hello, this is client.");
msg.setData(data);try {
mService.send(msg);
            } catch (RemoteException e) {
e.printStackTrace();
            }
        }
@Override
public void onServiceDisconnected(ComponentName name) {
        }
    };
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
Log.e(TAG, "onCreate");
Intent intent = new Intent(this, MessengerService.class);
bindService(intent, mConnection, Context.BIND_AUTO_CREATE);
    }
@Override
protected void onDestroy() {
unbindService(mConnection);
super.onDestroy();
Log.e(TAG, "onDestroy");
    }
}
這樣就完成了利用Messenger實現程序間通訊的功能。如果需要實現服務端能夠迴應客戶端，那麼客戶端就應該和服務端一樣，需要新建一個Handler，並通過這個Handler新建一個新的Messenger，將這個Messenger物件通過Message的replyTo引數傳遞給服務端，服務端通過這個replyTo引數在服務端新建一個Messenger物件，傳送Message型別的引數就可以迴應客戶端。

實現上述功能客戶端需要新增的程式碼是：

private Messenger mGetReplyMessenger = new Messenger(new MessengerHandler());
private static class MessengerHandler extends Handler{
@Override
public void handleMessage(Message msg) {
switch(msg.what){
case TO_HOLLE:
                Log.e(TAG, "receiver msg from Service:" + msg.getData().getString("reply"));
break;
default:
                super.handleMessage(msg);
        }
    }
}
和 
msg.replyTo = mGetReplyMessenger;

服務端需要新增的程式碼是：

Messenger client = msg.replyTo;
Message replyMessage = Message.obtain(null, TO_HOLLE);
Bundle bundle = new Bundle();
bundle.putString("reply", "嗯， 你的訊息我已經收到， 稍後會回覆你");
replyMessage.setData(bundle);
try {
client.send(replyMessage);
} catch (RemoteException e) {
e.printStackTrace();
}
服務端總的完整程式碼就是： 
/**
 * Created by su on 2017/10/26.
 */
public class MessengerService extends Service {
private static final int SAY_HOLLE = 0;
private static final int TO_HOLLE = 1;
private static final String TAG = "MessengerService";
private static class MessengerHandler extends Handler{
@Override
public void handleMessage(Message msg) {
switch(msg.what){
case SAY_HOLLE:
                    Log.e(TAG, "receive msg from client:" + msg.getData().getString("msg"));
Messenger client = msg.replyTo;
Message replyMessage = Message.obtain(null, TO_HOLLE);
Bundle bundle = new Bundle();
bundle.putString("reply", "嗯， 你的訊息我已經收到， 稍後會回覆你");
replyMessage.setData(bundle);
try {
client.send(replyMessage);
                    } catch (RemoteException e) {
e.printStackTrace();
                    }
break;
default:
                    super.handleMessage(msg);
            }
        }
    }
private final Messenger mMessenger = new Messenger(new MessengerHandler());
@Nullable
    @Override
public IBinder onBind(Intent intent) {
return mMessenger.getBinder();
    }
}
客戶端程式碼是： 
public class MainActivity extends AppCompatActivity {
private static final int SAY_HOLLE = 0;
private static final int TO_HOLLE = 1;
private static final String TAG = "MainActivity";
private Messenger mService;
private Messenger mGetReplyMessenger = new Messenger(new MessengerHandler());
private static class MessengerHandler extends Handler{
@Override
public void handleMessage(Message msg) {
switch(msg.what){
case TO_HOLLE:
                    Log.e(TAG, "receiver msg from Service:" + msg.getData().getString("reply"));
break;
default:
                    super.handleMessage(msg);
            }
        }
    }
private ServiceConnection mConnection = new ServiceConnection() {
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
mService = new Messenger(service);
Message msg = Message.obtain(null, SAY_HOLLE,0,0);
Bundle data = new Bundle();
data.putString("msg", "hello, this is client.");
msg.setData(data);
//
msg.replyTo = mGetReplyMessenger;
try {
mService.send(msg);
            } catch (RemoteException e) {
e.printStackTrace();
            }
        }
@Override
public void onServiceDisconnected(ComponentName name) {
        }
    };
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
Log.e(TAG, "onCreate");
Intent intent = new Intent(this, MessengerService.class);
bindService(intent, mConnection, Context.BIND_AUTO_CREATE);
    }
@Override
protected void onDestroy() {
unbindService(mConnection);
super.onDestroy();
Log.e(TAG, "onDestroy");
    }
}
最後在logcat觀察列印輸出的結果時，由於服務端和客戶端在一個應用的不同程序，客戶端在預設的包名程序下，這樣不加設定的話只能看到客戶端的log列印輸出結果，如果要檢視服務端的log列印結果，應該在log上設定過濾器，這樣才能檢視服務端的日誌列印結果。如：

這樣在logcat中觀察服務端列印的資訊就如下圖所示：


相關推薦

Messenger實現多程序通訊

Messenger進行多程序通訊時一次處理一個請求，在服務端不用考慮執行緒同步的問題，因為服務端不存在併發執行的情況。它的作用主要是為了傳遞訊息，如果需要跨程序呼叫服務端的方法就不適合使用。 用Messenger實現多執行緒通訊時，服務端： 在服務端建立一個Service來

多執行緒、多程序通訊 （java實現）

程序間通訊方式1.管道（匿名管道 Pipe）//   PipedInputStream  、PipedOutputStream2.命名管道（NamedPipe/FIFO）//java 不支援？3.訊號（Signal） // wait() notify() notifyall(

Linux----網路程式設計（TCP網路通訊客戶端伺服器程式設計實現多程序）

1、伺服器ser.c 1 #include <stdio.h> 2 #include <stdlib.h> 3 #include <unistd.h> 4 #include <assert.h> 5 #in

windows下多程序通訊，基於共享記憶體環形佇列實現

1 #include "stdafx.h" 2 #include "InterProcessCommunication.h" 3 #include <string> 4 enum 5 { 6 STATE_EMPTY = 0, 7 STATE_READ,

Android 使用Messenger實現跨app通訊

Android中使用跨程序通訊有以下幾種方式：檔案、廣播、aidl、messenger,今天要講的是使用messenger來實現跨app通訊也就是在兩個不同的app中實現雙向通訊。其實Messenger底層也是使用aidl的方式來實現的，只不過其使用handler來處理訊息，因為handler是執行

Python 程序間共享變數(多程序通訊安全)

import multiprocessing import time def worker(d, key, value): d[key] = value if __name__ == '__main__': mgr = multiprocessing.Manager()

python語法——使用Pool實現多程序並行

簡介 Pool 模組來自於 multiprocessing 模組。 multiprocessing 模組是跨平臺版本的多程序模組，像執行緒一樣管理程序，與 threading 很相似，對多核CPU的利用率會比 threading 好的多。 Pool 類可以提供指定數

python技巧——使用Pool實現多程序並行

簡介 可以使用 Pool來實現多程序並行。 Pool 模組來自於 multiprocessing 模組。 multiprocessing 模組是跨平臺版本的多程序模組，像執行緒一樣管理程序，與 threading 很相似，對多核CPU的利用率會比 threading

程序與執行緒（2）- python實現多程序

python 實現多程序  參考連結： https://morvanzhou.github.io/tutorials/python-basic/multiprocessing/ python中實現多程序的模組：multiprocessing 注意：在windows系統下

使用共享記憶體實現Linux程序通訊

我們通過共享記憶體的技術實現程序間的通訊，剛開始定義兩個檔案，讀程序從輸入檔案intput中讀取資料，並將其放入共享記憶體中，然後寫程序將共享記憶體中的資料輸出到輸出檔案output中。程式比較簡單，因

多執行緒與多程序及Python實現【Python實現多程序】

上一篇部落格介紹了多執行緒與多程序的理論部分，這篇部落格將參考部落格以及各種教程完成Python多程序實現部分。 multiprocessing模組 Process 類 multiprocessing.Process(group=None, target=N

python多程序通訊之multiprocessing.Queue

multiprocessing.Queue()和queue.Queue()的區別 Queue.Queue是程序內非阻塞佇列，用於程序內的各函式模組或執行緒間通訊。 multiprocess.Queue是跨程序通訊佇列。但是不能用於multiprocessing.

python3實現多程序併發任務

在python開發中，有時候會有這樣的需求，比如說我後很多個任務，需要並行執行，也就是說有一個任務佇列，大家都知道，在python中的多執行緒，它其實從嚴格意義上來講，並不是真正的多執行緒。所以用多執行緒我們還不如使用多程序。使用多程序的有什麼好處了，它可以實現分散式多機並行。多個客戶端共享一個

python之通過thread來實現多程序

程式碼如下： import threading, time class Test1(threading.Thread): def __init__(self, name): super().__init__(name=name) def run(self): print('tes

Linux 實現多程序拷貝檔案

//copy.c #include <stdio.h> #include <unistd.h> #include <fcntl.h> #include<stdlib.h> #include<sys/stat.h> #include<e

使用AIDL方式啟動Service 實現跨程序通訊

建立aidl檔案 注意：aidl檔案中可以引用其它aidl檔案中定義的介面，但是不能夠引用java類檔案中 定義的介面。建立時在Project模式在，選中src/main資料夾,new->adil檔案新建的aidl 檔案需要make才能編譯生 // MusicAidl

Android使用AIDL實現跨程序通訊（IPC）

前言：在還沒有做任何一件事情之前，千萬不要覺得這件事情很難，因為還沒有開始做內心就已經對這件事情產生了恐懼，這將會阻止你的進步，也許當你動手開始做了這件事後發現其實並不是很難。 一、 AIDL概述 含義：AIDL（Android Interface Defi

PHP 如何實現多程序 and mysql查詢效率

首先我來說說這個我的需求吧。 需求： 有極少的使用者來訪問我的網頁，但是一旦有使用者訪問，就會查詢資料庫，資料庫是極大的。如果直接查詢的話，那麼耗時很長，為了節約時間，有很多工作需要做，其中一個就是多程序（多執行緒）。比如，一個程序查詢一個table，這樣可以提高效率。然後

【Linux多程序通訊】訊號

注意區分訊號與訊號量之間的區別。 一、什麼是訊號 用過Windows的我們都知道，當我們無法正常結束一個程式時，可以用工作管理員強制結束這個程序，但這其實是怎麼實現的呢？同樣的功能在Linux上是通過生成訊號和捕獲訊號來實現的，執行中的程序捕獲到這個訊號然後作出一

Android四大元件應用系列——使用ContentProvider實現跨程序通訊

package com.jereh; public class PersonProvider extends ContentProvider { private DbOpenHelper openHelper; private static final UriMatcher