IPC之十六：D-Bus的标准接口、自省机制和服务接口的具体实现方法

2024-01-11 13:12
文章标签 实现 服务 接口 方法 bus 机制 ipc 自省 十六 具体 标准接口

本文主要是介绍IPC之十六：D-Bus的标准接口、自省机制和服务接口的具体实现方法，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

D-Bus的规范中提供了一系列的标准接口，绝大多数有D-Bus接口的系统调用都会实现这些标准接口，这些标准接口中包括D-Bus的自省(Introspection)机制，自省机制可以让我们通过一个标准接口了解一个D-Bus服务的各种方法的调用方法，本文将介绍D-Bus的这些标准接口及实现方式，同时也会介绍如何在D-Bus上提供自有服务，本文附有完整的实例和完整的源代码；本文实例在 Ubuntu 20.04 上编译测试通过，gcc版本号为：9.4.0；本文不适合 Linux 编程的初学者阅读。

1 D-Bus 基本概念

  • 在阅读本文前，建议先阅读有关 D-Bus 的其它文章，以便对 D-Bus 有个基本了解，本文将不再讨论以下文章已经介绍过的内容，这些文章包括：

    • IPC之十一：使用D-Bus实现客户端向服务端请求服务的实例
    • IPC之十二：使用libdbus在D-Bus上异步发送/接收信号的实例
    • IPC之十三：使用libdbus通过D-Bus请求系统调用实现域名解析的实例
    • IPC之十四：使用libdbus通过select()接收D-Bus消息的实例
    • IPC之十五：使用libdbus通过D-Bus请求系统调用实现任意DNS记录解析的实例

  • 在文章 《IPC之十三：使用libdbus通过D-Bus请求系统调用实现域名解析的实例》 中，我们介绍了 D-Bus 大多数的基本数据类型以及数组(ARRAY)和结构(STRUCT)；

  • 数组和结构在 D-Bus Specification 中被归类在容器类型(Container Type)中，容器类型中还有两个数据类型：VARIANT 和 DICT_ENTRY，本节将介绍这两种类型，其它数据类型的介绍请参考 《IPC之十三：使用libdbus通过D-Bus请求系统调用实现域名解析的实例》；

  • 容器类型：VARIANT

    • VARIANT 类型的编码是 ‘v’；
    • VARIANT 类型可以包含一个(只能一个)完整的类型，举例来说，可以是：“i”(整数)、“ai”(整数数组)、“(ii)”(两个整数组成的结构)，但是不能是 “ii”(两个整数)；
    • 在当输入或输出参数的数据类型不确定时，便可以使用 VARIANT 类型；

  • 容器类型：DICT_ENTRY

    • DICT_ENTRY 类型的编码为 ‘e’，实际应用中常以 “{}” 来表示一个 DICT_ENTRY 类型，和 STRUCT 类型用 “[]” 表示类似
    • DICT_ENTRY 类型其实就是 key-value 对，实际上就是一个由两个字段组成的结构(STRUCT)，其第一个字段必须是键(Key)，其类型必须是 D-Bus 的基本类型，不能是容器类型，第二个字段是键值(Value)，理论上可以是任意类型；

2 D-Bus 的标准接口

  • D-Bus Specification 中定义了一些标准接口(Standard Interface)，有 D-Bus 接口的系统调用都会实现这些标准接口，本节将介绍这些标准接口；

  • 接口：org.freedesktop.DBus.Peer

    • 这个接口下提供两个方法，Ping 和 GetMachineId，定义如下：
      org.freedesktop.DBus.Peer.Ping()
