我們繼續(xù)學(xué)習(xí)D-Bus，參考http://dbus./doc/dbus/libdbus-tutorial.html ，從底層，即libdbus學(xué)習(xí)如何發(fā)送signal，以及如何監(jiān)聽signal。signal在D-Bus的Daemon中廣播，為了提高效率，只發(fā)送給向daemon注冊要求該singal的對象。

 

　　這個(gè)圖我畫了很久，我希望能夠比較形象地說明D-Bus中各種概念的關(guān)系。對于程序，第一步需要將應(yīng)用和D-Bus后臺建立連接，也就是和System D-Bus daemon或者Session D-Bus daemon建立連接。一旦建立，daemon會給這條連接分配一個(gè)名字，這個(gè)名字在system或者session的生命周期是唯一的，即unique connection name，為了方便記憶，可以為這條連接分配一個(gè)便于記憶的well-known name。對于信號方式，分配這個(gè)名字不是必須的（在method_call中是需要的，我們在下一次學(xué)習(xí)中談到），因?yàn)樵谛盘柕谋O(jiān)聽中秩序給出Interface的名字和信號名稱，在下面的例子中，可以將相關(guān)的代碼屏蔽掉，不影響運(yùn)行，但是通常我們都這樣處理，尤其在復(fù)雜的程序中。在我們的例子中，定義這個(gè)BUS name為test.singal.source。當(dāng)然一個(gè)好的名字，為了避免于其他應(yīng)用重復(fù)，應(yīng)當(dāng)使用com.mycompany.myfunction之類的名字。 ，而interface的名字，一般前面和connection的BUS name一直。

發(fā)送方的小程序

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <dbus/dbus-glib.h>
#include <dbus/dbus.h>
#include <unistd.h>

int send_a_signal( char * sigvalue)
{
    DBusError err;
    DBusConnection * connection;
    DBusMessage * msg;
    DBusMessageIter arg;
    dbus_uint32_t  serial = 0;
    int ret;

    //步驟1:建立與D-Bus后臺的連接
    /* initialise the erroes */
    dbus_error_init(&err);
    /* Connect to Bus*/
    connection = dbus_bus_get(DBUS_BUS_SESSION , &err );
    if(dbus_error_is_set(&err)){
        fprintf(stderr,"Connection Err : %s\n",err.message);
        dbus_error_free(&err);
    }
    if(connection == NULL)
        return -1;

    //步驟2:給連接名分配一個(gè)well-known的名字作為Bus name，這個(gè)步驟不是必須的，可以用if 0來注釋著一段代碼，我們可以用這個(gè)名字來檢查，是否已經(jīng)開啟了這個(gè)應(yīng)用的另外的進(jìn)程。
#if 1
    ret = dbus_bus_request_name(connection,"test.singal.source",DBUS_NAME_FLAG_REPLACE_EXISTING,&err );
    if(dbus_error_is_set(&err)){
        fprintf(stderr,"Name Err : %s\n",err.message);
        dbus_error_free(&err);
    }
    if(ret != DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER)
        return -1;
#endif

    //步驟3:發(fā)送一個(gè)信號
    //根據(jù)圖，我們給出這個(gè)信號的路徑（即可以指向?qū)ο螅涌?，以及信號名，?chuàng)建一個(gè)Message
    if((msg = dbus_message_new_signal ("/test/signal/Object","test.signal.Type","Test")) == NULL){
        fprintf(stderr,"Message NULL\n");
        return -1;
    }
    //給這個(gè)信號（messge）具體的內(nèi)容
    dbus_message_iter_init_append (msg,&arg);
    if(!dbus_message_iter_append_basic (&arg,DBUS_TYPE_STRING,&sigvalue)){
        fprintf(stderr,"Out Of Memory!\n");
        return -1;
    }

    //步驟4: 將信號從連接中發(fā)送
    if( !dbus_connection_send (connection,msg,&serial)){
        fprintf(stderr,"Out of Memory!\n");
        return -1;
    }
    dbus_connection_flush (connection);
    printf("Signal Send\n");

    //步驟5: 釋放相關(guān)的分配的內(nèi)存。
    dbus_message_unref(msg );
    return 0;
}

int main( int argc , char ** argv){
    send_a_signal("Hello,world!");
    return 0;
}

希望接收該信號的的小程序例子

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <dbus/dbus-glib.h>
#include <dbus/dbus.h>
#include <unistd.h>

void listen_signal()
{
    DBusMessage * msg;
    DBusMessageIter arg;
    DBusConnection * connection;
    DBusError err;
    int ret;
    char * sigvalue;

     //步驟1:建立與D-Bus后臺的連接
    dbus_error_init(&err);
    connection = dbus_bus_get(DBUS_BUS_SESSION, &err);
    if(dbus_error_is_set(&err)){
        fprintf(stderr,"Connection Error %s\n",err.message);
        dbus_error_free(&err);
    }
    if(connection == NULL)
        return;

   //步驟2:給連接名分配一個(gè)可記憶名字test.singal.dest作為Bus name，這個(gè)步驟不是必須的,但推薦這樣處理
    ret = dbus_bus_request_name(connection,"test.singal.dest",DBUS_NAME_FLAG_REPLACE_EXISTING,&err);
    if(dbus_error_is_set(&err)){
        fprintf(stderr,"Name Error %s\n",err.message);
        dbus_error_free(&err);
    }
    if(ret != DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER)
        return;

    //步驟3:通知D-Bus daemon，希望監(jiān)聽來行接口test.signal.Type的信號
    dbus_bus_add_match(connection,"type='signal',interface='test.signal.Type'",&err);
    //實(shí)際需要發(fā)送東西給daemon來通知希望監(jiān)聽的內(nèi)容，所以需要flush
    dbus_connection_flush(connection);
    if(dbus_error_is_set(&err)){
        fprintf(stderr,"Match Error %s\n",err.message);
        dbus_error_free(&err);
    }
   
    //步驟4:在循環(huán)中監(jiān)聽，每隔開1秒，就去試圖自己的連接中獲取這個(gè)信號。這里給出的是中連接中獲取任何消息的方式，所以獲取后去檢查一下這個(gè)消息是否我們期望的信號，并獲取內(nèi)容。我們也可以通過這個(gè)方式來獲取method call消息。
    while(1){
        dbus_connection_read_write(connection,0);
        msg = dbus_connection_pop_message (connection);
        if(msg == NULL){
            sleep(1);
            continue;
        }
   
        if(dbus_message_is_signal(msg,"test.signal.Type","Test") ){
            if(!dbus_message_iter_init(msg,&arg) )
                fprintf(stderr,"Message Has no Param");
            else if(dbus_message_iter_get_arg_type(&arg) != DBUS_TYPE_STRING)
                g_printerr("Param is not string");
            else
                dbus_message_iter_get_basic(&arg,&sigvalue);
            printf("Got Singal with value : %s\n",sigvalue);
        }
        dbus_message_unref(msg);
    }//End of while
       
}

int main( int argc , char ** argv){
    listen_signal();
    return 0;
}

本文來自CSDN博客，轉(zhuǎn)載請標(biāo)明出處：http://blog.csdn.net/flowingflying/archive/2010/04/04/5449995.aspx