android native service編寫及兩個服務進程通訊

題外話:由於同事咨詢,口頭講解的話1對1,但不方便多方傳播及繼承性,因此特意寫此文章講解一番。

1、android service簡要說明:

Android Service :又稱為 Java Service ,是實現在框架層裡的 Service ,使用Java語言編寫。
Native Service :又稱為 System Service ,是實現在 Runtime 層裡的 Service 。使用C++語言編寫。

對於這兩種service來說,兩個對等service通訊都是利用binder,隻不過一種利用*.aidl,一種利用IInterface
編寫序列化代碼而已,本質是一樣的,本書先介紹native service的編寫及兩個native service
如何通訊的過程:

2、native service的特點
A、因為底層核心服務是 Android 框架裡最接近 Linux/Driver 的部分。為瞭充分發揮硬件設備
   的差異化特性,核心服務是讓上層 Java 應用程序來使用 Driver/HW Device 特色的重要管道。
B、在開機過程中,就可以啟動核心服務 ( 例如漢字輸入法服務等 ) ,讓眾多應用程序來共享之。
C、由於共享,所以能有效降低程序的大小及統一的接口變化 。

3、如何實現一個native service
要點如下:
a、核心服務通常在獨立的進程 (Process) 裡執行。
b、必須提供 IBinder 接口,讓其它程序可以進行跨進程的綁定 (Binding) 和呼叫。
c、因為共享,所以必須確保多線程安全 (Thread-safe) 。
d、以 C++ 類別定義,誕生其對象,透過 SM 之協助,將該對象參考值傳給 IServiceManager::addService() 函數,就加入到 Binder Driver 裡瞭。
e、應用程序可透過 SM 之協助而遠距綁定該核心服務,此時 SM 會回傳 IBinder 接口給應用程序。
f、應用程序可透過 IBinder::transact() 函數來與核心服務互傳數據。

下面以具體實例講解一下具體的每個步驟如何實現完成

先說明一個測試例子的模塊結構:

serviceTestA 是一個普通的過程,提供兩個整數的剩法及除法運算
serviceTestB 是一個普通的過程,提供兩個整數的加法及減法運算
TestService 是一個測試進程的程序,主要驗證兩個服務進程的接口函數,其中的代碼可以
放在任何一個進程進行訪問調用

a、編寫服務進程

serviceTestA.h 頭文件定義:

#ifndef __SERVICE_TEST_A__
#define __SERVICE_TEST_A__

#include <utils/RefBase.h>
#include <binder/IInterface.h>
#include <binder/Parcel.h>
#include <utils/threads.h>

namespace android{
//繼承BBinder類,從而提供IBinder 接口
class serviceTestA:public BBinder
{
public:
      serviceTestA();
virtual ~serviceTestA();
static int instantiate(); //建立唯一類實例
virtual status_t onTransact(uint32_t, const Parcel&, Parcel*, uint32_t);

private:
// protected by mLock 多線程安全
               mutable Mutex mLock;
};
}

#endif /* __SERVICE_TEST_A__ */

serviceTestA.cpp 實現文件:
#include <cutils/log.h>
#include <cutils/properties.h>
#include <binder/IServiceManager.h>
#include <binder/IPCThreadState.h>
#include <serviceTestA/serviceTestA.h>

namespace android {

enum{
CALCULATE_MUL_NUM = 0,
CALCULATE_DIV_NUM ,
};

int serviceTestA::instantiate() {
LOGI("serviceTestA instantiate");

int r = defaultServiceManager()->addService(String16("service.TestA"),
new serviceTestA());
LOGI("serviceTestA r = %d/n", r);
return r;
}

serviceTestA::serviceTestA() {
LOGI("serviceTestA created");
}

serviceTestA::~serviceTestA(){
LOGI("serviceTestA destroyed");
}

status_t serviceTestA::onTransact(uint32_t code, const Parcel&data, Parcel*reply, uint32_t flags){
LOGI("serviceTestA::onTransact code = %d",code);
Mutex::Autolock _l(mLock);
switch(code){
case CALCULATE_MUL_NUM:{
int a = data.readInt32();
int b = data.readInt32();
int sum = a * b ;
LOGI("sum mul value = %d",sum);
reply->writeInt32(sum);
return NO_ERROR;
}break;
case CALCULATE_DIV_NUM:{
int a = data.readInt32();
int b = data.readInt32();
int sum = a / b ;
LOGI("sum p value = %d",sum);
reply->writeInt32(sum);
return NO_ERROR;
}break;
default:
return BBinder::onTransact(code, data, reply, flags);
}
return 0;
}
}

Android.mk 文件:
LOCAL_PATH:= $(call my-dir)
 
include $(CLEAR_VARS)
 
LOCAL_SRC_FILES:= serviceTestA.cpp
 
LOCAL_SHARED_LIBRARIES:= libutils libutils libbinder
 
LOCAL_C_INCLUDES := $(TOP)/frameworks/base/include

LOCAL_MODULE:= libServiceTestA
 
LOCAL_PRELINK_MODULE:= false
 
include $(BUILD_SHARED_LIBRARY)

這裡生成libServiceTestA動態庫,方例升級服務程序

 

編寫獨立的進程程序:

 

它的用途是:誕生一個 serviceTestA 類別之對象,然後將該對象參考存入 Binder Driver 裡。
#include <sys/types.h>
#include <unistd.h>
#include <cutils/log.h>
#include <binder/IServiceManager.h>
#include <binder/IPCThreadState.h>
#include <serviceTestA/serviceTestA.h>

using namespace android;