org.freedesktop.DBus.Peer.GetMachineId(out STRING machine_uuid)
    • 调用 Ping 方法没有任何参数，服务端也只需要回复一个空信息(没有参数)即可，不需要添加任何参数；
    • 调用 GetMachineId 方法也没有任何参数，服务端要回复一个字符串参数给客户端，这个字符串应该为当前电脑的 UUID，在 Linux 上，可以使用 /var/lib/dbus/machine-id 或者 /etc/machine-id 文件中的值；
    • 当使用 dbus_connection_register_object_path() 向 D-Bus 注册一个对象路径的消息处理程序时，这两个方法在 D-Bus 中会自动实现，无需自己编程实现；

  • 接口：org.freedesktop.DBus.Introspectable

    • 这个接口下只有一个方法：Introspect，定义如下：
      org.freedesktop.DBus.Introspectable.Introspect(out STRING xml_data)
    • 调用 Introspect 方法没有任何参数，服务端要返回一个 xml 的字符串，这个字符串定义了对象下所有实现的方法(Method)、属性(Property)和信号(Signal);
    • 这个方法就是 D-Bus 的内省(Introspection)机制，一个对象的实例在实现了这个接口后，客户调用这个接口可以了解这个对象中各个接口的调用方法，调用参数和返回参数；
    • 在 《IPC之十三：使用libdbus通过D-Bus请求系统调用实现域名解析的实例》 和 《IPC之十五：使用libdbus通过D-Bus请求系统调用实现任意DNS记录解析的实例》 都调用了 systemd-resolved 系统调用的 D-Bus 接口，下面命令调用了systemd-resolved 系统调用中内省(Introspection)接口，可以直观地看一下返回的 XML 数据；
      $ dbus-send --print-reply --system \
> --dest=org.freedesktop.resolve1 \
> /org/freedesktop/resolve1 \
> org.freedesktop.DBus.Introspectable.Introspect
    • dbus-send 是一个非常有用的 D-Bus 命令行工具，使用 man dbus-send 在线手册可以了解其详细使用方法；
    • 这条命令的含义是，在系统总线(--system)上请求一个接口上的方法，总线名称：org.freedesktop.resolve1(--dest)，对象路径：/org/freedesktop/resolve1，接口：org.freedesktop.DBus.Introspectable，方法：Introspect，注意，接口和方法用 “.” 连接；
    • --print-reply 表示需要打印服务端的回复信息；
    • 返回的数据是 XML 格式，在 D-Bus Specification 中，对格式有明确的描述，在刚刚执行的命令中，有两个曾经在前面的文章中使用过的接口，把对这两个方法的定义放在这里；
      <node>......<interface name="org.freedesktop.resolve1.Manager">......<method name="ResolveHostname"><arg type="i" direction="in"/><arg type="s" direction="in"/><arg type="i" direction="in"/><arg type="t" direction="in"/><arg type="a(iiay)" direction="out"/><arg type="s" direction="out"/><arg type="t" direction="out"/></method>......<method name="ResolveRecord"><arg type="i" direction="in"/><arg type="s" direction="in"/><arg type="q" direction="in"/><arg type="q" direction="in"/><arg type="t" direction="in"/><arg type="a(iqqay)" direction="out"/><arg type="t" direction="out"/></method>......</interface>......
</node>
    • 其实这个格式很容易理解，不需要更多的解释，“in” 表示输入参数，“out” 表示输出参数，type 后面的字母是 D-Bus 的数据类型定义，在文章 《IPC之十三：使用libdbus通过D-Bus请求系统调用实现域名解析的实例》 中有介绍；
    • 本文的实例中将实现该接口；

  • 接口：org.freedesktop.DBus.Properties

    • 这个接口下有三个方法：Get、Set 和 GetAll：

      org.freedesktop.DBus.Properties.Get(in STRING interface_name,in STRING property_name,out VARIANT value);
