关于DBus （signal）的使用
作者：互联网
**
DBUS
**
DBUS有四种类型的消息：
1.方法调用（method call） 在对象上执行一个方法
2.方法返回（method return）返回方法执行的结果
3.错误（error）调用方法产生的异常
4.信号（signal）通知指定的信号发生了，可以想象成“事件”。
客户端：
发送信号的流程：
1.建立与DBus后台的连接
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-knmown的名字作为Bus name
**
//步骤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_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);
6.主函数实现
// 客户端代码
#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
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;
}
服务端：
建立一个dbus连接之后，为这个dbus连接起名，为我们将要进行的消息循环添加匹配条件(就是通过信号名和信号接口名来进行匹配控制的) – dbus_bus_add_match()。我们进入等待循环后，只需要对信号名，信号接口名进行判断就可以分别处理各种信号了。在各个处理分支上。我们 可以分离出消息中的参数。对参数类型进行判断和其他的处理。
1.获取连接
connection = dbus_bus_get(DBUS_BUS_SESSION, &err);
if(dbus_error_is_set(&err))
{
fprintf(stderr,"Connection error %s\n",err.message);
}
if(NULL == connection)
{
return;
}
2.设置感兴趣消息
dbus_bus_add_match(connection,"type='signal',interface='test.signal.type'",&err);
dbus_connection_flush(connection);
if(dbus_error_is_set(&err))
{
fprintf(stderr,"Match Error%s\n",err.message);
dbus_error_free(&err);
}
3.等待消息：
while(1)
{
dbus_connection_read_write(connection,0);
msg = dbus_connection_pop_message(connection);
if(NULL == msg)
{
sleep(1);
continue;
}
if(dbus_message_is_signal(msg,"test.signal.type","Test"))
{
if(!dbus_message_iter_init(msg,&arg))
{
fprintf(stderr,"MessageHas no pragrom!\n");
}else if(dbus_message_iter_get_arg_type(&arg) != DBUS_TYPE_STRING)
{
fprintf(stderr,"Param isnot string!\n");
}else
{
dbus_message_iter_get_arg_basic(&arg,&sigvalue);
printf("Recetive Signal Value:%s\n",sigvalue);
}
}
dbus_message_unref(msg);
}
}
4.服务段代码：
// 服务端代码
#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(&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，这个步骤不是必须的,但推荐这样处理
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,"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;
}
标签：signal,err,dbus,connection,关于,error,message,DBus 来源： https://blog.csdn.net/qq_48089436/article/details/115080544