当前位置：首页 > wzjs >正文

网站开发企业标准互联网推广中心

wzjs 2025/9/21 12:46:14

网站开发企业标准,互联网推广中心,广东门户网站建设,网站中文名注册1，引入 ubus提供了一种多进程通信的机制。存在一个守护进程ubusd，所以进程都注册到ubusd，ubusd进行消息的接收、分发管理。 ubus对多线程支持的不好，例如在多个线程中去请求同一个服务，就有可能出现不可预知的结果。 …

1，引入

ubus提供了一种多进程通信的机制。存在一个守护进程ubusd，所以进程都注册到ubusd，ubusd进行消息的接收、分发管理。

ubus对多线程支持的不好，例如在多个线程中去请求同一个服务，就有可能出现不可预知的结果。

ubus通信一共有三种实现方式：①端对端通信 ②订阅/通知 ③事件（广播）

2，ubus命令的使用

ubus list ：列出所有对象   
ubus -v list network.interface.lan : 查看指定对象的详细信息

ubus call network.interface.lan status ：执行指定对象的方法并获取返回结果

ubus listen [事件类型]: 实时接收指定或所有 ubus 事件

ubus send test.event '{"message":"Hello World"}'  ： 发送自定义事件

ubus subscribe mytest : 订阅mytest事件

3，向UBUS注册一个对象

主要步骤：uloop_init(); ubus_connect(NULL);ubus_add_uloop(ser_ctx);初始化object，ubus_add_object(ser_ctx, &sub_object);

代码实现：

int get_no_arg_info(struct ubus_context *ctx, struct ubus_object *obj,struct ubus_request_data *req, const char *method,struct blob_attr *msg)
{struct blob_buf b = {};blob_buf_init(&b, 0);blobmsg_add_string(&b, "obj_name", obj->name);blobmsg_add_u32(&b, "pid", (uint32_t)getpid());blobmsg_add_u32(&b, "uptime", (uint32_t)time(NULL));ubus_send_reply(ctx, req, b.head);blob_buf_free(&b);return 0;
}enum parm_num {T_ID = 0,T_NAME,T_AGE,T_MAX
};static const struct blobmsg_policy t_policy[] = {[T_ID]   = { .name = "id", .type = BLOBMSG_TYPE_INT32 },[T_NAME] = { .name = "name", .type = BLOBMSG_TYPE_STRING },[T_AGE]  = { .name = "age", .type = BLOBMSG_TYPE_INT32 },
};int get_arg_info(struct ubus_context *ctx, struct ubus_object *obj,struct ubus_request_data *req, const char *method,struct blob_attr *msg)
{int i = 0;struct blob_attr *tb[T_MAX];blobmsg_parse(t_policy, ARRAY_SIZE(t_policy), tb, blob_data(msg), blob_len(msg));for(i = 0; i < T_MAX; i++){if(!tb[i]){fprintf(stderr, "Failed to parse arg '%d'.\n", i);return -1;}}printf("-->id:   %d\n", blobmsg_get_u32(tb[T_ID]));printf("-->name: %s\n", blobmsg_get_string(tb[T_NAME]));printf("-->age:  %d\n", blobmsg_get_u32(tb[T_AGE]));return 0;
}static const struct ubus_method test_obj_methods[] = {UBUS_METHOD_NOARG("get_no_arg_info", get_no_arg_info),UBUS_METHOD( "get_arg_info", get_arg_info, t_policy),
};static struct ubus_object_type test_obj_type = UBUS_OBJECT_TYPE("test.service", test_obj_methods);static struct ubus_object test_object = {.name = "test.service",.type = &test_obj_type,.methods = test_obj_methods,.n_methods = ARRAY_SIZE(test_obj_methods),
};int main()
{int ret = 0;struct ubus_context *mytest_ctx = NULL;uloop_init();mytest_ctx = ubus_connect(NULL);if(!mytest_ctx) {fprintf(stderr, "Failed to connect ubus.\n");return ERROR;}ret = ubus_add_object(mytest_ctx, &test_object);if(ret) {fprintf(stderr, "Failed to add 'mytest' obj.\n");return ERROR;}ubus_add_uloop(mytest_ctx);uloop_run();ubus_free(mytest_ctx);uloop_done();
}

测试：