org.freedesktop.DBus.Properties.Set(in STRING interface_name,in STRING property_name,in VARIANT value);
org.freedesktop.DBus.Properties.GetAll(in STRING interface_name,out ARRAY of DICT_ENTRY<STRING,VARIANT> props);

    • 在一个对象实例中，每个接口下可以有一些属性(Properties/Attributes)，这些属性可以是只读的，也可以是可读/写的，这个接口用于操作这些属性；

    • 方法 Get 用于获取单个属性的值，输入参数 interface_name 表示接口名称，property_name表示属性名称，两个参数都是字符串，输出参数为属性值，由于并不清楚该属性值的数据类型，所以其输出参数的数据类型为 VARIANT；

    • 方法 Set 用于设置单个属性的值，这个方法其实就是 Get 方法的逆操作；

    • 方法 GetAll 可以获取某个接口中的所有属性的值，它的输入参数只有一个，interface_name，表示接口名称，因为并不知道会有多少个属性返回，所以输出参数 props 是一个数组，数组中是 DICT_ENTRY，其中的键值对表示属性名称和属性值；

    • 这个接口下还有一个信号：PropertiesChanged：

      org.freedesktop.DBus.Properties.PropertiesChanged(STRING interface_name,ARRAY of DICT_ENTRY<STRING, VARIANT> changed_properties,ARRAY<STRING> invalidated_properties);

    • 当一个或者多个属性发生变化时，可以发出这个信号通知连接的客户端；

    • interface_name 为接口名称，changed_properties 为一个 Key-Value 对的数组，每一组 Key-Value 记录着一个变化的属性名称和新的属性值，invalidated_properties 是一个字符串数组，记录已经无效的属性名称；

    • 本文的实例中将实现 Get 和 GetAll 两个方法

  • 接口：org.freedesktop.DBus.ObjectManager

    • 这个接口下有一个方法：GetManagedObjects
      org.freedesktop.DBus.ObjectManager.GetManagedObjects(out ARRAY of DICT_ENTRY<OBJPATH, ARRAY of DICT_ENTRY<STRING, ARRAY of DICT_ENTRY<STRING, VARIANT>>> objpath_interfaces_and_properties);
    • 这个方法没有输入参数，输出参数是整个 Objects 树；
    • 本文实例中并没有实现这个方法；

3 D-Bus 注册服务的基本方法

  • 在文章 《IPC之十一：使用D-Bus实现客户端向服务端请求服务的实例》 中的实例，已经可以在 D-Bus 上为客户端提供方法调用的服务，大致的流程如下：

    ......
