开始学习
第一个 D-Bus 程序
本文通过编写一个简单的 D-Bus 程序,带领读者正式进入 D-Bus 编程。
程序功能
我们知道,D-Bus 是一种高级的 IPC 通信机制,在 D-Bus 通信过程中,存在一个后台进程(BUS Daemon Process),后台进程和普通进程间信息交互是通过域套接字进行通信。大致的通信流程如下图所示:
在该示例中,进程 2 作为服务端,接收消息前需要连接到总线(dbus_bus_get),并告知总线自己希望得到的消息类型(dbus_bus_add_match),然后等待接收消息(dbus_connection_pop_message)。进程 2 收到总线转发的消息时会根据消息类型,做不同的处理(若是信号类型则不需要发送返回值给总线)。
进程 1 作为客户端,需先连接到总线(dbus_bus_get),然后构造消息(dbus_message_new_signal),再发送消息(dbus_connection_send)到后台进程。后台进程接收消息,然后根据消息类型对消息进行不同处理(bus_dispatch_matches)。
完整代码可在 GitHub 获取。
代码实现
dbus-server.c
/* 服务端代码 */
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <dbus/dbus.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:给连接名分配一个可记忆名字 getiot.singal.dest 作为 Bus name */
/* 这个步骤不是必须的,但推荐这样处理 */
ret =dbus_bus_request_name(connection, "getiot.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,希望监听来自接口 getiot.signal.Type 的信号 */
dbus_bus_add_match(connection, "type='signal',interface='getiot.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,"getiot.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;
}
dbus-client.c
/* 客户端代码 */
#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 1
ret = dbus_bus_request_name(connection, "getiot.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("/getiot/signal/Object", "getiot.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 world");
return 0;
}
Makefile
CFLAGS_DBUS = $(shell pkg-config --cflags --libs dbus-1)
CFLAGS_DBUS_GLIB = $(shell pkg-config --cflags --libs dbus-glib-1)
CFLAGS = -g -Wall -Werror
all: dbus-server dbus-client
dbus-server: dbus-server.c
gcc $< $(CFLAGS) $(CFLAGS_DBUS) $(CFLAGS_DBUS_GLIB) -o $@
dbus-client: dbus-client.c
gcc $< $(CFLAGS) $(CFLAGS_DBUS) $(CFLAGS_DBUS_GLIB) -o $@
clean:
rm -f dbus-server
rm -f dbus-client
.PHONY: all clean
编译运行
执行 make
命令编译 dbus-server.c 和 dbus-client.c 程序。
先运行服务端程序(dbus-server),再运行客户端程序(dbus-client),运行结果如下。
$ ./dbus-client
------Start Send_a_signal!-------
Signal Send: hello world
--------Success Signal Send----------
$ ./dbus-server
------Start Listen_signal!-------
Recetive Singal Value : hello world