一、什么是 DBus？

D-Bus是一个为应用程序间通信的消息总线系统, 用于进程之间的通信。

1.1 三层架构

1、函数库libdbus ------>>>>> 用于两个应用程序互相联系和交互消息。

2、基于 libdbus 构造的消息总线守护进程，可同时与多个应用程序相连，并能把来自一个应用程序的消息路由到0或者多个其他程序。

3、基于特定应用程序框架的封装库或捆绑（wrapper libraries or bindings ）。

1.2 高层功能

• 结构化的名字空间
• 独立于架构的数据格式
• 支持消息中的大部分通用数据元素
• 带有异常处理的通用远程调用接口
• 支持广播类型的通信

1.3 Bus daemon 总线守护

基于 libdbus 构造的消息总线守护进程，可同时与多个应用程序相连，并能把来自一个应用程序的消息路由到0或者多个其他程序。

从一个进程传递消息给另外一个进程，如果有很多 applications 链接到这个通道上，这个 daemon进程就会把消息转发给这些链接的所有程序。

DBus 是点对点通信，，经过 daemon 抽象后， 并由他寻址和发送消息，每个进程不关心消息发给哪个进程。

发送消息的过程：

第一步：创建和发送消息给后台 bus daemon 进程，这个过程中会有两个上下文的切换。

第二步：bus daemon进程会处理该消息，并转发给目标进程，引起上下文的切换目标程序接收到消息。

传递大量的数据，D-Bus不建议，建议共享内存。

二、 介绍

2.1 通讯逻辑图

 

在通讯中分为三种角色，分别为：client、bus daemon 和 server。通讯的过程主要分 client 和 server ：

1. client 需先连接到总线（dbus_bus_get），其次构造消息（dbus_message_new_signal），然后发送消息（dbus_connection_send）到后台进程。后台进程接收消息，然后根据消息类型对消息进行不同处理（bus_dispatch_matches）。
2. server 接收消息前需要连接到总线，并告知总线需要的消息类型（dbus_bus_add_match），然后等待接收消息（dbus_connection_pop_message）。server 收到总线转发的消息时会根据消息类型，做不同的处理。

2.2 使用案例

2.2.1 clent 发送数据

int main ()

{

GMainLoop *loop; // 定义一个事件循环对象的指针

DBusConnection *bus; // 定义总线连接对象的指针

DBusError error; // 定义D-Bus错误消息对象

loop = g_main_loop_new(NULL, FALSE); // 创建新事件循环对象

dbus_error_init (&error); // 将错误消息对象连接到D-Bus

// 错误消息对象

bus = dbus_bus_get(DBUS_BUS_SESSION, &error);// 连接到总线

if (!bus) {

g_warning("连接到D-Bus失败: %s", error.message); //判断是否连接错误

dbus_error_free(&error); //清除错误消息

return 1;

}

dbus_connection_setup_with_g_main(bus, NULL); // 将总线设为接收GLib事件循环

g_timeout_add(1000, (GSourceFunc)send_ding, bus);

// 每隔1000ms调用一次send_ding()函数

// 将总线指针作为参数

g_main_loop_run(loop); // 启动事件循环

return 0;

}

static gboolean send_ding(DBusConnection *bus) // 定义发送消息函数的细节

{

DBusMessage *message; // 创建消息对象指针

message = dbus_message_new_signal("/com/burtonini/dbus/ding",

"com.burtonini.dbus.Signal",

"ding"); // 创建消息对象并标识路径

dbus_message_append_args(message,

DBUS_TYPE_STRING, "ding!",

DBUS_TYPE_INVALID); //将字符串Ding!定义为消息

dbus_connection_send(bus, message, NULL); // 发送该消息

dbus_message_unref(message); // 释放消息对象

g_print("ding!\n"); // 该函数等同与标准输入输出

return TRUE;

}

2.2.2 server 接收数据

int main()

