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

下面是一个使用C++语言实现的发布-订阅通信方式的简单示例程序：

#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?

这个示例程序展示了一个简单的发布-订阅通信方式的实现，通过发布者发布消息并将其通知给所有订阅者，订阅者接收到消息并进行处理。你可以根据实际需求对该示例进行扩展和改进。