/* 服务端代码 */
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <dbus/dbus.h>
void listen_signal()
{
DBusMessage * msg;
DBusMessageIter arg;
DBusConnection * connection;
DBusError err;
int ret;
char * sigvalue;
/* 步骤1:建立与D-Bus后台的连接 */
dbus_error_init(&err);
connection = dbus_bus_get(DBUS_BUS_SESSION, &err);
if(dbus_error_is_set(&err)) {
fprintf(stderr,"ConnectionError %s\n",err.message);
dbus_error_free(&err);
}
if(connection == NULL) {
return;
}
/* 步骤2:给连接名分配一个可记忆名字 getiot.singal.dest 作为 Bus name */
/* 这个步骤不是必须的,但推荐这样处理 */
ret =dbus_bus_request_name(connection, "getiot.singal.dest", DBUS_NAME_FLAG_REPLACE_EXISTING, &err);
if(dbus_error_is_set(&err)){
fprintf(stderr,"Name Error%s\n",err.message);
dbus_error_free(&err);
}
if(ret != DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER)
return;
/* 步骤3:通知 D-Bus daemon,希望监听来自接口 getiot.signal.Type 的信号 */
dbus_bus_add_match(connection, "type='signal',interface='getiot.signal.Type'", &err);
/* 实际需要发送东西给 daemon 来通知希望监听的内容,所以需要 flush */
dbus_connection_flush(connection);
if(dbus_error_is_set(&err)) {
fprintf(stderr, "Match Error%s\n", err.message);
dbus_error_free(&err);
}
/* 步骤4:在循环中监听,每隔开1秒,就去试图自己的连接中获取这个信号 */
/* 这里给出的是中连接中获取任何消息的方式,所以获取后去检查一下这个消息是否我们期望的信号,并获取内容 */
/* 我们也可以通过这个方式来获取 method call 消息 */
while(1) {
dbus_connection_read_write(connection, 0);
msg = dbus_connection_pop_message (connection);
if(msg == NULL) {
sleep(1);
continue;
}
if(dbus_message_is_signal(msg,"getiot.signal.Type","Test")) {
if(!dbus_message_iter_init(msg, &arg)) {
fprintf(stderr,"MessageHas no Param");
}
else if(dbus_message_iter_get_arg_type(&arg) != DBUS_TYPE_STRING) {
fprintf(stderr,"Param isnot string");
}
else {
dbus_message_iter_get_basic(&arg, &sigvalue);
}
printf("Recetive Singal Value : %s\n", sigvalue);
}
dbus_message_unref(msg);
} /* End of while */
}
int main(void)
{
printf("------Start Listen_signal!-------\n");
listen_signal();
return 0;
}
client.c
/* 客户端代码 */
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <dbus/dbus-glib.h>
#include <dbus/dbus.h>
#include <unistd.h>
int send_a_signal(char * sigvalue)
{
DBusError err;
DBusConnection * connection;
DBusMessage * msg;
DBusMessageIter arg;
dbus_uint32_t serial =0;
int ret;
dbus_error_init(&err);
/* 步骤1:建立与D-Bus后台的连接 */
connection =dbus_bus_get(DBUS_BUS_SESSION, &err);
if(dbus_error_is_set(&err)) {
fprintf(stderr, "ConnectionErr : %s\n", err.message);
dbus_error_free(&err);
}
if(connection == NULL) {
return -1;
}
/* 步骤2:给连接名分配一个 well-known 的名字作为 Bus name,这个步骤不是必须的 */
/* 可以用宏开关控制这段代码,调试时可以用这个名字来检查,是否已经开启了这个应用的另外的进程 */
#if 1
ret = dbus_bus_request_name(connection, "getiot.singal.source", DBUS_NAME_FLAG_REPLACE_EXISTING, &err);
if(dbus_error_is_set(&err)) {
fprintf(stderr, "Name Err :%s\n", err.message);
dbus_error_free(&err);
}
if(ret != DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER) {
return -1;
}
#endif
/* 步骤3:发送一个信号,需要指定这个信号的路径(即可以指向对象)、接口,以及信号名,创建一个 Message */
if((msg = dbus_message_new_signal("/getiot/signal/Object", "getiot.signal.Type", "Test")) == NULL) {
fprintf(stderr,"MessageNULL\n");
return -1;
}
/* 给这个信号(messge)具体的内容 */
dbus_message_iter_init_append(msg,&arg);
if(!dbus_message_iter_append_basic(&arg,DBUS_TYPE_STRING,&sigvalue)) {
fprintf(stderr,"Out OfMemory!\n");
return -1;
}
printf("Signal Send: %s\n",sigvalue);
/* 步骤4: 将信号从连接中发送 */
if( !dbus_connection_send(connection,msg,&serial)) {
fprintf(stderr,"Out of Memory!\n");
return -1;
}
dbus_connection_flush(connection);
printf("--------Success Signal Send----------\n");
/* 步骤5: 释放相关的分配的内存 */
dbus_message_unref(msg );
return 0;
}
int main(void)
{
printf("------Start Send_a_signal!-------\n");
send_a_signal("hello world");
return 0;
}