碼上快樂

相關內容    簡體    繁體

DBus 入門與應用－－基本概念 下（C API 級別的使用觀點）

本文轉載自   查看原文   2012-12-09 23:45   6635    [112] IPC 通信/ [111] Linux編程

轉載請注明出處               作者： 唐風

 

通信數據的設置和獲取

前篇主要是有講一些相對高層的概念，比如 object，interface，method 之類的，對於這些“C 本來沒有的東西”，如何在 DBus 中表現的確實很讓我迷惑了一陣。但通信數據的發送可能比前面那些名稱好理解得多。因為這些概念都是很本來就是底層的，很 C 的。

DBus 提供了一個 DBusMessageIter 的類型，使用這個類型的變量，我們就可以向 DBusMessage 中很容易地加入數據，也可以很容易地從中取出數據。

  1. DBusMessage* msg;
  2. DBusMessageIter args;
  3.  
  4. // msg...
  5.  
  6. dbus_message_iter_init_append(msg, &args);
  7. dbus_uint32_t my_data = 10;
  8. if(!dbus_message_iter_append_basic(&args, DBUS_TYPE_UINT32, &my_data)) {
  9.     printf("Out of memory\n");
  10.     return RES_FAILED;
  11. }
  12.  
  13. dbus_connection_flush(conn);
  14. dbus_message_unref(msg);

第 2 行的代碼聲明了一個 DBusMessageIter 的對象 args，第 6 行的代碼處，對 args 進行初始化，這可以讓一個 DBusMessageIter 對象與對應的 DBusMessage 關聯起來，后面再對 DBusMessageIter的時候（設置或者取得數據），就是對相應的 DBusMessage 進行處理。然后使用第8行的函數，將一個 uint32 的數據 my_data 追加到 msg 中了。如果還要追加新的參數的話，只需要繼續調用該函數，並傳入適當的參數就可以了。

  1. dbus_bool_t dbus_message_iter_append_basic(DBusMessageIter * iter,
  2.                                                           inttype,
  3.                                            const void *      value
  4.                                            )

這個函數可以用來向 DBusMessageIter 中追加一些“基本類型”（basic）的數據，所謂基本類型的數據，在 DBus 中是這么定義的：

Conventional Name

Encoding

Alignment

BYTE

A single 8-bit byte.

1

BOOLEAN

As for UINT32, but only 0 and 1 are valid values.

4

INT16

16-bit signed integer in the message's byte order.

2

UINT16

16-bit unsigned integer in the message's byte order.

2

INT32

32-bit signed integer in the message's byte order.

4

UINT32

32-bit unsigned integer in the message's byte order.

4

INT64

64-bit signed integer in the message's byte order.

8

UINT64

64-bit unsigned integer in the message's byte order.

8

DOUBLE

64-bit IEEE 754 double in the message's byte order.

8

STRING

A UINT32 indicating the string's length in bytes excluding its terminating nul, followed by non-nul string data of the given length, followed by a terminating nul byte.

4

(for the length)
OBJECT_PATH Exactly the same as STRING except the content must be a valid object path (see below).

4

(for the length)

（參考 DBus 的在線 API 的 Marshaling (Wire Format) 一節）

有 basic type，當然也就有更復雜的不是 basic 的類型，但這和基本概念的關系不大，在這篇文章中就不多介紹了。（請參考我其它的 DBus 博文）

到現在為止，我已經知道如何把數據入到一個 DBusMessage 中了，那么，如何從一個 DBusMessage 中取出數據呢？比如，我在 A 進程使用上面的代碼把 my_data 加到 DBusMessage 中了，現在 B 進程取到了 DBusMessage，如何把數據取出來呢？

  1. DBusMessage* msg;
  2. DBusMessageIter args;
  3.  
  4. // get a DBusMessage from process A
  5.  
  6. if(!dbus_message_iter_init(msg, &args)) {
  7.     printf("dbus_message_iter_init error, msg has no arguments!\n");
  8. }
  9. else if (DBUS_TYPE_UINT32 != dbus_message_iter_get_arg_type(&args)){
  10.     printf("not a uint 32 type !\n");
  11. }
  12. else {
  13.     dbus_uint32_t my_age = 0;
  14.     dbus_message_iter_get_basic(&args, &my_age);
  15.     printf("Got signal with value %d\n", my_age);
  16. }

