Glib学习（29） gdbus 的peer to peer简单例子

怼烎@ 2022-12-27 14:00 173阅读 0赞

Peer2Peer模式：这种模式一般称之为点对点的星型结构，Client与Server之间是直接的Peer2Peer的连接，少了DBus Daemon的中转，因此性能较好。

server结构

//创建loop，不运行
    pLoop = g_main_loop_new(NULL, FALSE);
    //创建skeleton
    pSkeleton = rtplay_gdbus_example_skeleton_new();
    //获得guid
    _guid = g_dbus_generate_guid();
    //创建一个新的D-Bus服务器，该服务器侦听有效address中的第一个地址。
    _server = g_dbus_server_new_sync("unix:abstract=gdbus_server", G_DBUS_SERVER_FLAGS_AUTHENTICATION_ALLOW_ANONYMOUS,
                                         _guid, NULL, NULL, &_error);
    //注册new-connection，在客户端链接时被调用
    g_signal_connect(_server, "new-connection", G_CALLBACK(on_new_connection), NULL);
    //启动server。
    g_dbus_server_start(_server);
    //运行loop
    g_main_loop_run(pLoop);

on\_new\_connection函数

//获得_iface
    _iface = RTPLAY_GDBUS_EXAMPLE_GET_IFACE(pSkeleton);
    //注册方法，当客户端调用时会被执行
    _iface->handle_my_method1 = My_Method1;
    //导出interface，获得connection。
    g_dbus_interface_skeleton_export(G_DBUS_INTERFACE_SKELETON(pSkeleton), connection, RTPLAY_GDBUS_EXAMPLE_OBJECT_PATH,
                                     &_error);
    //注册closed，在客户端断开时被调用
    g_signal_connect(connection, "closed", G_CALLBACK(on_close_connection), user_data);

client结构

//创建loop，不运行
    pLoop = g_main_loop_new(NULL, FALSE);
    //同步连接并建立D-Bus客户端连接，以与由地址指定的端点交换D-Bus消息。
    _pGdbus_connection = g_dbus_connection_new_for_address_sync(
                "unix:abstract=gdbus_server", G_DBUS_CONNECTION_FLAGS_AUTHENTICATION_CLIENT, NULL, NULL, &_pError);
    //创建proxy，链接信号使用
    pProxy = rtplay_gdbus_example_proxy_new_sync(_pGdbus_connection, G_DBUS_PROXY_FLAGS_NONE, NULL,
                                                                RTPLAY_GDBUS_EXAMPLE_OBJECT_PATH, NULL, &_pError);
    //信号链接
    g_signal_connect(pProxy, "my-signal1", G_CALLBACK(My_Signal_1_Handler), NULL);
    //运行loop
    g_main_loop_run(pLoop);

安装教程

1.  mkdir build  
2.  cd build/  
3.  cmake ..  
4.  make

运行结果

$ ./server/SvrExample 
    InitDBusCommunicationServer: Server started.
    New thread created: Success
    run call in the server.
    Emit_My_Signal1() is called.
    Emit_My_Signal1() is called.
    Emit_My_Signal2() is called.
    Emit_My_Signal1() is called.
    Emit_My_Signal1() is called.
    Emit_My_Signal2() is called.
    Emit_My_Signal1() is called.
    Emit_My_Signal1() is called.
    Emit_My_Signal2() is called.
    Emit_My_Signal1() is called.
    Emit_My_Signal1() is called.
    Emit_My_Signal2() is called.
    A new connection [ 0x7f0c24004040 ] was created
    Emit_My_Signal1() is called.
    Server MyMethod1 call. Parameter: method1 synchronize call..
    Server MyMethod1 call. Parameter: method1 asynchronize call..
    Server MyMethod2 call. Parameter: in_arg1 = 12 , in_arg2 = 34.
    Server MyMethod2 call. Parameter: in_arg1 = 10 , in_arg2 = 21.
    Emit_My_Signal1() is called.
    Emit_My_Signal2() is called.
    Emit_My_Signal1() is called.
    Emit_My_Signal2() is called.
    Emit_My_Signal1() is called.
    Emit_My_Signal1() is called.
    Emit_My_Signal1() is called.
    Emit_My_Signal2() is called.
    The (null) connection [ 0x7f0c24004040 ] was closed!
    Emit_My_Signal1() is called.

$ ./example/CltExample 
    InitDBusCommunication: Client started.
    New thread created: Success
    run call in the client.
    Signal_1_Callback: String value: Server Signal1(13).
    client myMethod_1 call, in_arg = method1 synchronize call. out_arg = Server My_Method1 to output..
    client myMethodAsync_1 call, in_arg = method1 asynchronize call..
    client MethodCallback_1 call.
    Method1Callback: return value: Server My_Method1 to output..
    client myMethod_2 call, in_arg1 = 12, in_arg2 = 34, out_arg1 = Server MyMethod2 to output., out_arg2 = 46.
    client myMethodAsync_2 call, in_arg1 = 10, in_arg2 = 21.
    client MethodCallback_2 call.
    Method2Callback: return value: (Server MyMethod2 to output., 31).
    Signal_1_Callback: String value: Server Signal1(14).
    Signal_2_Callback: Int value: 15, String value: Server Signal2
    Signal_1_Callback: String value: Server Signal1(16).
    Signal_2_Callback: Int value: 17, String value: Server Signal2
    Signal_1_Callback: String value: Server Signal1(18).
    Signal_1_Callback: String value: Server Signal1(19).
    Signal_1_Callback: String value: Server Signal1(20).
    Signal_2_Callback: Int value: 21, String value: Server Signal2

源码下载地址：[https://gitee.com/RTplay/gdbus-p2p-demo][https_gitee.com_RTplay_gdbus-p2p-demo]

其中gdbus-example-peer.c是官方的示例代码，这个逻辑非常全，如果想减少不必要的调试可以参考这个文件。

[https_gitee.com_RTplay_gdbus-p2p-demo]: https://gitee.com/RTplay/gdbus-p2p-demo