{

GMainLoop *loop; // 定义一个事件循环对象的指针

DBusConnection *bus; // 定义总线连接对象的指针

DBusError error; // 定义D-Bus错误消息对象

loop = g_main_loop_new(NULL, FALSE); // 创建新事件循环对象

dbus_error_init(&error); // 将错误消息对象连接到D-Bus

bus = dbus_bus_get(DBUS_BUS_SESSION, &error); // 连接到总线

if (!bus) { // 判断是否连接错误

g_warning("连接到D-Bus失败: %s", error.message);

dbus_error_free(&error); // 清除错误消息

return 1;

}

dbus_connection_setup_with_g_main(bus, NULL);// 将总线设为接收GLib事件循环

dbus_bus_add_match(bus, "type='signal',interface

='com.burtonini.dbus.Signal'"); // 定义匹配器

dbus_connection_add_filter(bus, signal_filter, loop, NULL); // 调用函数接收消息

g_main_loop_run(loop); // 启动事件循环

return 0;

}

// 定义接收消息函数的细节

static DBusHandlerResult signal_filter(DBusConnection *connection, DBusMessage *message, void *user_data)

{

GMainLoop *loop = user_data; // 定义事件循环对象的指针，并与主函数中的同步

if (dbus_message_is_signal(message, DBUS_INTERFACE_ORG_FREEDESKTOP_LOCAL,

"Disconnected")) // 接收连接成功消息，判断是否连接失败

{

g_main_loop_quit (loop); // 退出主循环

return DBUS_HANDLER_RESULT_HANDLED;

}

// 指定消息对象路径，判断是否成功

if (dbus_message_is_signal(message, "com.burtonini.dbus.Signal",

"Ping"))

{

DBusError error; // 定义错误对象

char *s;

dbus_error_init(&error); // 将错误消息对象连接到D-Bus错误

if (dbus_message_get_args(message, &error, DBUS_TYPE_STRING, &s,

DBUS_TYPE_INVALID)) // 接收消息，并判断是否有错误

{

g_print("接收到的消息是: %s\n", s); // 输出接收到的消息

dbus_free (s); // 清除该消息

}

else

{

// 有错误时执行下列语句

g_print("消息已收到，但有错误提示: %s\n", error.message);

dbus_error_free (&error);

}

return DBUS_HANDLER_RESULT_HANDLED;

}

return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;

}

API

void dbus_error_init(DBusError *error);

目的：

参数：

[in]

[out]

过程：

DBusConnection *dbus_bus_get(DBusBusType type, DBusError *error);

目的：

参数：

[in]

[out]

过程：

void dbus_connection_setup_with_g_main (DBusConnection *connection,

GMainContext *context);

目的：

参数：

[in]

[out]

过程：

void dbus_bus_add_match(DBusConnection *connection,

const char *rule,

DBusError *error);

目的：

参数：

[in]

[out]

过程：

dbus_bool_t dbus_connection_add_filter(DBusConnection *connection,

DBusHandleMessageFunction function,

void *user_data,

DBusFreeFunction free_data_function);

目的：

参数：

[in]

[out]

过程：

dbus_bool_t dbus_message_is_signal(DBusMessage *message,

const char *interface,

const char *signal_name);

目的：

参数：

[in]

[out]

过程：

dbus_bool_t dbus_message_get_args(DBusMessage *message,

DBusError *error,

int first_arg_type,

...);

目的：

参数：

[in]

[out]

过程：

DBusMessage* dbus_message_new_signal(const char *path,

const char *interface,

const char *name);

目的：

参数：

[in]

[out]

过程：

dbus_bool_t dbus_message_append_args(DBusMessage *message,

int first_arg_type,

...);

目的：

参数：

[in]

[out]

过程：

dbus_bool_t dbus_connection_send (DBusConnection *connection,

DBusMessage *message,

dbus_uint32_t *client_serial);

目的：

参数：

[in]

[out]

过程：

void dbus_message_unref(DBusMessage *message);

目的：

参数：

[in]

[out]

过程：