很簡單，一樣的先使用 dbus_messge_iter_init 先把 DBusMessage 對象和從 DBus 總線中取到的 msg 關聯起來。這樣，使用第 9 行的函數先取得第一個通信數據中第一個參數的類型，如果類型無誤的話可以進而使用第 14 行的函數取得參數值本身。

這樣，一個簡單的數據如何入到 DBusMessage 中，又如何從 DBusMessage 中取出來就明白了。那么如何將 DBusMessage 在進程之間傳遞呢？

消息的發送和獲取

消息的發送其實比較簡單，當進程 A 准備申請好一個 DBusMessage對象，設置好它的“類型”（就是各種名字），放好需要通信的數據，之后，使用下面的代碼就可以將數據發送到總線上：

  1. dbus_uint32_t serial = 0;
  2.  
  3. if(!dbus_connection_send(conn, msg, &serial)) {
  4.     printf("Out of memory");
  5.     return RES_FAILED;
  6. }
  7. dbus_connection_flush(conn);

這很簡單，只是 dbus_connection_flush 這個函數有點突兀，它的作用是“Blocks until the outgoing message queue is empty.”，可以簡單地理解為調用這個函數可以使用得發送進程一直等消息發送完了才能繼續運行。

接受方的代碼也很簡單：

  1. dbus_connection_read_write(conn, 0);
  2. msg = dbus_connection_pop_message(conn);
  3.  
  4. if(NULL == msg) {
  5.     sleep(1);
  6.     continue;
  7. }

使用 1 和 2 行的代碼就可以取出發送到本進程的消息，之后就可以使用 msg （如果 msg 不是 NULL 的話）來獲取通信數據了。

 

到這里，基本概念就有了。后面，應該對 DBus 的細節再深入的探索。

 

Sample 代碼：

發送方進程(my_client)：

My_Client.cpp
  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <dbus/dbus.h>
  4. #include <unistd.h>
  5.  
  6. const int RES_SUCCESS = -1;
  7. const int RES_FAILED  = 0;
  8.  
  9. int my_dbus_initialization(char const * _bus_name, DBusConnection ** _conn) {
  10.     DBusError err;
  11.  
  12.     int ret;
  13.  
  14.     dbus_error_init(&err);
  15.  
  16.     *_conn = dbus_bus_get(DBUS_BUS_SESSION, &err);
  17.     if(dbus_error_is_set(&err)) {
  18.         printf("Connection Error\n");
  19.         dbus_error_free(&err);
  20.         return RES_FAILED;
  21.     }
  22.  
  23.     ret = dbus_bus_request_name(*_conn, _bus_name, DBUS_NAME_FLAG_REPLACE_EXISTING, &err);
  24.     if(dbus_error_is_set(&err)){
  25.         printf("Requece name error \n");
  26.         dbus_error_free(&err);
  27.         return RES_FAILED;
  28.     }
  29.  
  30.     if(DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER != ret) {
  31.         return RES_FAILED;
  32.     }
  33.  
  34.     return RES_SUCCESS;
  35. }
  36.  
  37. int my_dbus_send_sigal(DBusConnection * conn) {
  38.     dbus_uint32_t serial = 0;
  39.     DBusMessage* msg;
  40.     DBusMessageIter args;
  41.     char sigvalue[20] = "liyiwen";
  42.  
  43.     msg = dbus_message_new_signal("/test/signal/Object",  // object name
  44.         "test.signal.Type",     // interface name
  45.         "Test");                // name of signal
  46.  
  47.     if (NULL == msg) {
  48.         printf("Message Null");
  49.         return RES_FAILED;
  50.     }
  51.  
  52.     dbus_message_iter_init_append(msg, &args);
  53.  
  54.     printf("%s\n", sigvalue);
  55.     dbus_uint32_t my_age = 10;
  56.     if(!dbus_message_iter_append_basic(&args, DBUS_TYPE_UINT32, &my_age)) {
  57.         printf("Out of memory\n");
  58.         return RES_FAILED;
  59.     }
  60.  
  61.     if(!dbus_connection_send(conn, msg, &serial)) {
  62.         printf("Out of memory");
  63.         return RES_FAILED;
  64.     }
  65.     dbus_connection_flush(conn);
  66.  
  67.     dbus_message_unref(msg);
  68.  
  69.     return RES_SUCCESS;
  70.  
  71. }
  72.  
  73. int main(int agrc, char** argv)
  74. {
  75.     DBusConnection * conn;
  76.  
  77.     printf("Start\n");
  78.     if (RES_FAILED == my_dbus_initialization("test.method.client", &conn)) {
  79.         exit(1);
  80.     }
  81.     my_dbus_send_sigal(conn);
  82.  
  83.     while(1){sleep(10);}
  84.  
  85.     return 0;
  86. }