int main(int argc,char *argv[]){
sp<ProcessState> proc(ProcessState::self());
sp<IServiceManager> sm = defaultServiceManager();
LOGI("ServiceManager: %p", sm.get());
serviceTestA::instantiate(); // 這是重點。。。。
ProcessState::self()->startThreadPool();
IPCThreadState::self()->joinThreadPool();
return 0;
}

Android.mk 文件:
LOCAL_PATH:= $(call my-dir)
 
include $(CLEAR_VARS)
 
LOCAL_SRC_FILES:= main.cpp
 
LOCAL_SHARED_LIBRARIES:= libutils libServiceTestA
 
LOCAL_MODULE:= serviceTestA
 
include $(BUILD_EXECUTABLE)

www.aiwalls.com
這裡最重要的是調用:serviceTestA::instantiate();
其先執行到 new serviceTestA() ,就誕生一個 serviceTestA 類別之對象;
接著,呼叫 defaultServiceManager() 函數取得 SM 的 IServiceManager 接口;
再呼叫 IServiceManager::addService() 將該對象參考存入 Binder Driver 裡,並且同時存入
到ServiceManager中註冊並管理,如此其它進程才能通過ServiceManager::getService找到相應服務進程

以上代碼同理,serviceTestB服務進程也一樣的這樣建立,不再復述。

b、測試服務進程
testService.cpp編寫:
#include <cutils/log.h>
#include <cutils/properties.h>
#include <binder/IServiceManager.h>
#include <binder/IPCThreadState.h>
#include <serviceTestA/serviceTestA.h>
#include <serviceTestB/serviceTestB.h>

using namespace android;

enum{
CALCULATE_ADD_NUM = 0,
CALCULATE_SUB_NUM ,
};

enum{
CALCULATE_MUL_NUM = 0,
CALCULATE_DIV_NUM ,
};

int main(int argc,char *argv[]){
sp<IBinder> TestAbinder;
sp<IBinder> TestBbinder;
Parcel data, reply;
int sum=0;

LOGI("testService main is call…");

sp<IServiceManager> sm = defaultServiceManager();

while(1){
TestAbinder = sm->getService(String16("service.TestA"));
LOGE("TestA::getAddService %p/n",sm.get());
if (TestAbinder == 0) {
LOGE("TestAService not published, waiting…");
usleep(1000000);
continue;
}
else{
LOGI("TestA::getAddService success…");
break;
}
}

while(1){
TestBbinder = sm->getService(String16("service.TestB"));
LOGE("TestB::getAddService %p/n",sm.get());
if (TestBbinder == 0) {
LOGE("TestBService not published, waiting…");
usleep(1000000);
continue;
}
else{
LOGI("TestB::getAddService success…");
break;
}
}

//測試兩個service中的函數
data.writeInt32(1000);
data.writeInt32(200);
LOGI("BpAddService::create remote()->transact()/n");
TestAbinder->transact(CALCULATE_MUL_NUM,data,&reply);
sum = reply.readInt32();
LOGI("CALCULATE_ADD_NUM value = %d",sum);

data.writeInt32(1000);
data.writeInt32(200);
LOGI("BpAddService::create remote()->transact()/n");
TestAbinder->transact(CALCULATE_DIV_NUM,data,&reply);
sum = reply.readInt32();
LOGI("CALCULATE_SUB_NUM value = %d",sum);

data.writeInt32(1000);
data.writeInt32(200);
LOGI("BpAddService::create remote()->transact()/n");
TestBbinder->transact(CALCULATE_ADD_NUM,data,&reply);
sum = reply.readInt32();
LOGI("CALCULATE_MUL_NUM value = %d",sum);

data.writeInt32(1000);
data.writeInt32(200);
LOGI("BpAddService::create remote()->transact()/n");
TestBbinder->transact(CALCULATE_SUB_NUM,data,&reply);
sum = reply.readInt32();
LOGI("CALCULATE_DIV_NUM value = %d",sum);

return 0;
}

這裡最重要的就是通過defaultServiceManager得到默認的sm,然後通過getService得到sp<IBinder>對象,即可操作相應服務進程的接口函數,整個過程還是相當清晰的。

 

最後附上測試的結果打印:

# ./TestService
./TestService
# logcat
logcat
——— beginning of /dev/log/main
I/        ( 1379): testService main is call…
E/        ( 1379): TestA::getAddService 0xa680/n
I/        ( 1379): TestA::getAddService success…
E/        ( 1379): TestB::getAddService 0xa680/n
I/        ( 1379): TestB::getAddService success…
I/        ( 1379): BpAddService::create remote()->transact()/n
I/        ( 1371): serviceTestA::onTransact code = 0
I/        ( 1371): sum mul value = 200000
I/        ( 1379): CALCULATE_MUL_NUM value = 200000
I/        ( 1379): BpAddService::create remote()->transact()/n
I/        ( 1371): serviceTestA::onTransact code = 1
I/        ( 1371): sum p value = 5
I/        ( 1379): CALCULATE_DIV_NUM value = 5
I/        ( 1379): BpAddService::create remote()->transact()/n
I/        ( 1374): serviceTestB::onTransact code = 0
I/        ( 1374): sum add value = 1200
I/        ( 1379): CALCULATE_ADD_NUM value = 1200
I/        ( 1379): BpAddService::create remote()->transact()/n
I/        ( 1374): serviceTestB::onTransact code = 1
I/        ( 1374): sum sub value = 800
I/        ( 1379): CALCULATE_SUB_NUM value = 800
結果表明完全正確

 

摘自 andyhuabing的專欄

發佈留言