gdbus-demo/gdbus-cpp-demo/server/server.cpp

#include "server.h"

// 进程主循环函数
static void* start_main_loop(void *) {
    g_main_loop_run(main_loop); // 进入主循环
    return nullptr;
}

// 接收请求
static gboolean receive_text(ComGdbusDemo *object, GDBusMethodInvocation *invocation, const gchar *input, gpointer) {
    g_print("Receive -> %s\n", input);
    com_gdbus_demo_complete_show_data(object, invocation, "Get it"); // 返回数据
    sleep(2); // 模拟处理
    com_gdbus_demo_emit_complete(skeleton, "Process complete"); // 发送完成信号
    g_print("Complete signal sent.\n");
    return true; // 请求处理成功
}

// 如果无法建立与总线的连接会调用 name_lost_handler()
// 如果无法获取 bus-name，会先调用 bus_acquired_handler()，再调用 name_lost_handler()
// 如果已获得 bus-name ，会先调用 bus_acquired_handler()，再调用 name_acquired_handler()

// GDBus Acquired 回调
static void gdbus_acquired_callback(GDBusConnection *callback_connection, const gchar *, gpointer) {
    GError *error = nullptr;
    skeleton = com_gdbus_demo_skeleton_new();
    g_signal_connect(skeleton, "handle-show-data", G_CALLBACK(receive_text), NULL); // 设置对象接口
    g_dbus_interface_skeleton_export(G_DBUS_INTERFACE_SKELETON(skeleton), callback_connection,
                                     "/com/gdbus/object", &error); // 绑定到对象上
    if (error != nullptr) {
        g_print("Failed to export object: %s.\n", error->message);
        g_error_free(error);
        g_main_loop_quit(main_loop); // 退出主循环
        return;
    }
    g_print("Skeleton load successfully.\n");
}

// GDBus Name Acquired 回调
static void gdbus_name_acquired_callback(GDBusConnection *, const gchar *, gpointer) {
    g_print("Acquired bus-name success.\n");
}

// GDBus Name Lost 回调
static void gdbus_name_lost_callback(GDBusConnection *, const gchar *, gpointer) {
    g_print("Name lost error: Failed to get bus-name.\n");
    g_main_loop_quit(main_loop); // 退出主循环
}

// 初始化DBus连接
void init_dbus_server() {
    main_loop = g_main_loop_new(nullptr, false); // 创建主循环对象
    // 申请 bus-name 并将结果给到回调函数
    g_bus_own_name(G_BUS_TYPE_SESSION, "com.gdbus.demo", G_BUS_NAME_OWNER_FLAGS_NONE,
                   &gdbus_acquired_callback, &gdbus_name_acquired_callback,
                   &gdbus_name_lost_callback, nullptr, nullptr);
}

int main() {
    pthread_t tid;
    init_dbus_server(); // 初始化DBus
    pthread_create(&tid, nullptr, start_main_loop, nullptr); // 创建线程 进入主循环
    for (;;) {} // 死循环
}