简单的c++实现消息发布/订阅机制例子（成员函数被其他类掉调用的例子）

以下是一个简单的使用 C++ 实现发布 / 订阅机制的示例代码。这个示例包含一个简单的事件系统，其中有发布者（Publisher）和订阅者（Subscriber）。

以下代码需要C++11以上支持

#include <iostream>
#include <vector>
#include <functional>// 事件参数结构体，可以根据实际需求修改
struct EventData {int value;
};// 事件处理函数类型定义
using EventHandler = std::function<void(const EventData&)>;// 发布者类
class Publisher {
public:void publish(const EventData& data) {for (const auto& handler : subscribers) {handler(data);}}void subscribe(EventHandler handler) {subscribers.push_back(handler);}private:std::vector<EventHandler> subscribers;
};// 订阅者类示例
class Subscriber {
public:Subscriber(const std::string& name) : name(name) {}void onEvent(const EventData& data) {std::cout << name << " received event with value: " << data.value << std::endl;}private:std::string name;
};int main()
{Publisher publisher;Subscriber sub1("Subscriber 1");Subscriber sub2("Subscriber 2");// 订阅者注册事件处理函数,这里将sub1的onEvent成员函数，传入到publisher的容器中，被后续publish触发调用。publisher.subscribe(std::bind(&Subscriber::onEvent, sub1, std::placeholders::_1));publisher.subscribe(std::bind(&Subscriber::onEvent, sub2, std::placeholders::_1));EventData event = { 42 };publisher.publish(event);EventData event2 = { 43 };publisher.publish(event2);return 0;
}

在这个示例中：

1. Publisher类
   • 有一个publish方法，用于遍历所有订阅者的事件处理函数，并调用它们，将事件数据传递给每个订阅者。
   • 有一个subscribe方法，用于将订阅者的事件处理函数添加到subscribers向量中。
2. Subscriber类
   • 每个订阅者有一个onEvent方法，这个方法定义了订阅者如何处理接收到的事件。在main函数中，通过std::bind将Subscriber的onEvent方法绑定到Publisher的subscribe方法上，从而注册为事件处理函数。
3. 在main函数中：
   • 创建了一个Publisher对象和两个Subscriber对象。
   • 两个Subscriber对象分别订阅了Publisher发布的事件。
   • 然后创建一个EventData对象，并通过Publisher的publish方法发布这个事件，此时所有订阅者都会接收到这个事件并进行相应的处理。

注意，这是一个非常基础的发布 / 订阅机制示例，在实际应用中，可能需要更多的功能，如事件类型的区分、动态订阅 / 取消订阅、多线程安全性等。