你 这个问题 请使用C加加实现 分布式通信：发布订阅的简单代码 第一次代码没有写完

当然，我可以帮你提供一个使用C++实现分布式通信的发布订阅模式的简单代码。以下是一个示例：

#include <iostream>
#include <vector>
#include <thread>
#include <functional>
#include <mutex>
#include <condition_variable>

// 定义一个简单的消息结构
struct Message {
    std::string topic;
    std::string content;
};

// 定义订阅者类
class Subscriber {
public:
    Subscriber(const std::string& topic) : topic(topic) {}

    void notify(const Message& message) {
        if (message.topic == topic) {
            std::cout << "Received message on topic '" << topic << "': " << message.content << std::endl;
        }
    }

private:
    std::string topic;
};

// 定义发布者类
class Publisher {
public:
    void subscribe(Subscriber* subscriber, const std::string& topic) {
        std::unique_lock<std::mutex> lock(mutex);
        subscribers[topic].push_back(subscriber);
    }

    void unsubscribe(Subscriber* subscriber, const std::string& topic) {
        std::unique_lock<std::mutex> lock(mutex);
        auto& topicSubscribers = subscribers[topic];
        topicSubscribers.erase(std::remove(topicSubscribers.begin(), topicSubscribers.end(), subscriber), topicSubscribers.end());
    }

    void publish(const Message& message) {
        std::unique_lock<std::mutex> lock(mutex);
        auto& topicSubscribers = subscribers[message.topic];
        for (auto subscriber : topicSubscribers) {
            subscriber->notify(message);
        }
    }

private:
    std::mutex mutex;
    std