1. 程式人生 > >D-Bus學習(五):Signal的收發小例子

D-Bus學習(五):Signal的收發小例子

  我們繼續學習D-Bus,參考http://dbus.freedesktop.org/doc/dbus/libdbus-tutorial.html ,從底層,即libdbus學習如何傳送signal,以及如何監聽signal。signal在D-Bus的Daemon中廣播,為了提高效率,只發送給向daemon註冊要求該singal的物件。

  這個圖我畫了很久,我希望能夠比較形象地說明D-Bus中各種概念的關係。對於程式,第一步需要將應用和D-Bus後臺建立連線,也就是和System D-Bus daemon或者Session D-Bus daemon建立連線。一旦建立,daemon會給這條連線分配一個名字,這個名字在system或者session的生命週期是唯一的,即unique connection name,為了方便記憶,可以為這條連線分配一個便於記憶的well-known name。對於訊號方式,分配這個名字不是必須的(在method_call中是需要的,我們在下一次學習中談到),因為在訊號的監聽中秩序給出Interface的名字和訊號名稱,在下面的例子中,可以將相關的程式碼遮蔽掉,不影響執行,但是通常我們都這樣處理,尤其在複雜的程式中。在我們的例子中,定義這個BUS name為test.singal.source。當然一個好的名字,為了避免於其他應用重複,應當使用com.mycompany.myfunction之類的名字。

,而interface的名字,一般前面和connection的BUS name一直。

傳送方的小程式

#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:給連線名分配一個well-known的名字作為Bus name,這個步驟不是必須的,可以用if 0來註釋著一段程式碼,我們可以用這個名字來檢查,是否已經開啟了這個應用的另外的程序。

#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:傳送一個訊號
    //根據圖,我們給出這個訊號的路徑(即可以指向物件),介面,以及訊號名,建立一個Message

    if((msg = dbus_message_new_signal ("/test/signal/Object","test.signal.Type","Test")) == NULL){
        fprintf(stderr,"Message NULL/n");
        return -1;
    }
    //給這個訊號(messge)具體的內容
    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: 將訊號從連線中傳送
    if( !dbus_connection_send (connection,msg,&serial)){
        fprintf(stderr,"Out of Memory!/n");
        return -1;
    }
    dbus_connection_flush (connection);
    printf("Signal Send/n");

    //步驟5: 釋放相關的分配的記憶體。
    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:給連線名分配一個可記憶名字test.singal.dest作為Bus name,這個步驟不是必須的,但推薦這樣處理
    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,希望監聽來行介面test.signal.Type的訊號
    dbus_bus_add_match(connection,"type='signal',interface='test.signal.Type'",&err);
    //實際需要傳送東西給daemon來通知希望監聽的內容,所以需要flush
    dbus_connection_flush(connection);
    if(dbus_error_is_set(&err)){
        fprintf(stderr,"Match Error %s/n",err.message);
        dbus_error_free(&err);
    }
   
    //步驟4:在迴圈中監聽,每隔開1秒,就去試圖自己的連線中獲取這個訊號。這裡給出的是中連線中獲取任何訊息的方式,所以獲取後去檢查一下這個訊息是否我們期望的訊號,並獲取內容。我們也可以通過這個方式來獲取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;
}