Windows DBus如何传送和接收数据

69 阅读 0 评论 46 点赞

我是靠谱客的博主糟糕紫菜，最近开发中收集的这篇文章主要介绍Windows DBus如何传送和接收数据，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

DBus是进程间通信的工具。网上的资料不太多，大都又是基于GLib或python的。在windows下如果要用纯c/c++语言，似乎只能用原始的DBus库来编写程序。倘若不亲自写写，还真不知道到底是怎样的。

DBus的数据都要绑定在消息上：
消息： DBusMessage
数据： DBusMessageIter
从数据结构的命名上看，与其称之为消息的数据，不如称为消息数据的迭代器。
事实上其数据的操作过程，就是个迭代过程。

I 传输单独一个变量
如bool类型，有：

 
 DBusMessage *msg;                      // DBus消息
DBusMessageIter datatoSentIter;       // DBus数据迭代器
dbus_bool_t singleData = true;        // DBus的内建bool型

// 每条语句都需要返回值bool判断是否成功，为方便清晰略去
dbus_message_iter_init_append(msg, &datatoSentIter);    // 将迭代器绑定至消息

dbus_message_iter_append_basic(&datatoSentIter, DBUS_TYPE_BOOLEAN, &singleData);

// TODO: 向连接发送并flush

以上是发送，接收此单个bool数据也很简单：

 
 DBusMessageIter dataRecievedIter;       // 接收数据迭代器
dbus_bool_t singleData;                 // 保存传送过来的bool变量

dbus_message_iter_init(&msg, &dataRecievedIter);   // 生成msg消息的数据迭代器

if (dbus_message_iter_get_arg_type(&dataRecievedIter) == DBUS_TYPE_BOOLEAN)
{
    dbus_message_iter_get_basic(&dataRecievedIter, &singleData);
}
 

II 传输数个变量或数组
如传输一个bool变量，一个char*字符串和一个int数组
对于发送有：

 
 DBusMessage msg;
DBusMessageIter datatoSendIter;

dbus_bool_t boolArg = true;             // 要传送的bool变量
char strArg[] = "I am a string";        // 要传送的字符串
int *intArrayArg = GetIntArray();       // 要传送的int数组，GetIntArray()给intArrayArg初始化赋值
 

由于要传输的数据包含这三种数据类型，该数据实际上是一个由这三组数据组成的结构
在Windows DBus中需以专门的代码来处理

 
 DBusMessageIter subStructIter;

dbus_message_iter_open_container(&msg, 
                                 DBUS_TYPE_STRUCT,    // 开启子迭代的类型
                                 NULL,
                                 &subStructIter);     // 要被初始化为子迭代的迭代器

// 开启后关闭前对子迭代的操作有效
dbus_message_iter_append_basic(&subStructIter, DBUS_TYPE_BOOLEAN, &boolArg);         // 将bool变量append为第一个

char *buff = strArg;           // 对于一些编译器，声名为char strArg[]的strArg无法通过DBus，故需要这一步
dbus_message_iter_append_basic(&subStructIter, DBUS_TYPE_STRING, &buff);            // 将字符串append为第二个
 

由于数组不是基本类型，无法用*_append_basic函数来append，需开启新的子迭代

 
 char buf[2];
buf[0] = DBUS_TYPE_INT;
buf[1] = '/0';

DBusMessageIter subArrayIter;
dbus_message_iter_open_container(&subStructIter,       // 从前一子迭代开启新的子迭代
                                 DBUS_TYPE_ARRAY,      // 开启的子迭代是数组
                                 buf,                  // 表示数组的数据类型，注意特殊的表示方法
                                 &subArrayIter);       // 初始化子迭代

int elementNum = GetIntArrayCount();                  // 获得int数组的元素个数
dbus_message_iter_append_fixed_array(&subArrayIter,
                                     DBUS_TYPE_INT,    // 数组元素数据类型
                                     &intArrayArg,     // 数组地址的地址
                                     elementNum);      // 数组元素个数
 

最后要关闭子迭代，实际上是将子迭代的数据加载到了父迭代器上

 
 dbus_message_iter_close_container(&subStructIter, &subArrayIter);
dbus_message_iter_close_container(&datatoSendIter, &subStructIter);

对于接收有：

 
 DBusMessageIter dataRecievedIter;

// 声明用于接受数据的变量
dbus_bool_t boolArg;
char *strArg;
int *intArrayArg;

dbus_message_iter_init(msg, &dataRecievedIter);   // 用msg数据初始化数据迭代器

// 对于迭代中的每一层，都需专门解开处理
DBusMessageIter subStructIter;
dbus_message_iter_recurse(&dataRecievedIter, &subStructIter); // 将迭代器中打包的数据解开给子迭代

// 以下每步都需判断数据类型，为清晰略去
dbus_message_iter_get_basic(&subStructIter，&boolArg);
dbus_message_iter_next(&subStructIter);          // 步进，相当于指针指向下个数据

dbus_message_iter_get_basic(&subStructIter, &strArg);
dbus_message_iter_next(&subStructIter);

DBusMessageIter subArrayIter;
dbus_message_iter_recurse(&subStructIter, &subArrayIter); //解开下层迭代

int elementNum;        
dbus_message_iter_get_fixed_array(&subArrayIter, &intArrayIter, &elementNum);   // 获得数组指针以及元素个数
 

由上代码可知，无论做否数据类型的判断，传输数据的格式发送与接收双方应该定义好。Linux上的DBus-GLib支持对于xml定义的解析自动生成头文件，方便的解决了这个问题。

对于传输数据的内存释放，除了传送的具体数据外，迭代器不需专门释放，但是消息需要解引用。

另外，对于成分十分复杂的数据，实际上可以事先定义一个足够大的结构，将所有要传输的数据都放在里面，比如：
typedef struct
{
    bool a;
    char str[3];
    ...
}LargeStruct;

然后用如下代码来发送：

 
 LargeStruct data;

// 初始化...
// ...

// 转换成BYTE数组append
BYTE *byteLargeStruct = (BYTE*)(&data);
dbus_message_iter_append_fixed_array(&iter,
                                     DBUS_TYPE_BYTE,
                                     buf,
                                     &byteLargeStruct,
                                     sizeof(LargeStruct));
 