接收方進程（my_server.cpp）

My_Server.cpp
  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <dbus/dbus.h>
  4. #include <unistd.h>
  5.  
  6. const int RES_SUCCESS = -1;
  7. const int RES_FAILED  = 0;
  8.  
  9. int my_dbus_initialization(char const * _bus_name, DBusConnection **_conn) {
  10.     DBusError err;
  11.     int ret;
  12.  
  13.     dbus_error_init(&err);
  14.  
  15.     *_conn = dbus_bus_get(DBUS_BUS_SESSION, &err);
  16.     if(dbus_error_is_set(&err)) {
  17.         printf("Connection Error(%s) \n", err.message);
  18.         dbus_error_free(&err);
  19.         return RES_FAILED;
  20.     }
  21.  
  22.     ret = dbus_bus_request_name(*_conn, _bus_name, DBUS_NAME_FLAG_REPLACE_EXISTING, &err);
  23.     if(dbus_error_is_set(&err)){
  24.         printf("Requece name error(%s) \n", err.message);
  25.         dbus_error_free(&err);
  26.         return RES_FAILED;
  27.     }
  28.     if(DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER != ret) {
  29.         return RES_FAILED;
  30.     }
  31.     return RES_SUCCESS;
  32. }
  33.  
  34. int main(int agrc, char** argv)
  35. {
  36.  
  37.     DBusError err;
  38.     DBusMessage* msg;
  39.     DBusMessageIter args;
  40.  
  41.     dbus_error_init(&err);
  42.     DBusConnection *conn;
  43.     if (RES_FAILED == my_dbus_initialization("test.method.server", &conn)) {
  44.         exit(1);
  45.     }
  46.  
  47.     dbus_bus_add_match(conn, "type='signal', interface='test.signal.Type'", &err);
  48.  
  49.     dbus_connection_flush(conn);
  50.     if(dbus_error_is_set(&err)) {
  51.         printf("dbus_bus_add_match err (%s)", err.message);
  52.         return RES_FAILED;
  53.     }
  54.  
  55.     while(1) {
  56.         dbus_connection_read_write(conn, 0);
  57.         msg = dbus_connection_pop_message(conn);
  58.  
  59.         if(NULL == msg) {
  60.             sleep(1);
  61.             continue;
  62.         }
  63.  
  64.         if(dbus_message_is_signal(msg, "test.signal.Type", "Test")) {
  65.             if(!dbus_message_iter_init(msg, &args)) {
  66.                 printf("dbus_message_iter_init error, msg has no arguments!\n");
  67.             }
  68.             else if (DBUS_TYPE_UINT32 != dbus_message_iter_get_arg_type(&args)){
  69.                 printf("not a uint 32 type !\n");
  70.             }
  71.             else {
  72.                 dbus_uint32_t my_age = 0;
  73.                 dbus_message_iter_get_basic(&args, &my_age);
  74.                 printf("Got signal with value %d\n", my_age);
  75.             }
  76.         }
  77.  
  78.         dbus_message_unref(msg);
  79.  
  80.     }
  81.  
  82.     return 0;
  83. }

參考資料：

  1. http://dbus.freedesktop.org/doc/dbus-specification.html  這當然是最權威最重要的資料，但我覺得不是一個很好的入門資料。
  2. http://dbus.freedesktop.org/doc/dbus-tutorial.html 這里面有一些不錯的例子，對Names 的解釋也很好，但用的是 glib 的 binding，不能探究更底層的動作一度還是讓我雲里霧里。
  3. http://dbus.freedesktop.org/doc/api/html/group__DBusMessage.html  DBus 的 C 編程接口的在線文檔，非常棒也非常有用
  4. http://dbus.freedesktop.org/doc/dbus/libdbus-tutorial.html 如何用 C API 層面的 DBus ，相見恨晚。


免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。



猜您在找 DBus 入門與應用－－基本概念 上（C API 級別的使用觀點） DBus 入門與應用 －－ DBus 的 C 編程接口 使用flink Table &Sql api來構建批量和流式應用(1)Table的基本概念 在windows下使用dbus Serverless 基本概念入門 SWIG 基本概念和入門 dbus使用講解- 下（轉） C# Marshal類基本概念和入門示例程序 C語言的基本概念 JTS基本概念和使用
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM