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

尼克

发布时间：2025-12-18 14:55:02

680人浏览过

来源于php中文网

原创

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

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

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

核心设计思路

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

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

基础实现代码

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

立即学习“C++免费学习笔记（深入）”；

#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;
};
使用示例
定义具体事件并注册处理逻辑：

							
								
								
									百度MCP广场
									探索海量可用的MCP Servers
								
								下载 
							
						

立即学习“C++免费学习笔记（深入）”；
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;
}
扩展建议
可根据实际需求进一步增强功能：


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

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

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

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

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

c++的虚函数调用开销到底有多大？ (性能测试与分析)

c++如何处理命令行参数_c++ main函数argc与argv详解

C++里的mutable关键字怎么用？(允许在const函数中修改成员)

c++中如何使用std::enable_if_c++模板元编程SFINAE特性【汇总】

c++中如何实现简单的内存泄漏检测_c++重载new与delete操作符【详解】

c++速学教程(入门到精通)

c++怎么学习？c++怎么入门？c++在哪学？c++怎么学才快？不用担心，这里为大家提供了c++速学教程(入门到精通)，有需要的小伙伴保存下载就能学习啦！

下载

相关标签:

回调函数 ai c++ 架构 const 回调函数 void 指针继承接口 private Event 线程多线程 map function 事件异步

本站声明：本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn

上一篇：c++如何将数字转换为字符串 to_string()函数的使用【实用技巧】下一篇：C++如何解析JSON_使用nlohmann/json库处理C++中的JSON数据

作者最新文章

苹果手机怎么设置默认浏览器_iPhone Safari替换方法

2026-01-19 08:35

Laravel中如何配置环境变量.env_Laravel环境变量读取与生效方法【教程】

2026-01-19 08:49

composer如何将外部库映射到指定命名空间_composer自定义类库加载【实战】

2026-01-19 08:53

todesk和AnyDesk的对比分析_todesk与AnyDesk功能性能对比

2026-01-19 08:55

sublime如何安装Compare Side-By-Side_sublime文件对比插件【详解】

2026-01-19 08:57

CrazyGames官方网站链接 CrazyGames电脑在线免费玩

2026-01-19 09:02

Laravel Eloquent如何实现作用域(Scopes)来复用查询逻辑？ (全局与本地作用域)

2026-01-19 09:05

c++中如何使用std::distance计算迭代器间距离_c++容器技巧【汇总】

2026-01-19 09:18

电脑风扇狂转但CPU温度不高原因揭秘软件设置与清灰建议【实用贴士】

2026-01-19 09:24

失业金怎么领取领取条件及手机APP申请操作流程【指南】

2026-01-19 09:43

热门AI工具

DeepSeek

幻方量化公司旗下的开源大模型平台

AI大模型

开放平台

豆包大模型

字节跳动自主研发的一系列大型语言模型

AI大模型

通义千问

阿里巴巴推出的全能AI助手

AI大模型

腾讯元宝

腾讯混元平台推出的AI助手

文档处理

Excel 表格

文心一言

文心一言是百度开发的AI聊天机器人，通过对话可以生成各种形式的内容。

AI大模型

中文写作

讯飞写作

基于讯飞星火大模型的AI写作工具，可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

中文写作

写作工具

即梦AI

一站式AI创作平台，免费AI图片和视频生成。

图片拼接

图画生成

ChatGPT

最最强大的AI聊天机器人程序，ChatGPT不单是聊天机器人，还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

AI大模型

中文写作

智谱清言 - 免费全能的AI助手

AI大模型

PDF 文档

相关专题

c语言const用法

const是关键字，可以用于声明常量、函数参数中的const修饰符、const修饰函数返回值、const修饰指针。详细介绍：1、声明常量，const关键字可用于声明常量，常量的值在程序运行期间不可修改，常量可以是基本数据类型，如整数、浮点数、字符等，也可是自定义的数据类型；2、函数参数中的const修饰符，const关键字可用于函数的参数中，表示该参数在函数内部不可修改等等。

524

2023.09.20

javascriptvoid(o)怎么解决

javascriptvoid(o)的解决办法：1、检查语法错误；2、确保正确的执行环境；3、检查其他代码的冲突；4、使用事件委托；5、使用其他绑定方式；6、检查外部资源等等。本专题为大家提供相关的文章、下载、课程内容，供大家免费下载体验。

175

2023.11.23

java中void的含义

本专题整合了Java中void的相关内容，阅读专题下面的文章了解更多详细内容。

2025.11.27

硬盘接口类型介绍

硬盘接口类型有IDE、SATA、SCSI、Fibre Channel、USB、eSATA、mSATA、PCIe等等。详细介绍：1、IDE接口是一种并行接口，主要用于连接硬盘和光驱等设备，它主要有两种类型：ATA和ATAPI，IDE接口已经逐渐被SATA接口；2、SATA接口是一种串行接口，相较于IDE接口，它具有更高的传输速度、更低的功耗和更小的体积；3、SCSI接口等等。

1023

2023.10.19

PHP接口编写教程

本专题整合了PHP接口编写教程，阅读专题下面的文章了解更多详细内容。

2025.10.17

php8.4实现接口限流的教程

PHP8.4本身不内置限流功能，需借助Redis（令牌桶）或Swoole（漏桶）实现；文件锁因I/O瓶颈、无跨机共享、秒级精度等缺陷不适用高并发场景。本专题为大家提供相关的文章、下载、课程内容，供大家免费下载体验。

444

2025.12.29

线程和进程的区别

线程和进程的区别：线程是进程的一部分，用于实现并发和并行操作，而线程共享进程的资源，通信更方便快捷，切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

481

2023.08.10

Python 多线程与异步编程实战

本专题系统讲解 Python 多线程与异步编程的核心概念与实战技巧，包括 threading 模块基础、线程同步机制、GIL 原理、asyncio 异步任务管理、协程与事件循环、任务调度与异常处理。通过实战示例，帮助学习者掌握如何构建高性能、多任务并发的 Python 应用。

143

2025.12.24

PHP WebSocket 实时通信开发

本专题系统讲解 PHP 在实时通信与长连接场景中的应用实践，涵盖 WebSocket 协议原理、服务端连接管理、消息推送机制、心跳检测、断线重连以及与前端的实时交互实现。通过聊天系统、实时通知等案例，帮助开发者掌握使用 PHP 构建实时通信与推送服务的完整开发流程，适用于即时消息与高互动性应用场景。

2026.01.19

热门下载

网站特效

网站源码

网站素材

前端模板