while (dbus_connection_read_write_dispatch(conn, -1)) {DBusMessage *message;message = dbus_connection_pop_message(conn);if (message == NULL) {continue;}ret = dbus_message_get_type(message);if (ret != DBUS_MESSAGE_TYPE_METHOD_CALL) {dbus_message_unref(message);continue;}if (!dbus_message_is_method_call(message, INTERFACE_NAME, METHOD_NAME)) {print_dbus_error(&dbus_error, "Server: dbus_message_is_method_call");dbus_message_unref(message);continue;}// codes for providing the service......
}

  • 作为简单的范例，提供一种客户端调用服务端方法的服务当然是可以的，但是在 D-Bus 的编程规范中，发布一个服务应该向 D-Bus 注册一个对象路径(Object Path)的处理程序，其具体步骤如下：

    DBusHandlerResult server_message_handler(DBusConnection *conn, DBusMessage *message, void *data) {......
}
const DBusObjectPathVTable server_vtable = {.message_function = server_message_handler
};
int main(void) {DBusConnection *conn;DBusError err;dbus_error_init(&err);conn = dbus_bus_get(DBUS_BUS_SESSION, &err);dbus_bus_request_name(conn, SERVER_BUS_NAME, DBUS_NAME_FLAG_REPLACE_EXISTING , &err);// registers the objectif (!dbus_connection_register_object_path(conn, OBJECT_PATH_NAME, &server_vtable, NULL)) {printf("Failed to register an object pth.\n");exit(EXIT_FAILURE);}......return EXIT_SUCCESS;
}

  • 重点是 dbus_connection_register_object_path()，在以前的文章中没有介绍过，其定义如下：

    dbus_bool_t dbus_connection_register_object_path(DBusConnection *connection,const char *path,const DBusObjectPathVTable *vtable,void *user_data);
    • connection 是 dbus_bus_get() 获得的连接；
    • path 是要在 D-Bus 上注册的对象路径(Object Path)，连接(connection)和对象路径(object path)的概念在以前的文章里都有过介绍；
    • 参数 vtable 是这个函数的重点，这个参数的数据类型是 DBusObjectPathVTable，这是一个结构，其定义如下：
      struct DBusObjectPathVTable
{DBusObjectPathUnregisterFunction   unregister_function; /**< Function to unregister this handler */DBusObjectPathMessageFunction      message_function; /**< Function to handle messages */void (* dbus_internal_pad1) (void *); /**< Reserved for future expansion */void (* dbus_internal_pad2) (void *); /**< Reserved for future expansion */void (* dbus_internal_pad3) (void *); /**< Reserved for future expansion */void (* dbus_internal_pad4) (void *); /**< Reserved for future expansion */
};
    • 可以看到这个结构中有用的只有两个字段，message_function 和 unregister_function；
    • message_function 是一个消息处理函数，准备注册的对象下的消息将全部由这个函数处理，unregister_function 用于在取消注册时需要执行的函数，通常用于释放 message_function 可能占用的资源；
    • 在本文的实例中，我们并没有用到 unregister_function 这个字段，因为取消注册时，我们并不需要释放资源；
    • user_data 是在调用 message_function 时传递给这个函数的用户数据，可以是结构、数组或者字符串等任意数据；
    • 再看看 message_function 是如何定义的，message_function 的类型为 DBusObjectPathMessageFunction，其定义如下：
      typedef DBusHandlerResult(* DBusObjectPathMessageFunction) (DBusConnection *connection, DBusMessage *message, void *user_data);
    • 所以，这个函数要写成下面的样子：
      DBusHandlerResult server_message_handler(DBusConnection *connection, DBusMessage *message, void *user_data) {// Codes for processing messages......
}
    • 这里面的 user_data 就是在注册对象路径时定义的 user_data，D-Bus 在调用这个函数时会把 connection、收到的消息 message 以及 user_data 传递给函数；

  • 注册好对象路径的消息处理函数后，还需要在主程序中建立一个主循环才可以让这个处理函数发挥作用：

    while (dbus_connection_read_write_dispatch(conn, 100)) {// main loop......
}

  • 只有运行这个主循环，D-Bus 才会去分发消息，前面注册的消息处理程序才会被调用；

  • 以前文章实例中在调用 dbus_connection_read_write_dispatch()，都是以阻塞方式，即把超时时间设为 -1，上面的代码片段将超时设置为 100 ms，这是通常的做法，因为通常情况下，程序除了处理消息外还需要处理别的事务，在主循环里可以处理其它事务，而在 message_function 中处理消息；

4 实例

  • 源程序：dbus-service.c (点击文件名下载源程序，建议使用UTF-8字符集)演示了 D-Bus 标准接口和服务接口的实现方法；

  • 该程序实现了两个标准接口中的三个方法，加上 D-Bus 自动实现的两个方法，一共实现了三个标准接口下的五个方法，分别是：

    1. 标准接口 org.freedesktop.DBus.Introspectable 下的 Introspect 方法(D-bus 内省机制)；
    2. 标准接口 org.freedesktop.DBus.Properties 下的 Get 方法；
    3. 标准接口 org.freedesktop.DBus.Properties 下的 GetAll 方法；
    4. 标准接口 org.freedesktop.DBus.Peer 下的 Ping 方法；
    5. 标准接口 org.freedesktop.DBus.Peer 下的 GetMachineId 方法；

  • 该程序在自定义的接口(cn.whowin.TestInterface)上实现了三个方法：

    1. Hello 方法：请求参数为一个字符串，该方法在请求参数前面加上 "Hello "，并作为参数回复给客户端；
    2. EmitSignal 方法：收到请求后，该方法将广播一个 “OnEmitSignal” 信号给订阅该信号的客户端；
    3. quit 方法：收到该请求后，服务程序回复给客户端一个空消息(没有参数)，并主动退出程序；

  • 该程序在自定义的接口(cn.whowin.TestInterface)上实现了两个只读属性：Version 和 Author，可以使用标准接口的 Get 或 GetAll 获取属性值；

  • 该程序在自定义的接口(cn.whowin.TestInterface)上实现了一个信号：OnEmitSignal，在收到 EmitSignal 请求后将发送该信号；

  • 编译：gcc -Wall -g dbus-service.c -o dbus-service `pkg-config --libs --cflags dbus-1`

  • 有关 pkg-config --libs --cflags dbus-1 可以参阅文章 《IPC之十一：使用D-Bus实现客户端向服务端请求服务的实例》 中的简要说明；

  • 运行：./dbus-service

  • 测试方法如下，启动两个终端，一个终端上运行 dbus-service 程序，在另一个终端上输入如下命令可以测试本程序的各个方法和属性：

    • 标准接口测试：
      $ dbus-send --print-reply --session --dest=cn.whowin.TestDbus /cn/whowin/TestObject org.freedesktop.DBus.Introspectable.Introspect
