欢迎来到雄杰鑫电商资讯网
技术教程

c++如何实现一个事件总线(Event Bus)_c++松耦合的组件通信架构

尼克 次阅读
事件总线通过解耦发布与订阅实现组件通信，核心包含事件基类、订阅回调和分发器，支持类型安全与线程安全，适用于C++中构建松耦合系统。

在C++中实现一个事件总线（Event Bus）是构建松耦合系统的一种有效方式，尤其适用于模块间需要通信但又不希望直接依赖的场景。事件总线允许组件发布事件，并由感兴趣的组件订阅和响应，从而解耦生产者与消费者。

核心设计思路

事件总线的核心是将“发送消息”和“处理消息”的逻辑分离。它通常包含以下几个关键部分：

  • 事件基类：所有具体事件继承自一个公共基类，便于统一管理。
  • 订阅者接口：定义接收事件的回调机制。
  • 事件分发器：维护事件类型到回调函数的映射，并负责广播事件。
  • 线程安全支持（可选）：多线程环境下需加锁保护共享数据。

基础实现代码

下面是一个简洁、类型安全的同步事件总线实现：

#include 
#include 
#include 
#include 
#include 
#include 

// 事件基类
struct Event {
virtual ~Event() = default;
};
// 事件总线类
class EventBus {
public:
// 订阅某个类型的事件
template
void subscribe(F&& callback) {
static_assert(std::is_base_of_v, "T must derive from Event");
    std::lock_guardzuojiankuohaophpcnstd::mutexyoujiankuohaophpcn lock(m_mutex);
    m_callbacks[std::type_index(typeid(T))].push_back(
        [func = std::forwardzuojiankuohaophpcnFyoujiankuohaophpcn(callback)](const Event* e) {
            func(static_castzuojiankuohaophpcnconst T*youjiankuohaophpcn(e));
        }
    );
}

// 发布事件
void publish(const Event* event) {
    if (!event) return;

    std::type_index type_idx = std::type_index(typeid(*event));
    std::lock_guardzuojiankuohaophpcnstd::mutexyoujiankuohaophpcn lock(m_mutex);

    auto it = m_callbacks.find(type_idx);
    if (it != m_callbacks.end()) {
        for (const auto& handler : it-youjiankuohaophpcnsecond) {
            handler(event);
        }
    }
}

// 清除所有订阅（可选）
void clear() {
    std::lock_guardzuojiankuohaophpcnstd::mutexyoujiankuohaophpcn lock(m_mutex);
    m_callbacks.clear();
}
private:
std::map<:type_index std::vector event>>> m_callbacks;
std::mutex m_mutex;
};


使用示例


定义具体事件并注册处理逻辑：


struct PlayerJumpEvent : Event {
    int playerId;
    PlayerJumpEvent(int id) : playerId(id) {}
};

struct EnemySpawnEvent : Event {
float x, y;
EnemySpawnEvent(float x, float y) : x(x), y(y) {}
};
// 某个系统订阅事件
class MovementSystem {
public:
void onPlayerJump(const PlayerJumpEvent* evt) {
printf("MovementSystem: Player %d jumped\n", evt->playerId);
}
};
class CombatSystem {
public:
void onEnemySpawn(const EnemySpawnEvent* evt) {
printf("CombatSystem: Enemy spawned at (%.2f, %.2f)\n", evt->x, evt->y);
}
};
// 使用
int main() {
EventBus bus;
MovementSystem movSys;
CombatSystem combatSys;
// 订阅事件
bus.subscribezuojiankuohaophpcnPlayerJumpEventyoujiankuohaophpcn([&](const PlayerJumpEvent* e) {
    movSys.onPlayerJump(e);
});

bus.subscribezuojiankuohaophpcnEnemySpawnEventyoujiankuohaophpcn([&](const EnemySpawnEvent* e) {
    combatSys.onEnemySpawn(e);
});

// 发布事件
PlayerJumpEvent jump(100);
bus.publish(&jump);

EnemySpawnEvent spawn(10.5f, 20.3f);
bus.publish(&spawn);

return 0;
}


扩展建议


可根据实际需求进一步增强功能：


    

  • 
异步分发：引入任务队列和工作线程，实现事件延迟或跨线程传递。
    • 

  • 
自动退订：使用智能指针或句柄机制，避免悬空回调。
    • 

  • 
优先级支持：为回调添加执行顺序控制。
    • 

  • 
模板特化优化：对高频事件做快速路径处理。
    • 



基本上就这些。这个轻量级实现足以支撑大多数中小型项目的组件通信需求，同时保持低耦合和高可测试性。根据项目复杂度，可以逐步迭代功能。不复杂但容易忽略的是生命周期管理和线程安全细节。 






            
 ai 是一个 的是 几个 适用于 接口 感兴趣 架构 事件 线程 多线程 function 可选 继承 map c++ 退订 Event const 特化 指针 异步 回调函数 private 回调 void 句柄

相关文章

按ESC键退出。