个人笔记

外观

2026-09-22
1600
6.2m

iceoryx2 黑板机制：共享内存配置分发 ​

在基于 iceoryx2 的分布式系统里，pub-sub 是最常用的通信模型，但用它分发配置类数据并不划算：每个订阅者都要在共享内存中预留一份完整的数据槽位，配置越大、节点越多，冗余越严重。iceoryx2 提供的第三种通信模型——黑板（Blackboard）——把这类「一份配置、多方读写」的数据集中到一块共享内存中，所有节点访问同一份数据。本文介绍黑板模型的适用场景、核心约束与 C++ 实现方式，适合正在使用或评估 iceoryx2 的开发者。

为什么配置分发不适合 pub-sub ​

pub-sub 的零拷贝是「每条链路各一份」的零拷贝：发布者写入一次，每个订阅者都有自己独立的数据槽位，通过引用计数管理生命周期。这对传感器数据流是合理的设计，但对配置类数据会造成成倍的内存冗余：

  • 传统 pub-sub：1MB 配置分发给 1000 个订阅者，共享内存中要预留 1001 份（1000 个订阅者槽位 + 1 个发布者槽位），约 1001MB；
  • 黑板模式：全部节点共享同一块 1MB 黑板内存，外加少量键值元数据。

典型适用场景：

  • 集中管理大量配置参数（传感器采样频率、电压阈值等），需要动态更新和全局共享；
  • 配置体积较大、读取方众多，内存占用是主要矛盾。

黑板模型：创建者与打开者 ​

黑板在共享内存中维护一组键值对，访问者分两种角色：

  • 创建者（creator）：唯一的一个节点，负责创建黑板服务、初始化所有键和默认值，并持有可写句柄；
  • 打开者（opener）：任意多个节点，打开已存在的黑板服务，按键获取句柄读取或更新值。

所有句柄指向同一块内存，创建者或任一打开者的更新立即对所有读取方可见，没有消息拷贝和传递过程。

C++ 实现 ​

以「全局配置服务」为例：一个配置管理节点维护电池阈值与传感器更新频率，一个传感器节点读取频率并按它控制数据发布节奏。代码基于 iceoryx2 官方文档的 blackboard 示例。

写入端（配置管理节点） ​

cpp
#include "iceoryx2.hpp"
#include "iox2/container/static_string.hpp"

using namespace iox2;

int main() {
    auto node = NodeBuilder().create<ServiceType::Ipc>().value();

    // 配置键类型：StaticString 跨语言兼容（Rust/Python/C 均可构造）
    using KeyType = container::StaticString<50>;

    auto battery_key = container::StaticString<50>::from_utf8("battery_threshold");
    auto us_sensor_key = container::StaticString<50>::from_utf8("ultra_sonic_sensor_update_rate_in_ms");
    if (!battery_key.has_value() || !us_sensor_key.has_value()) {
        std::cerr << "Blackboard keys could not be created." << std::endl;
        return 1;
    }

    // 创建黑板服务：声明创建者角色，并初始化所有键的默认值
    auto service = node.service_builder(ServiceName::create("global_config").value())
                       .blackboard_creator<KeyType>()
                       // 电池阈值默认 25%
                       .template add<float>(battery_key.value(), 0.25)
                       // 传感器更新频率默认 100ms
                       .template add<uint32_t>(us_sensor_key.value(), 100)
                       .create()
                       .value();

    auto writer = service.writer_builder().create().value();

    // 按键获取类型安全的条目句柄
    auto battery_threshold_handle = writer.template entry<float>(battery_key.value()).value();
    auto update_rate_handle = writer.template entry<uint32_t>(us_sensor_key.value()).value();

    while (node.wait(iox2::bb::Duration::from_millis(100)).has_value()) {
        // 从上游获取新值并写入黑板（浅拷贝，所有读取方立即可见）
        auto new_battery_threshold = get_battery_threshold();
        if (new_battery_threshold.has_value()) {
            battery_threshold_handle.update_with_copy(new_battery_threshold.value());
        }

        auto new_update_rate = get_update_rate();
        if (new_update_rate.has_value()) {
            update_rate_handle.update_with_copy(new_update_rate.value());
        }
    }

    return 0;
}

读取端（配置使用节点） ​

cpp
#include "iceoryx2.hpp"
#include "iox2/container/static_string.hpp"

using namespace iox2;

int main() {
    auto node = NodeBuilder().create<ServiceType::Ipc>().value();

    // 键类型必须与写入端一致
    using KeyType = container::StaticString<50>;

    // 以打开者身份访问已存在的黑板服务
    auto service = node.service_builder(ServiceName::create("global_config").value())
                       .blackboard_opener<KeyType>()
                       .open()
                       .value();

    auto reader = service.reader_builder().create().value();

    auto us_sensor_key = container::StaticString<50>::from_utf8("ultra_sonic_sensor_update_rate_in_ms").value();
    auto update_rate_handle = reader.template entry<uint32_t>(us_sensor_key).value();

    // 读取方同时可以用普通 pub-sub 发布数据
    auto publisher_service = node.service_builder(ServiceName::create("ultrasonic_sensor").value())
                                 .publisher<Distance>()
                                 .create()
                                 .value();
    auto publisher = publisher_service.writer_builder().create().value();

    while (true) {
        // 每轮循环重新读取黑板，拿到最新配置值
        uint32_t current_update_rate = *update_rate_handle.get();

        if (!node.wait(iox2::bb::Duration::from_millis(current_update_rate)).has_value()) {
            break;
        }

        auto sample = publisher.loan_uninit().value();
        auto initialized_sample = sample.write_payload(
            Distance { get_ultra_sonic_sensor_distance(), 42.0 }
        );
        send(std::move(initialized_sample)).value();
    }

    return 0;
}

读取端主循环的写法值得注意：等待时长直接来自黑板中的当前值，配置更新后不需要重启进程，下一轮循环自动生效。

关键约束与适用边界 ​

  • 单一创建者：所有键和默认值必须由唯一一个创建者节点初始化，其余节点只能以打开者身份访问。这意味着黑板的键集合在创建时确定，不适合运行时动态增删键。
  • 类型安全：entry<T>() 在编译期和运行时校验类型，与创建时不一致的类型访问会返回错误，而不是静默读到脏数据。
  • 数据类型限制：值必须是平凡可拷贝（trivially copyable）、与共享内存兼容的类型——适合标量、小型 POD 结构，不适合持有指针或动态分配内存的对象。
  • 跨语言键类型：多语言混合部署时，键要用整数或 StaticString 这类各语言都能构造的类型。
  • 不是消息队列：黑板只保存每个键的最新值，没有历史、没有排队语义；需要消息流语义时仍应使用 pub-sub。

结语 ​

黑板模式解决的是配置类数据的分发效率问题，可以概括为三点：一是一份内存多方共享，把 pub-sub 的「每链路一份」变为「全局一份」，内存占用与节点数解耦；二是创建者-打开者角色划分，键与默认值由单一节点集中初始化，其余节点按键读写，更新即时可见；三是类型安全的句柄访问，编译期与运行时双重校验，避免共享内存场景下最危险的静默类型错配。在 iceoryx2 系统中，配置、参数、状态标志这类「最新值即全部信息」的数据都适合走黑板，消息流仍交给 pub-sub。

参考 ​

最近更新

基于 VitePress 构建

Copyright © 2026 ww1820