$ dbus-send --print-reply --session --dest=cn.whowin.TestDbus /cn/whowin/TestObject org.freedesktop.DBus.Properties.Get string:"cn.whowin.TestInterface" string:"Version"
$ dbus-send --print-reply --session --dest=cn.whowin.TestDbus /cn/whowin/TestObject org.freedesktop.DBus.Properties.Get string:"cn.whowin.TestInterface" string:"Author"
$ dbus-send --print-reply --session --dest=cn.whowin.TestDbus /cn/whowin/TestObject org.freedesktop.DBus.Properties.GetAll
$ dbus-send --print-reply --session --dest=cn.whowin.TestDbus /cn/whowin/TestObject org.freedesktop.DBus.Peer.Ping
$ dbus-send --print-reply --session --dest=cn.whowin.TestDbus /cn/whowin/TestObject org.freedesktop.DBus.Peer.GetMachineId
    • 自定义接口测试：
      $ dbus-send --print-reply --session --dest=cn.whowin.TestDbus /cn/whowin/TestObject cn.whowin.TestInterface.Hello string:"whowin"
$ dbus-send --print-reply --session --dest=cn.whowin.TestDbus /cn/whowin/TestObject cn.whowin.TestInterface.EmitSignal
$ dbus-send --print-reply --session --dest=cn.whowin.TestDbus /cn/whowin/TestObject cn.whowin.TestInterface.Quit

  • 在自定义接口中，有一个 EmitSignal 方法，服务端收到该方法的请求时，会广播出一个 OnEmitSignal 信号，测试方法如下：

    • 在 1 号终端上运行服务端程序：$ ./dbus-service
    • 在 2 号终端上订阅自定义接口上的信号：
      $ dbus-monitor "type='signal',sender='cn.whowin.TestDbus',interface='cn.whowin.TestInterface'"
    • 在 3 号终端上请求服务端的 EmitSignal 方法：
      $ dbus-send --print-reply --session --dest=cn.whowin.TestDbus /cn/whowin/TestObject cn.whowin.TestInterface.EmitSignal
    • 在 2 号终端上可以看到收到了 OnEmitSignal 信号；

  • 使用 gdbus 命令测试内省(Introspection)机制

    $ gdbus introspect --session --dest cn.whowin.TestDbus --object-path /cn/whowin/TestObject

  • 标准接口测试运行动图：

    GIF of testing for gbus-service

欢迎订阅 『进程间通信专栏』

这篇关于IPC之十六：D-Bus的标准接口、自省机制和服务接口的具体实现方法的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/594478。

相关文章

Python依赖库的几种离线安装方法总结

Python依赖库的几种离线安装方法总结

《Python依赖库的几种离线安装方法总结》：本文主要介绍如何在Python中使用pip工具进行依赖库的安装和管理,包括如何导出和导入依赖包列表、如何下载和安装单个或多个库包及其依赖,以及如何指定... 目录前言一、如何copy一个python环境二、如何下载一个包及其依赖并安装三、如何导出requirem
阅读更多...
SpringBoot基于沙箱环境实现支付宝支付教程

