C++中如何设计事件总线_发布订阅模式

冰火之心

发布时间：2025-07-25 08:15:02

897人浏览过

来源于php中文网

原创

事件总线是一种解耦发布者与订阅者的通信机制，通过维护事件类型到订阅者列表的映射实现事件分发。1. 使用typeid获取事件类型并分发事件；2. 事件内存由事件总线在publish后释放；3. 避免性能瓶颈可采用异步处理、事件过滤、分层事件总线、线程池等策略；4. 处理异常可通过try-catch块、错误处理函数或返回值机制；5. 保证事件顺序可通过单线程处理、序列化到消息队列或使用版本号控制。

C++中如何设计事件总线_发布订阅模式

事件总线/发布订阅模式，简单来说，就是让不同的对象（发布者和订阅者）在不知道彼此的情况下进行通信。发布者发出事件，订阅者接收并处理感兴趣的事件。这是一种解耦的好方法，能让系统更灵活、可扩展。

解决方案

C++中实现事件总线，主要思路是维护一个事件类型到订阅者列表的映射。当某个事件发生时，事件总线负责通知所有订阅了该事件的订阅者。以下是一种基础实现方式，可以根据具体需求进行扩展：

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

#include 
#include 
#include 
#include 
#include 

// 定义事件基类
class Event {
public:
    virtual ~Event() = default;
};

// 定义事件处理函数的类型别名
using EventHandler = std::function;

// 事件总线类
class EventBus {
public:
    // 订阅事件
    void subscribe(const std::string& eventType, EventHandler handler) {
        subscribers_[eventType].push_back(handler);
    }

    // 取消订阅事件
    void unsubscribe(const std::string& eventType, EventHandler handler) {
        auto& subs = subscribers_[eventType];
        subs.erase(std::remove_if(subs.begin(), subs.end(),
                                  [&](const EventHandler& h) { return h.target() == handler.target(); }),
                   subs.end());
    }

    // 发布事件
    void publish(Event* event) {
        const std::string eventType = typeid(*event).name(); // 获取事件类型名称
        auto it = subscribers_.find(eventType);
        if (it != subscribers_.end()) {
            for (const auto& handler : it->second) {
                handler(event);
            }
        }
        delete event; // 重要：事件由发布者创建，总线负责传递，最后由总线释放内存
    }

private:
    std::map> subscribers_;
};

// 示例事件类
class ButtonClickEvent : public Event {
public:
    ButtonClickEvent(int buttonId) : buttonId_(buttonId) {}
    int buttonId() const { return buttonId_; }
private:
    int buttonId_;
};

// 示例订阅者类
class Logger {
public:
    void onButtonClick(Event* event) {
        ButtonClickEvent* clickEvent = dynamic_cast(event);
        if (clickEvent) {
            std::cout << "Button " << clickEvent->buttonId() << " clicked!" << std::endl;
        }
    }
};

int main() {
    EventBus bus;
    Logger logger;

    // 订阅事件
    bus.subscribe(typeid(ButtonClickEvent).name(), std::bind(&Logger::onButtonClick, &logger, std::placeholders::_1));

    // 发布事件
    bus.publish(new ButtonClickEvent(1));
    bus.publish(new ButtonClickEvent(2));

    return 0;
}

这个例子展示了如何定义事件、订阅事件、发布事件。关键点在于使用typeid来获取事件的类型信息，这使得我们可以根据事件类型来分发事件。注意，事件的内存管理是个需要考虑的问题，这里选择在publish函数中释放事件内存。

ChatX翻译

最实用、可靠的社交类实时翻译工具。支持全球主流的20+款社交软件的聊天应用，全球200+语言随意切换。让您彻底告别复制粘贴的翻译模式，与世界各地高效连接！

下载

如何避免事件总线成为性能瓶颈？

事件总线在大型系统中可能会成为性能瓶颈。想象一下，如果一个事件被成千上万的订阅者订阅，每次发布事件都需要通知所有订阅者，这会消耗大量的CPU和网络资源。可以考虑以下优化策略：

异步处理: 使用消息队列（例如RabbitMQ、Kafka）来实现事件总线。发布者将事件发送到消息队列，订阅者从消息队列中异步拉取事件。这样可以解耦发布者和订阅者，提高系统的吞吐量。
事件过滤: 允许订阅者指定更精确的过滤条件。例如，可以基于事件的内容进行过滤，只接收满足特定条件的事件。这可以减少订阅者需要处理的事件数量。
分层事件总线: 将事件总线分成多个层级。例如，可以有一个全局事件总线，用于处理全局性的事件；同时，可以有多个局部事件总线，用于处理特定模块的事件。这样可以减少单个事件总线的负载。
线程池: 使用线程池来并发地处理事件。这样可以提高事件总线的并发处理能力。

如何处理事件处理中的异常？

事件处理函数可能会抛出异常。如果事件总线直接调用事件处理函数，那么异常可能会导致程序崩溃。因此，需要一种机制来处理事件处理中的异常。

try-catch块: 在事件总线内部使用try-catch块来捕获事件处理函数抛出的异常。捕获到异常后，可以记录日志、发送告警，或者采取其他适当的措施。
错误处理函数: 允许订阅者注册一个错误处理函数。当事件处理函数抛出异常时，事件总线会调用该错误处理函数。错误处理函数可以负责记录日志、发送告警，或者采取其他适当的措施。
返回值: 要求事件处理函数返回一个状态码，表示事件处理是否成功。如果事件处理失败，事件总线可以记录日志、发送告警，或者采取其他适当的措施。

选择哪种方法取决于具体的需求。使用try-catch块是最简单的方法，但它可能会隐藏一些错误。使用错误处理函数可以提供更灵活的错误处理机制。使用返回值可以提供更明确的错误信息。

如何保证事件的顺序性？

在某些场景下，事件的顺序非常重要。例如，如果一个事件表示账户余额增加，另一个事件表示账户余额减少，那么这两个事件的顺序必须得到保证。否则，可能会导致账户余额错误。

单线程处理: 使用单线程来处理事件。这样可以保证事件按照发布的顺序被处理。但是，单线程处理可能会成为性能瓶颈。
序列化: 将事件序列化到消息队列中，然后使用单线程的消费者来消费消息。这样可以保证事件按照发布的顺序被处理，同时可以利用消息队列的持久化能力。
版本号: 为每个事件分配一个版本号。订阅者可以根据版本号来判断事件的顺序。如果订阅者收到的事件的版本号小于它已经处理过的事件的版本号，那么订阅者可以忽略该事件。

选择哪种方法取决于具体的需求。单线程处理是最简单的方法，但它可能会成为性能瓶颈。序列化可以保证事件的顺序，但它会增加系统的复杂性。版本号可以提供更灵活的顺序保证机制。

C++中引用和指针有什么区别？（代码说明）

c++如何打印函数堆栈信息_c++ backtrace函数与符号名解析【方法】

c++怎么实现高并发下的无锁队列_c++ std::atomic原子变量与CAS操作【详解】

c++ stringstream用法详解_c++字符串与数字转换利器

c++怎么用jemalloc c++替换默认内存分配器【性能】