分布式通信：发布订阅通信方式，请使用C加加语言写出一个完整示例程序

下面是一个使用C++语言实现的发布-订阅通信方式的简单示例程序： ```cpp #include <iostream> #include <string> #include <vector> // 订阅者类 class Subscriber { public: void receiveMessage(const std::string& message) { std::cout << "Received message: " << message << std::endl; } }; // 发布者类 class Publisher { public: void publishMessage(const std::string& message) { notifySubscribers(message); } void subscribe(Subscriber* subscriber) { subscribers.push_back(subscriber); } void unsubscribe(Subscriber* subscriber) { for (auto it = subscribers.begin(); it != subscribers.end(); ++it) { if (*it == subscriber) { subscribers.erase(it); break; } } } private: void notifySubscribers(const std::string& message) { for (auto subscriber : subscribers) { subscriber->receiveMessage(message); } } std::vector<Subscriber*> subscribers; }; int main() { // 创建发布者和订阅者对象 Publisher publisher; Subscriber subscriber1, subscriber2; // 订阅者订阅主题 publisher.subscribe(&subscriber1); publisher.subscribe(&subscriber2); // 发布者发布消息 publisher.publishMessage("Hello, subscribers!"); // 订阅者取消订阅 publisher.unsubscribe(&subscriber2); // 发布者再次发布消息 publisher.publishMessage("How are you doing?"); return 0; } ``` 在这个示例程序中，我们定义了一个`Subscriber`类和一个`Publisher`类。`Subscriber`类表示订阅者，其中的`receiveMessage`函数用于接收消息并进行处理。`Publisher`类表示发布者，其中的`publishMessage`函数用于发布消息，`subscribe`和`unsubscribe`函数用于订阅和取消订阅主题。在`Publisher`类内部，使用一个`std::vector`容器来保存订阅者对象的指针，并通过`notifySubscribers`函数将消息通知给所有订阅者。 在`main`函数中，我们创建了一个发布者对象和两个订阅者对象，并进行了一系列的操作。首先，两个订阅者订阅了发布者的主题。然后，发布者发布了一条消息，并将其通知给所有订阅者。接着，一个订阅者取消了对主题的订阅。最后，发布者再次发布了一条消息，但这次只有一个订阅者接收到了消息。 运行该程序后，你将看到输出结果如下： ``` Received message: Hello, subscribers! Received message: Hello, subscribers! Received message: How are you doing? ``` 这个示例程序展示了一个简单的发布-订阅通信方式的实现，通过发布者发布消息并将其通知给所有订阅者，订阅者接收到消息并进行处理。你可以根据实际需求对该示例进行扩展和改进。