SpringBoot基于沙箱环境实现支付宝支付教程

《SpringBoot基于沙箱环境实现支付宝支付教程》本文介绍了如何使用支付宝沙箱环境进行开发测试,包括沙箱环境的介绍、准备步骤、在SpringBoot项目中结合支付宝沙箱进行支付接口的实现与测试... 目录一、支付宝沙箱环境介绍二、沙箱环境准备2.1 注册入驻支付宝开放平台2.2 配置沙箱环境2.3 沙箱
阅读更多...
Nginx实现高并发的项目实践

Nginx实现高并发的项目实践

《Nginx实现高并发的项目实践》本文主要介绍了Nginx实现高并发的项目实践,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录使用最新稳定版本的Nginx合理配置工作进程(workers)配置工作进程连接数(worker_co
阅读更多...
python中列表list切分的实现

python中列表list切分的实现

《python中列表list切分的实现》列表是Python中最常用的数据结构之一,经常需要对列表进行切分操作,本文主要介绍了python中列表list切分的实现,文中通过示例代码介绍的非常详细,对大家... 目录一、列表切片的基本用法1.1 基本切片操作1.2 切片的负索引1.3 切片的省略二、列表切分的高
阅读更多...
基于Python实现一个PDF特殊字体提取工具

基于Python实现一个PDF特殊字体提取工具

《基于Python实现一个PDF特殊字体提取工具》在PDF文档处理场景中,我们常常需要针对特定格式的文本内容进行提取分析,本文介绍的PDF特殊字体提取器是一款基于Python开发的桌面应用程序感兴趣的... 目录一、应用背景与功能概述二、技术架构与核心组件2.1 技术选型2.2 系统架构三、核心功能实现解析
阅读更多...
MyBatis与其使用方法示例详解

MyBatis与其使用方法示例详解

《MyBatis与其使用方法示例详解》MyBatis是一个支持自定义SQL的持久层框架,通过XML文件实现SQL配置和数据映射,简化了JDBC代码的编写,本文给大家介绍MyBatis与其使用方法讲解,... 目录ORM缺优分析MyBATisMyBatis的工作流程MyBatis的基本使用环境准备MyBati
阅读更多...
使用Python实现表格字段智能去重

使用Python实现表格字段智能去重

《使用Python实现表格字段智能去重》在数据分析和处理过程中,数据清洗是一个至关重要的步骤,其中字段去重是一个常见且关键的任务,下面我们看看如何使用Python进行表格字段智能去重吧... 目录一、引言二、数据重复问题的常见场景与影响三、python在数据清洗中的优势四、基于Python的表格字段智能去重
阅读更多...
Spring AI集成DeepSeek实现流式输出的操作方法

Spring AI集成DeepSeek实现流式输出的操作方法

《SpringAI集成DeepSeek实现流式输出的操作方法》本文介绍了如何在SpringBoot中使用Sse（Server-SentEvents）技术实现流式输出,后端使用SpringMVC中的S... 目录一、后端代码二、前端代码三、运行项目小天有话说题外话参考资料前面一篇文章我们实现了《Spring
阅读更多...
Nginx中location实现多条件匹配的方法详解

Nginx中location实现多条件匹配的方法详解

《Nginx中location实现多条件匹配的方法详解》在Nginx中,location指令用于匹配请求的URI,虽然location本身是基于单一匹配规则的,但可以通过多种方式实现多个条件的匹配逻辑... 目录1. 概述2. 实现多条件匹配的方式2.1 使用多个 location 块2.2 使用正则表达式
阅读更多...
Nginx配置系统服务&设置环境变量方式

Nginx配置系统服务&设置环境变量方式

《Nginx配置系统服务&设置环境变量方式》本文介绍了如何将Nginx配置为系统服务并设置环境变量,以便更方便地对Nginx进行操作,通过配置系统服务,可以使用系统命令来启动、停止或重新加载Nginx... 目录1.Nginx操作问题2.配置系统服android务3.设置环境变量总结1.Nginx操作问题
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2