linux D-Bus学习第一天：一次简单的信号通讯

// 服务端代码
#include <stdio.h>
#include <stdlib.h>
#include <string.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(DBusError *error)  初始化DBusError结构。
　　　//dbus_bus_get(DBusBusType type, DBusError *error) 连接到一个总线守护进程并向其注册客户端。
　　 //dbus_error_is_set(const DBusError *error) 判断是否有错误
　　 //dbus_error_free(DBusError *error) 释放DBusError
 
    dbus_error_init(&err);
    connection =dbus_bus_get(DBUS_BUS_SESSION, &err);
    if(dbus_error_is_set(&err)){
        fprintf(stderr,"ConnectionError %s\n",err.message);
        dbus_error_free(&err);
    }
    if(connection == NULL)
        return;

   //步骤2:给连接名分配一个可记忆名字test.singal.dest作为Bus name，这个步骤不是必须的,但推荐这样处理
　　//dbus_bus_request_name(DBusConnection *connection,const char *name,unsigned int flags, DBusError *error) 通过调用总线上的RequestName方法，请求总线将给定的名称分配给该连接。

    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(DBusConnection *connection,const char *rule, DBusError *error) 添加匹配规则以匹配通过消息总线的消息，即向总线添加监听感兴趣的事件。
　　//dbus_connection_flush(DBusConnection *connection) 阻塞并等待消息发送出去
    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消息。
　　//dbus_connection_read_write(DBusConnection *connection,int timeout_milliseconds) 阻塞函数，当产生读取或写入请求时阻塞会结束
　　//dbus_connection_pop_message(DBusConnection *connection)  返回传入消息队列中接收到的第一条消息，并将其从队列中删除

    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,"MessageHas no Param");
            else if(dbus_message_iter_get_arg_type(&arg)!= DBUS_TYPE_STRING)
                fprintf(stderr,"Param isnot string");
            else
                dbus_message_iter_get_basic(&arg,&sigvalue);
            printf("Recetive Singal Value : %s\n",sigvalue);
        }
        dbus_message_unref(msg);
    }//End of while

}
int main(void){

    printf("------Start Listen_signal!-------\n");
    listen_signal();
    return 0;
}

// 客户端代码
#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;

    dbus_error_init(&err);

    //步骤1:建立与D-Bus后台的连接
    //
    connection =dbus_bus_get(DBUS_BUS_SESSION ,&err );
    if(dbus_error_is_set(&err)){
        fprintf(stderr,"ConnectionErr : %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
　　//在Dbus中对象的命名也有要求，虽然没有强制要求但建议命名方式是以路径的方式命名，主要目的是为了区分模块

    if((msg =dbus_message_new_signal("/test/signal/Object","test.signal.Type","Test"))== NULL){
        fprintf(stderr,"MessageNULL\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 OfMemory!\n");
        return -1;
    }

    printf("Signal Send: %s\n",sigvalue);
    //步骤4: 将信号从连接中发送
    if( !dbus_connection_send(connection,msg,&serial)){
        fprintf(stderr,"Out of Memory!\n");
        return -1;
    }
    dbus_connection_flush(connection);
    printf("--------Success Signal Send----------\n");

   //步骤5: 释放相关的分配的内存。
    dbus_message_unref(msg );
    return 0;
}

int main(void)
{
    printf("------Start Send_a_signal!-------\n");
    send_a_signal("hello ");
    return 0;
}