/uSPF

uSPF(Micro Subscribe Publish Frame) 是一个轻量级“发布-订阅”模式的框架，适合嵌入式应用。

Primary LanguageCApache License 2.0Apache-2.0

uSPF

  • uSPF(Micro Subscribe Publish Frame)是一个轻量级发布-订阅模式的框架，甚至没有 broker(代理)，特别适合嵌入式应用，详细文档见uSPF微型框架的介绍。

编译

  • uSPF 库 引用了 ttlib_mirco，所以需要 --recursive 后缀。
git clone https://github.com/tangaoo/uSPF.git --recursive

cd uSPF

make

依赖

  • uSPF 框架依赖 ttlib_mirco库(即工程中dep目录)，具体可见项目主页。

用法

定义

typedef struct __demo_data_t
{
    const char* name;
    int a;
}demo_data_t, *demo_data_ref_t;

USPF_MSG_DEFINE(demo_topic, sizeof(demo_data_t));

注册

uspf_register(USPF_MSG_ID(demo_topic), NULL);

订阅

  • 异步注册，poll 时不会阻塞。
uspf_node_ref_t node = uspf_subscribe(USPF_MSG_ID(demo_topic), USPF_ASYNC, tt_null);
  • 同步注册，poll 时会阻塞。
uspf_node_ref_t node = uspf_subscribe(USPF_MSG_ID(demo_topic), USPF_SYNC, tt_null);

发布

uspf_publish(USPF_MSG_ID(demo_topic), &data);

轮询（同步/非同步）

  • 异步轮询，非阻塞。
uspf_poll(node);
  • 同步轮询，阻塞。
uspf_poll_sync(node);

获取数据

uspf_copy(USPF_MSG_ID(demo_topic), node, &data);

补充

  • publish 代码与 subscribe 代码分属不同文件时，一般定义 topic 放在 publish 部分，而声名放在 subscribe 部分。
  • 详细部分参见example。

TODO

  • 引入 ttlib_mirco 库，替换目前的链表操作;
  • 目前仅支持数据包形式订阅，后续需要支持纯流数据的支持，用 ringbuffer 实现;
  • 目前仅支持单进程内部订阅与发布，后续需支持多进程。
  • 引入 protobuf。